json - Spring集成，如何使用@Transformer从/到JSON转换？

Question

我的问题是如何在 SI 端点之间传递对象？

我发现的几乎每个示例都使用 XML 设置，我正在使用 Annotation 并且不知道如何解决此异常

Caused by: java.lang.IllegalArgumentException: Could not resolve 'json__TypeId__' in 'javaTypes'.
    at org.springframework.integration.support.json.AbstractJacksonJsonObjectMapper.createJavaType(AbstractJacksonJsonObjectMapper.java:68)
    at org.springframework.integration.support.json.Jackson2JsonObjectMapper.extractJavaType(Jackson2JsonObjectMapper.java:116)
    at org.springframework.integration.support.json.Jackson2JsonObjectMapper.extractJavaType(Jackson2JsonObjectMapper.java:52)
    at org.springframework.integration.support.json.AbstractJacksonJsonObjectMapper.fromJson(AbstractJacksonJsonObjectMapper.java:61)
    at org.springframework.integration.json.JsonToObjectTransformer.doTransform(JsonToObjectTransformer.java:87)
    at org.springframework.integration.transformer.AbstractTransformer.transform(AbstractTransformer.java:33)
    ... 18 more

例如，人们建议使用 xml 来解决这个问题

<bean class="org.springframework.amqp.support.converter.DefaultClassMapper">
    <property name="defaultType" value="foo.MyObject" />
</bean>

但是我正在使用注释创建转换器来处理从 channel 接收的消息，如下所示

    @Bean
    @Transformer(inputChannel="fromTcp", outputChannel="toHandler")
    JsonToObjectTransformer jsonToObjectTransformer() {
        ObjectMapper mapper = new ObjectMapper();       
        JsonObjectMapper<JsonNode, JsonParser> jm = new Jackson2JsonObjectMapper(mapper);
        return new JsonToObjectTransformer(jm);
    }

实际上我不知道如何在 SI 端点之间传递对象。我只能传递 String，SI 使用默认序列化将 String 处理为 byte[]，将 byte[] 处理为 String。

Answer 1

转换器需要知道要转换成什么类型​​；您收到的错误是因为您没有提供类型，因此它会回退到寻​​找包含类型信息的 header 。

相当于 xml 的是:

@Bean
@Transformer(inputChannel="fromTcp", outputChannel="toHandler")
JsonToObjectTransformer jsonToObjectTransformer() {
    return new JsonToObjectTransformer(MyObject.class);
}