根据对象类型反序列化 JSON

Question

我正在创建一个以 JSON 消息形式接收请求的服务。我需要解析消息并根据请求类型采取适当的措施。例如（在伪代码中）：

switch(request.type) {
    case "NewOrder":
        createNewOrder(order);
        break;
    case "CancelOrder"
        cancelOrder(orderId);
        break;
}

似乎大多数 JSON API（至少那些为您执行对象映射的 API）都需要根对象类型来反序列化。有什么优雅的方法吗？

例如，在Jackson API（使用全对象映射）中，我需要调用映射器如下：

NewOrder newOrder = mapper.readValue(src, NewOrder.class);
CancelOrder cancelOrder = mapper.readValue(src. CancelOrder.class);

这意味着我需要在解析对象之前就知道它的类。我真正需要的是某种方法来查看 JSON 字符串，确定请求类型，然后调用适当的 readValue() 方法 - 如下所示：

String requestType = getRequestType(src);
switch(request.type) {
    case "NewOrder":
        NewOrder newOrder = mapper.readValue(src, NewOrder.class);
        createNewOrder(newOrder.order);
        break;
    case "CancelOrder"
        CancelOrder cancelOrder = mapper.readValue(src. CancelOrder.class);
        cancelOrder(cancelOrder.orderId);
        break;
}

是否可以使用 Jackson 或任何其他 Java JSON 解析器来做到这一点？我确信我可以转到较低级别并使用流式 API 或基于节点的 API，但如果可以的话，尽量避免这种复杂性。

Answer 1

如果使用Jackson将JSON输入解析成Map，可以快速获取类型信息。然后，您可以将该对象创建为所需的类，并使用ObjectMapper.convert 从您从 Jackson 获得的 Map 中配置该对象。

这是一个例子：

public class Test1 {
private String f;
private String b;

public void setFoo(String v) { f = v; }

public void setBim(String v) { b = v; }

public String toString() { return "f=" + f + ", b=" + b; }


public static void main(String[] args) throws Exception {
    String test = "{ \"foo\":\"bar\", \"bim\":\"baz\" }";
    ObjectMapper mapper = new ObjectMapper();
    HashMap map = mapper.readValue(new StringReader(test), HashMap.class);
    System.out.println(map);
    Test1 test1 = mapper.convertValue(map, Test1.class);
    System.out.println(test1);
}
}

Answer 2

您可以在订单周围使用包装器：

{
"NewOrder": {...}
}

或

{
"CancelOrder": {...}
}

更新：

class Wrapper {
    newOrder: NewOrder;
    cancelOrderId: Integer;
}

Wrapper wrapper = mapper.readValue(src, Wrapper.class);

if (wrapper.newOrder != null) {
    createNewOrder(wrapper.newOrder);
}
if (wrapper.cancelOrderId != null) {
    cancelOrder(wrapper.cancelOrderId);
}

Answer 3

假设订单只是数据，将责任委托给 DoSomethingService 并通过工厂生产服务可能会有所帮助：

Service service = takeActionFactory
    .buildTheRightServiceForTheValue(src);
service.takeAction();

工厂会解析 JSON 对象：

Service buildTheRightServiceForTheValue(src) {
    switch(request.type) {
    case "NewOrder":
        return new NewOrderService(mapper.readValue(src, NewOrder.class)); 
        break;
    case "CancelOrder"
        return new CancelOrderService(mapper.readValue(src. CancelOrder.class));
        break;
    }
    case "SomeOtherObject"
        return new SomeOtherService(mapper.readValue(src, SomeOtherService.class));
    }

具体的服务是服务的子类：

NewOrderService implements Service {
    private final NewOrder newOrder;
    /**constructor*/
    ...

    void takeAction() {
        createNewOrder(newOrder.order);
    }
}

Answer 4

感谢 Maurice、Simon 和 nzroller。结合您所有回复的想法，这就是我想出的解决方案。欢迎反馈。

public enum MessageType {
    NewOrder,
    CancelOrder
}

public class JsonMessage {
    private MessageType messageType;
    private Object payload;
    ...
}

public class Order {
    private String orderId;
    private String itemId;
    private int quantity;
    ...
}

public class NewOrder {
    private Order order;
    ...
}

public class CancelOrder {
    private String orderId;
    ...
}

以下是序列化 NewOrder 的方法：

JsonMessage jsonMessage =
    new JsonMessage(MessageType.NewOrder, newOrder);
ObjectMapper mapper = new ObjectMapper();
String jsonMessageString = mapper.writeValueAsString(jsonMessage);

为了反序列化，我首先将 JSON 字符串读入 JsonNode 的树中。然后我阅读了 messageType。最后，根据消息类型，我直接将payload作为Java对象读取。

JsonNode rootNode = mapper.readValue(jsonMessageString, JsonNode.class);

MessageType messageType =
    MessageType.valueOf(rootNode.path("messageType").getTextValue());

switch(messageType) {
    case NewOrder:
        NewOrder newOrder = mapper.readValue(
                rootNode.path("payload"), NewOrder.class);
        myOrderService.placeOrder(newOrder.getOrder());
        break;

    case CancelOrder:
        CancelOrder cancelOrder = mapper.readValue(
                rootNode.path("payload"), CancelOrder.class);
        myOrderService.cancelOrder(cancelOrder.getOrderId());
        break;
}