Spring Integration中recipient-list-router通道发送错误负载问题咨询

首先先梳理下你给出的HTTP入站网关配置：

<http:inbound-gateway id="webListGateway" 
                      request-channel="fromWeb_List" 
                      reply-channel="toWeb_List" 
                      path="/api/profile/V1/get" 
                      supported-methods="GET">
    <http:header name="container" expression="#pathVariables.container"/>
    <http:header name="groupName" expression="#pathVariables.groupName"/>
    <http:header name="userId" expression="#pathVariables.userId"/>
</http:inbound-gateway>

从这个配置来看，入站网关会把GET请求的请求体（通常是空的）作为初始Payload发到fromWeb_List通道，同时把路径变量塞进消息头里。结合你遇到的Router payload错误问题，咱们从以下几个方向排查：

1. 先确认初始Payload的内容 #

GET请求默认没有请求体，所以Spring Integration会把空值或者空字节数组作为初始Payload发送到下游。如果你期望Router处理的是路径变量相关的内容，那这里就需要在网关之后加一个Transformer来构建正确的Payload，比如把消息头里的参数组装成Map：

<transformer input-channel="fromWeb_List" output-channel="routerReadyChannel">
    <expression>
        new java.util.HashMap() {{
            put("container", headers.container);
            put("groupName", headers.groupName);
            put("userId", headers.userId);
        }}
    </expression>
</transformer>

这样后续Router拿到的就是包含所有路径变量的Map，而不是空Payload。

2. 检查Recipient List Router的配置是否有误 #

很多时候问题出在Router的表达式使用上。比如如果你的Router用expression来指定接收者，这个表达式的返回值会替换原Payload，而不是仅仅作为路由条件。举个典型的错误配置：

<!-- 错误示例：这个配置会把Payload替换成headers.container的值，而不是基于它路由 -->
<recipient-list-router input-channel="fromWeb_List">
    <recipient channel="containerAChannel" expression="headers.container == 'A'"/>
</recipient-list-router>

正确的做法是用selector-expression来定义路由条件，这样不会修改原Payload：

<recipient-list-router input-channel="routerReadyChannel">
    <recipient channel="containerAChannel" selector-expression="headers.container == 'A'"/>
    <recipient channel="containerBChannel" selector-expression="headers.container == 'B'"/>
</recipient-list-router>

3. 监控中间环节的Payload变化 #

检查fromWeb_List到Router之间的所有组件（Filter、Service Activator、Transformer等），看有没有组件意外修改了Payload。比如某个Service Activator的方法返回值会直接替换原Payload，如果方法返回了错误的对象，就会导致Router拿到错误的内容。

最简单的监控方式是给通道加Wire Tap，打印消息的Payload和头信息：

<channel id="fromWeb_List">
    <interceptors>
        <wire-tap channel="debugLoggingChannel"/>
    </interceptors>
</channel>

<logging-channel-adapter id="debugLoggingChannel" level="DEBUG" 
                         expression="Payload: #{payload}, Headers: #{headers}"/>

启动应用后看DEBUG日志，就能清晰看到消息从网关出来后，经过每个组件时Payload的变化，快速定位到哪里出了问题。

4. 确认接收通道的组件是否匹配Payload格式 #

有时候不是Router发错了Payload，而是接收通道的组件期望的格式和实际收到的不匹配。比如接收通道的Service Activator期望一个UserProfile对象，但Router发来的是Map，这时候会报错，看起来像是Router的问题，但实际是上游没有做好转换。

你可以给Router的每个接收通道也加Wire Tap，确认发送到各个通道的Payload是否符合预期。

如果以上步骤还没解决问题，把你的Recipient List Router配置以及中间环节的组件代码/配置贴出来，我再帮你精准定位！

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