Spring Integration中JsonToObjectTransformer遇类型不匹配异常求助

首先咱们得把问题根源理清楚：你从MongoDB轮询到的消息 payload 是**java.util.ArrayList**（里面装的是MongoDB的Document对象或者你的实体类实例），但JsonToObjectTransformer只认JSON格式的字符串、字节数组、文件、流这类数据，类型对不上自然就抛出异常了。

下面给你两种可行的解决方案，你可以根据实际场景选：

方案一：直接将Document转换为实体类（推荐，更高效） #

没必要绕JSON的弯路，直接用MongoDB自带的转换器把Document转成你的目标实体类就行：

@Bean
public IntegrationFlow mongoDbToEntityFlow(MongoDbMessageSource mongoDbMessageSource, MongoConverter mongoConverter) {
    return IntegrationFlows.from(mongoDbMessageSource, e -> e.poller(Pollers.fixedDelay(5000)))
            .split() // 把列表拆成单个Document，逐个处理
            .transform(doc -> mongoConverter.read(YourEntity.class, (Document) doc)) // 直接转成实体类
            .handle(yourEntityHandler()) // 替换成你的实体处理逻辑
            .get();
}

方案二：先转JSON字符串再用JsonToObjectTransformer #

如果一定要用JsonToObjectTransformer，那先把每个Document转成JSON字符串，再传给转换器：

@Bean
public IntegrationFlow mongoDbJsonToEntityFlow(MongoDbMessageSource mongoDbMessageSource) {
    return IntegrationFlows.from(mongoDbMessageSource, e -> e.poller(Pollers.fixedDelay(5000)))
            .split() // 拆分列表为单个元素
            .transform(Transformers.converter(document -> ((Document) document).toJson())) // Document转JSON字符串
            .transform(new JsonToObjectTransformer(YourEntity.class)) // JSON转实体类
            .handle(System.out::println) // 替换成你的处理逻辑
            .get();
}

额外提醒 #

如果你的MongoDB入站适配器已经配置为直接返回实体类列表（比如通过指定查询的返回类型），那拆分后拿到的就是现成的实体实例，完全不需要JsonToObjectTransformer，直接移除这个转换器就能解决问题。

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