Spring Integration中使用.handle(自定义POJO类)转换返回null问题排查

核心问题定位 #

从报错日志看，CompositeMessageConverter无法将JSON格式的MQTT消息 payload 转换为自定义POJO，本质是JSON反序列化环节出现匹配问题，结合你用String.class能正常工作的情况，可从以下几个方向排查修复：

1. 修正POJO的Jackson注解配置 #

你之前误用了@JsonPropertyIgnore，正确忽略未知属性的类级别注解是@JsonIgnoreProperties(ignoreUnknown = true)，同时要确保POJO字段与JSON键完全匹配（大小写一致），Lombok注解需正确生成构造方法、getter/setter：

@Data
@NoArgsConstructor
@AllArgsConstructor
@JsonIgnoreProperties(ignoreUnknown = true) // 正确的忽略未知属性注解
public class MyCustomPojo {
    private String action;
    private Integer battery;
    private Integer linkquality;
    private Integer voltage;
}

2. 显式添加JSON转换步骤 #

默认的消息转换器可能未优先处理JSON到POJO的转换，可在handle之前显式添加JSON反序列化步骤：

@Bean
public IntegrationFlow emosButtonMqttFlow() {
    return IntegrationFlows.from(mqttInboundChannelAdapter())
            .transform(Transformers.fromJson(MyCustomPojo.class)) // 显式将JSON转为POJO
            .handle(MyCustomPojo.class, (message, payload) -> {
                // 你的业务处理逻辑
                return null;
            })
            .get();
}

3. 检查并配置自定义Jackson消息转换器 #

若默认转换器仍不生效，可注册自定义的MappingJackson2MessageConverter，确保反序列化规则符合需求：

@Bean
public MappingJackson2MessageConverter jacksonMessageConverter() {
    MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
    ObjectMapper objectMapper = new ObjectMapper()
            .configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false)
            .registerModule(new JavaTimeModule()); // 若包含日期类型需添加
    converter.setObjectMapper(objectMapper);
    return converter;
}

4. 验证Lombok注解是否生效 #

确认IDE已启用Lombok插件，maven编译阶段注解处理器正常工作——可查看编译后的MyCustomPojo.class文件，检查是否生成了无参构造、getter/setter方法。若Lombok未生效，Jackson无法通过反射实例化POJO，会直接导致转换失败。

5. 确认MQTT消息格式合法性 #

用String.class接收时打印完整payload，检查是否存在隐藏特殊字符、JSON格式错误（比如引号不匹配、逗号遗漏），这些隐性问题也会导致反序列化失败。

内容的提问来源于stack exchange，提问作者Draaksward