Spring Integration Aggregator INT_MESSAGE表滞留消息问题咨询

项目中使用版本为5.1.4.RELEASE的Spring Integration Aggregator，核心配置如下：

<int:aggregator id="adobeJdbcAggregator" input-channel="aggregatorInputChannel" 
                output-channel="aggregatorOutputChannel"
                correlation-strategy-expression="headers['eventType']" 
                message-store="ccsJdbcMessageStore" 
                send-partial-result-on-expiry="true" 
                group-timeout-expression="#{aggregateGroupTimeoutValue}"
                expire-groups-upon-completion="true"
                expire-groups-upon-timeout="true" 
                release-strategy-expression="#{aggregateReleaseStrategyExpressionValue}"
                ref="ccsAggregatorBean" 
                method="processMessage"  
                auto-startup="true"/>

故障现象 #

偶发INT_MESSAGE表存在滞留消息，不符合聚合完成后表内无待处理消息的预期；排查确认INT_MSG_GROUP、INT_GROUP_TO_MSG两张关联表中均无对应待处理记录。当前通过group-timeout-expression配置了基于时间戳的消息组过期规则，需要定位部分消息未正常完成聚合的故障原因。

可能的问题原因 #

• 跨事务配置不一致：如果JdbcMessageStore绑定的数据源事务管理器，和聚合器上游消费链路（如MQ消费、通道轮询器）配置的事务管理器不是同一个实例，会出现跨事务提交不一致问题：上游消费逻辑触发回滚时，INT_MESSAGE表的消息写入已经提交，但后续入组、关联关系写入的操作被回滚，直接形成无关联的滞留消息。
• 版本自带的组清理逻辑边界缺陷：5.1.4.RELEASE版本的JdbcMessageStore#removeMessageGroup方法存在执行顺序缺陷，清理消息组时先删除INT_GROUP_TO_MSG关联记录、再删除INT_MSG_GROUP组记录，最后才循环删除组内对应的INT_MESSAGE记录；如果执行到删除消息步骤时出现数据库连接断开、SQL执行超时、死锁触发回滚，且清理逻辑未被整体事务包裹，前面两步的删除操作一旦提交，就会留下无关联的消息残留。
• 关联键缺失导致入组失败：聚合器以headers['eventType']作为分组关联依据，如果消息在进入聚合器前被转换逻辑、header过滤器移除了eventType头，关联策略会返回null值，触发聚合器的错误投递流程；如果错误通道的处理逻辑没有手动清理对应已写入的消息记录，就会留下无组关联的滞留消息。
• 高并发场景下的竞态写入问题：如果配置的组超时时间过短，或aggregateGroupTimeoutValue是基于消息头时间戳计算的极小值，高并发场景下可能出现时序问题：消息刚完成INT_MESSAGE表写入、还未提交INT_GROUP_TO_MSG关联记录时，该组的超时/完成判定已经触发，清理逻辑扫描不到这条未提交关联的消息，直接清空了组和已有关联消息；后续关联写入因组已不存在失败回滚，但已提交的INT_MESSAGE记录不会被自动清理，形成滞留。
• 自定义聚合逻辑异常中断清理流程：自定义的ccsAggregatorBean#processMessage方法如果抛出未被聚合器错误通道捕获的异常，可能中断整个组的后续清理流程：组已被标记为完成、关联记录和组记录已经被删除，但单条消息的删除步骤未执行，最终残留消息记录。
• 重复消息触发主键冲突：如果同一条消息因上游重试被重复投递到聚合器，第二次写入INT_GROUP_TO_MSG表时会触发(GROUP_KEY, MESSAGE_ID)联合主键冲突，该异常如果被JDBC模板捕获吞掉，不会触发对应INT_MESSAGE记录的回滚/删除，也会形成无关联的滞留记录。

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