Spring Integration多HTTP出站网关聚合无output/reply channel异常

安全阿岳

2026-8-27

问题根因

通道类型不符合预期：配置中使用的publishsubscribechannel没有显式声明，Spring Integration会将未显式定义的通道默认实例化为DirectChannel（点到点传输模式，同一条消息仅投递给一个下游消费者），而非发布订阅模式。该问题会导致两个HTTP调用链永远只有一个能收到消息，聚合器始终凑不齐所需的全部响应数据，消息组长期无法释放。
聚合关联逻辑错误：配置的correlation-strategy-expression="headers['id']"取的是每条消息的全局唯一标识，两个HTTP分支的消息经过独立处理流程后，各自的id头完全不同，无法被归到同一个聚合组，直接导致聚合器无法正常完成消息归集。
手动设置replyChannel引发循环：手动往消息头写入replyChannel时，很容易指向流程中已执行过的上游节点，造成消息在流程中无限循环转发，触发栈溢出。
流程拓扑不符合需求：当前配置是先执行第一个HTTP调用，再将该调用的结果发到通道触发第二个HTTP调用，并非并行发起两个HTTP请求的逻辑，和归集两个接口响应的需求完全不匹配。

修复方案

按以下步骤调整配置即可：

第一步：显式定义发布订阅通道，开启序列标识自动生成
替换默认生成的点到点通道，保证同一条入口消息可以同时投递给两个下游HTTP调用链，开启apply-sequence后框架会自动给同批次的分支消息注入统一的关联ID、消息序号、总条数头信息，简化聚合器配置：
```
<int:publish-subscribe-channel id="publishsubscribechannel" apply-sequence="true"/>
```
第二步：调整消息流拓扑
将两个HTTP调用链都设置为发布订阅通道的直接下游，入口消息先转发到发布订阅通道，再并行触发两个HTTP请求：
1. 如果intermediateSChannel是流程入站通道（比如入站网关的输出通道），加一个桥接器直接转发消息即可，不要在转发前执行HTTP调用：
```
<int:bridge input-channel="intermediateSChannel" output-channel="publishsubscribechannel"/>
```
2. 原有的第一个HTTP调用链，修改input-channel为publishsubscribechannel，去掉原来从intermediateSChannel接入、输出到publishsubscribechannel的错误配置，调整后两个HTTP链平行作为发布订阅通道的下游，处理完成后都输出到aggregatorChannel。

第三步：修正聚合器配置
移除错误的消息ID关联策略，使用框架自动注入的关联ID做分组，直接根据消息条数判断是否释放聚合组，无需手动设置replyChannel，只要链上配置了output-channel，聚合完成的消息会自动发往指定通道：

<int:chain id="chain3" input-channel="aggregatorChannel" output-channel="outputChannel">
    <int:aggregator id="tAggregator" 
        ref="tDataAggregator"
        method="processAggregator"
        correlation-strategy-expression="headers['correlationId']" 
        release-strategy-expression="size() == 2"
        expire-groups-upon-completion="true"/>
</int:chain>

第四步：校验通道配置
确认outputChannel已显式定义且配置了对应的下游消费者（比如业务结果处理器、入站网关的应答通道），不要留下无消费者的悬空通道。

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