Spring Integration 中 TimeoutCountSequenceSizeReleaseStrategy 无法按预期触发超时释放，根本原因在于该策略仅在新消息到达时才被调用；若无新消息入组，超时逻辑不会自动执行——需改用 group-timeout 属性实现真正的定时释放。
spring integration 中 `timeoutcountsequencesizereleasestrategy` 无法按预期触发超时释放，根本原因在于该策略仅在新消息到达时才被调用；若无新消息入组，超时逻辑不会自动执行——需改用 `group-timeout` 属性实现真正的定时释放。
在 Spring Integration 的聚合器（
- ❌ TimeoutCountSequenceSizeReleaseStrategy 中的 timeout 参数并非启动后台定时器，而仅作为“自该组最后一次收到消息起，已过去多久”的参考值；
- ❌ 若某消息组在创建后 2 分钟内再无任何新消息到达，则 release-strategy-expression 永远不会被执行，超时逻辑形同虚设；
- ✅ 真正支持主动超时释放的机制是聚合器自身的 group-timeout 属性（或其 Java DSL / @Bean 对应的 setGroupTimeout() 方法），它会为每个活跃组注册独立的延迟任务，在超时后强制释放（或过期）该组。
正确配置方式（XML 配置）
将原配置中的 release-strategy-expression 移除，直接使用 group-timeout 并启用超时行为：
<int:aggregator
input-channel="aggregatorInChannel"
output-channel="splitterInChannel"
message-store="customMessageStore"
correlation-strategy-expression="headers['type']"
ref="taskAggregationService"
method="aggregateTask"
<!-- ✅ 关键：启用基于时间的主动释放 -->
group-timeout="120000" <!-- 2 minutes -->
<!-- ✅ 必须启用，否则超时组会被丢弃而非释放 -->
send-partial-result-on-expiry="true"
<!-- ✅ 可选：避免超时后重复处理同一组 -->
expire-groups-upon-timeout="true"
expire-groups-upon-completion="true"
id="customAggregator"/>⚠️ 注意：group-timeout 与 release-strategy 互斥且不可共存于超时场景。一旦设置了 group-timeout，release-strategy 将不再参与超时决策；它仅在 group-timeout 未设置且有新消息到达时才生效。
补充说明与最佳实践
- send-partial-result-on-expiry="true" 是必须项：若为 false（默认），超时组将被直接丢弃，不会向 output-channel 发送任何结果。
- expire-groups-upon-timeout="true" 推荐开启：防止超时后残留无效组占用内存（尤其配合自定义 MessageStore 时）。
- 避免误用 TimeoutCountSequenceSizeReleaseStrategy：该策略适用于“既要数量达标又要不超时”的复合场景（例如：最多等 2 分钟，但只要凑够 5 条就立即发），而非纯时间驱动释放。纯定时需求请始终优先选用 group-timeout。
- 版本升级建议：您当前使用的 Spring Integration 5.3.20（对应 Spring Boot 2.5.x）已属维护末期。最新稳定版（如 6.3.x）对超时调度、线程安全及错误处理均有显著增强，官方文档 也已明确强调 group-timeout 的核心地位。
综上，解决“超时不释放”问题的关键，不是调试 ReleaseStrategy，而是理解 Spring Integration 聚合器的生命周期模型，并正确选用 group-timeout 这一主动式超时机制。
