Spring Integration拆分聚合流程异常全捕获后无法终止问题咨询

问题原因 #

当使用ExpressionEvaluatingRequestHandlerAdvice并设置trapException=true时，如果没有指定异常处理后的返回逻辑，捕获到异常的消息不会产生任何输出结果。而aggregate组件需要等待所有拆分后的消息对应的结果（无论成功或失败）才能完成聚合并结束流程。当所有元素都抛出异常且未生成输出时，aggregate会一直处于等待状态，导致流程无法结束。

解决方案 #

需要给ExpressionEvaluatingRequestHandlerAdvice配置returnFailureExpression，让每个异常被捕获后返回一个可被聚合的结果，确保所有拆分后的消息都能产生输出，触发aggregate的完成逻辑。

修改后的代码示例 #

public Advice advice() {
    var advice = new ExpressionEvaluatingRequestHandlerAdvice();
    advice.setTrapException(true);
    // 配置异常捕获后的返回值，可根据业务需求自定义内容
    // 示例：返回包含原始payload和异常信息的字符串
    advice.setReturnFailureExpressionString("'处理失败，原始内容: ' + payload + '，异常信息: ' + exception.message");
    // 也可以返回自定义业务对象，例如：
    // advice.setReturnFailureExpression(new SpelExpressionParser().parseExpression(
    //     "new com.example.FailureRecord(payload, exception.message, T(java.time.LocalDateTime).now())"));
    return advice;
}

额外说明 #

• split组件默认开启applySequence=true，该属性会自动为拆分后的消息添加组标识，确保aggregate能正确识别同一组的所有消息，无需额外配置。
• 若需更灵活的聚合触发条件，可为aggregate配置releaseStrategy，例如设置固定消息数量的释放策略：

  .aggregate(a -> a.releaseStrategy(new MessageCountReleaseStrategy(expectedSplitCount)))
  

内容的提问来源于stack exchange，提问作者Médéric Martin