使用StdDeserializer Jackson 2.5处理多态性

Question

我有三个从超级类（SensorData）继承的类

@JsonDeserialize(using = SensorDataDeserializer.class)
public abstract class SensorData {

}

public class HumiditySensorData extends SensorData {
}

public class LuminositySensorData extends SensorData {
}

public class TemperatureSensorData extends SensorData {
}

我想根据参数将一个json输入转换为其中一个类。我正在尝试使用Jackson StdDeserializer并创建一个自定义的反序列化程序

@Component
public class SensorDataDeserializer extends StdDeserializer<SensorData> {

    private static final long serialVersionUID = 3625068688939160875L;

    @Autowired
    private SensorManager sensorManager;

    private static final String discriminator = "name";

    public SensorDataDeserializer() {
        super(SensorData.class);
        SpringBeanProvider.getInstance().autowireBean(this);
    }

    @Override
    public SensorData deserialize(JsonParser parser,
            DeserializationContext context) throws IOException,
            JsonProcessingException {
        ObjectMapper mapper = (ObjectMapper) parser.getCodec();
        ObjectNode root = (ObjectNode) mapper.readTree(parser);
        ObjectNode sensor = (ObjectNode) root.get("data");
        String type = root.get(discriminator).asText();
        Class<? extends SensorData> clazz = this.sensorManager
                .getCachedSensorsMap().get(type).sensorDataClass();
        if (clazz == null) {
            // TODO should throw exception
            return null;
        }
        return mapper.readValue(sensor.traverse(), clazz);
    }
}

我的问题是，当我确定映射具体类的正确类型时，映射器再次调用自定义stdDeserializer。所以我需要一种方法来打破循环当我有正确的类型。stacktrace是下一个

java.lang.NullPointerException
at com.hp.psiot.mapping.SensorDataDeserializer.deserialize(SensorDataDeserializer.java:38)
at com.hp.psiot.mapping.SensorDataDeserializer.deserialize(SensorDataDeserializer.java:1)
at com.fasterxml.jackson.databind.ObjectMapper._readValue(ObjectMapper.java:3532)
at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:1868)
at com.hp.psiot.mapping.SensorDataDeserializer.deserialize(SensorDataDeserializer.java:47)
at com.hp.psiot.mapping.SensorDataDeserializer.deserialize(SensorDataDeserializer.java:1)
at com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:3560)
at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:2660)
at org.springframework.http.converter.json.AbstractJackson2HttpMessageConverter.readJavaType(AbstractJackson2HttpMessageConverter.java:205)
at org.springframework.http.converter.json.AbstractJackson2HttpMessageConverter.read(AbstractJackson2HttpMessageConverter.java:200)
at org.springframework.web.servlet.mvc.method.annotation.AbstractMessageConverterMethodArgumentResolver.readWithMessageConverters    (AbstractMessageConverterMethodArgumentResolver.java:138)
at org.springframework.web.servlet.mvc.method.annotation.RequestResponseBodyMethodProcessor.readWithMessageConverters(RequestResponseBodyMethodProcessor.java:184)
at org.springframework.web.servlet.mvc.method.annotation.RequestResponseBodyMethodProcessor.resolveArgument(RequestResponseBodyMethodProcessor.java:105)

输入示例

{
    "name":"temperature",
    "data": {
        "value":20
    }
}

我只包含stacktrace来显示映射器正在再次调用反序列化器。nullPointerException的原因是，当调用第二个ObjectMapper时，输入为

"value":20

因此，抛出了一个异常，因为我们没有确定类型的信息，也没有检查输入是否正确

如果可能的话，我希望避免使用JsonSubTypes和JsonTypeInfo。

提前道谢！

部分解

class ServiceData {
    @JsonDeserialize(using = SensorDataDeserializer.class)
    List<SensorData> sensors;

}

 @Component
 public class SensorDataDeserializer extends StdDeserializer<List<SensorData>> {

      private static final long serialVersionUID = 3625068688939160875L;

      @Autowired
      private SensorManager sensorManager;

      private static final String discriminator = "name";

      public SensorDataDeserializer() {
           super(SensorData.class);
            SpringBeanProvider.getInstance().autowireBean(this);
      }

      @Override
      public List<SensorData> deserialize(JsonParser parser,
                DeserializationContext context) throws IOException,
                JsonProcessingException {
           try {
                ObjectMapper mapper = (ObjectMapper) parser.getCodec();
                ArrayNode root = (ArrayNode) mapper.readTree(parser);
                int size = root.size();
                List<SensorData> sensors = new ArrayList<SensorData>();
                for (int i = 0; i < size; ++i) {
                     ObjectNode sensorHead = (ObjectNode) root.get(i);
                     ObjectNode sensorData = (ObjectNode) sensorHead.get("data");
                     String tag = sensorHead.get(discriminator).asText();
                     Class<? extends SensorData> clazz = this.sensorManager
                               .getCachedSensorsMap().get(tag).sensorDataClass();
                     if (clazz == null) {
                          throw new InvalidJson("unbound sensor");
                     }
                     SensorData parsed = mapper.readValue(sensorData.traverse(),
                               clazz);
                     if (parsed == null) {
                          throw new InvalidJson("unbound sensor");
                     }
                     sensors.add(parsed);
                }
                return sensors;
           } catch (Throwable e) {
                throw new InvalidJson("invalid data");
           }

      }
 }

希望它能帮助某人：）

Answer 1

为什么不直接使用@jsonTypeInfo？多态处理是它的特定用例。

在这种情况下,您需要使用如下内容：

@JsonTypeInfo(use=Id.NAME, include=As.PROPERTY, property="name")
@JsonSubTypes({ HumiditySensorData.class, ... }) // or register via mapper
public abstract class SensorData { ... }

@JsonTypeName("temperature")
public class TemperaratureSensorData extends SensorData {
   public TemperaratureSensorData(@JsonProperty("data") JsonNode data) {
     // extract pieces out
  }
}

这将处理从“name”到子类型的解析，将“data”的内容绑定为jsonnode（或者，如果您愿意，可以使用map或object或任何匹配的类型）。