Spring Integration抛出异常时如何终止chain流程？

核心错误点 #

• 方法映射不匹配：你在chain中配置的第三个transformer调用方法为check，但对应CheckValidationmpl类中的校验方法名为checkValidation，方法名不匹配导致校验逻辑未执行，异常无法抛出，chain会完整执行所有节点后将消息投递到requestOutputChannel
• Bean引用无效：第二个transformer中定义的是匿名内部bean，没有配置id，第三个transformer的ref="transform2Class"无法找到对应实例，会导致校验组件被跳过
• error-channel配置场景错误：header中配置的error-channel仅对异步消息投递场景生效，同步调用流程的异常会沿调用栈向上抛给入口gateway，该配置属于多余配置，可能干扰异常处理逻辑

修复步骤 #

1. 修正Bean定义与方法映射
   首先定义公共的transform2Class bean，修正transformer的方法名配置，同时删除多余的error-channel header配置：

<!-- 单独定义公共bean -->
<bean id="transform2Class" class="transform2Class" />

<int:chain input-channel="requestChannel" output-channel="requestOutputChannel">
    <int:transformer id="transformer1" method="transform">
        <bean class="transform1Class" />
    </int:transformer>

    <int:transformer id="transformer2" ref="transform2Class" method="transform" />

    <!-- 修正调用方法名和bean引用 -->
    <int:transformer id="transformer3" ref="transform2Class" method="checkValidation"/>
</int:chain>

2. 验证网关异常处理逻辑
   你已经在入口gateway上配置了全局error-channel="errorHandlerChannel"，同步流程中抛出的异常会被gateway自动捕获封装为ErrorMessage投递到该通道，你配置的bridge会将消息路由到endFlowChannel作为网关返回值，主流程会直接中断，不会再投递到requestOutputChannel。
3. 可选强管控配置
   如果需要彻底避免异常时流程走到output-channel，可以为chain增加异常拦截advice，显式指定异常时直接走错误流程：

<int:chain input-channel="requestChannel" output-channel="requestOutputChannel">
    <int:advice-chain>
        <bean class="org.springframework.integration.handler.advice.ExpressionEvaluatingRequestHandlerAdvice">
            <property name="trapException" value="true"/>
            <property name="failureChannel" value="errorHandlerChannel"/>
            <property name="returnOnFailure" value="true"/>
        </bean>
    </int:advice-chain>
    <!-- 原有组件配置 -->
</int:chain>

内容的提问来源于stack exchange，提问作者İlkay Gunel