Spring Integration Aggregator响应聚合异常，分组不全问题求助

问题描述 #

应用通过Spring Integration Splitter拆分消息生成消息列表处理，基于JMS_CORRELATION_ID关联的响应消息无法正确聚合到同一分组：

• 典型异常：4条响应中3条聚为一组、1条单独成组；或2条一组、另2条分属不同组，最终导致输出通道异常
• 具体复现场景：前2条响应正常归组；第3条响应查找现有分组返回null，创建新分组单独聚合；第4条响应找到前2条的分组并聚合，但该分组因未完成进入超时等待，最终仅释放3条响应（预期4条）

已尝试的XML配置：

expire-groups-upon-completion="true"
expire-groups-upon-timeout="true" group-timeout="600000"

同时尝试引用SimpleMessageStore作为message-store，问题未解决；测试过的Spring Integration版本包括5.5.20、5.5.19、5.5.15、5.3.4.RELEASE、4.3.4.RELEASE。

排查与解决方案 #

1. 确认JMS_CORRELATION_ID的绝对一致性 #

所有响应消息的JMS_CORRELATION_ID必须完全一致，重点检查：

• 大小写敏感：ID的大小写差异会被判定为不同分组键
• 隐形字符：避免ID中包含空格、换行符或编码差异
• 传递完整性：确认Splitter拆分后的请求消息关联ID被正确设置到JMS请求中，且响应方严格原样返回该ID

2. 修正聚合器分组键配置 #

确保聚合器的correlation-strategy正确提取JMS_CORRELATION_ID，XML配置示例：

<aggregator input-channel="responseChannel"
            output-channel="aggregatedOutputChannel"
            correlation-strategy-expression="headers['JMS_CORRELATION_ID']"
            release-strategy-expression="size() == 4"
            message-store="messageStore"
            expire-groups-upon-completion="true"
            expire-groups-upon-timeout="true"
            group-timeout="600000"/>

若使用自定义CorrelationStrategy，需确保getCorrelationKey方法返回的键值无逻辑偏差，同一ID必须返回完全相同的键。

3. 校验消息存储的一致性 #

• 多实例部署场景：SimpleMessageStore为内存存储，无法跨实例共享分组数据，需改用分布式存储（如RedisMessageStore、JdbcMessageStore）
• 单实例场景：排查是否有代码意外修改了消息存储中的分组键或分组数据

4. 调整分组超时与过期逻辑 #

• 缩短group-timeout测试：过长的超时时间可能导致未完成分组残留，干扰后续消息的分组查找，可先设置为30000（30秒）验证
• 确保expire-groups-upon-completion和expire-groups-upon-timeout同时生效，避免无效分组占用存储

5. 日志跟踪分组过程 #

添加DEBUG级日志，跟踪聚合器的分组查找与创建细节：

<logger name="org.springframework.integration.aggregator" level="DEBUG"/>

查看每条响应消息的correlationKey值，以及分组查找结果（是否找到现有分组、是否创建新分组），定位分组不匹配的具体环节。

6. 检查Splitter的关联ID传递 #

确保Splitter拆分后的所有子消息都继承原始消息的关联ID，避免被意外覆盖，示例配置：

<splitter input-channel="requestChannel" output-channel="jmsOutChannel">
    <expression>payload.items</expression>
    <header-enricher>
        <header name="JMS_CORRELATION_ID" expression="headers['originalCorrelationId']"/>
    </header-enricher>
</splitter>

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