Spring Integration升级后routeToRecipients中Header解包异常问题

Spring Integration从1.5.x升级到6.x后，handle组件的行为发生了变化：旧版本中，当handle返回Message对象时，下游组件会直接接收这个Message作为payload；而6.x版本会自动解包返回的Message，将其内部的payload（也就是你的OrderMessage）传递给下游，同时合并原Message的头部到当前消息头中。这就导致你在routeToRecipients里试图把OrderMessage强转为Message时抛出类型转换异常。

1. 调整handle组件的返回逻辑 #

不再返回包装后的Message，直接返回OrderMessage，头部会自动继承并传递：

.<byte[]>handle((payload, headers) -> {
    OrderMessage orderMessage = (OrderMessage) jsonMessageConverter.convert(payload);
    return orderMessage;
})

2. 修改routeToRecipients的条件判断 #

routeToRecipients的条件参数本身就是Message<?>类型，直接调用getHeaders()即可获取头部，无需强转，同时建议添加空指针防护避免异常：

.routeToRecipients(exhaustedRetriesRouter -> exhaustedRetriesRouter
        .recipient(GenericFlow.EXHAUSTED_CHANNEL,
                message -> {
                    MessageHeaders headers = message.getHeaders();
                    if (!headers.containsKey("x-death")) {
                        return false;
                    }
                    List<?> xDeathList = (List<?>) headers.get("x-death");
                    if (xDeathList == null || xDeathList.isEmpty()) {
                        return false;
                    }
                    Map<?, ?> xDeathEntry = (Map<?, ?>) xDeathList.get(0);
                    Long count = (Long) xDeathEntry.get("count");
                    return count != null && count >= 3L;
                })

• 确保RabbitMQ传递的x-death头部被正确映射到Spring Integration的MessageHeaders中，这一步在Spring AMQP与Spring Integration的集成中默认是支持的，但如果有自定义消息转换器，需要确认头部没有被过滤。
• 6.x版本的Spring Integration对消息处理的透明度更高，尽量避免在流程中传递嵌套的Message对象，遵循“payload+头部”的标准模型。

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