如何使用ChannelInterceptor终止Spring Integration中的执行流程

核心逻辑是给需要管控的Spring Integration消息通道绑定自定义的ChannelInterceptor拦截器，通过全局线程安全的终止状态标识控制消息是否向下流转，一旦触发终止规则，拦截器直接中断消息传递，即可终止整个执行流程。

• 第一步：编写自定义拦截器实现类
  重写preSend方法，新增线程安全的终止状态标识，以及手动触发终止、重置状态的方法：

import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.support.ChannelInterceptor;
import java.util.concurrent.atomic.AtomicBoolean;

public class TerminableChannelInterceptor implements ChannelInterceptor {
    // 线程安全的终止标识
    private final AtomicBoolean terminateFlag = new AtomicBoolean(false);

    @Override
    public Message<?> preSend(Message<?> message, MessageChannel channel) {
        // 终止标识为true时直接返回null，Spring Integration会自动终止当前消息的后续处理流程
        if (terminateFlag.get()) {
            return null;
        }
        return message;
    }

    // 外部调用该方法手动触发流程终止
    public void triggerTerminate() {
        terminateFlag.set(true);
    }

    // 重置终止标识，恢复流程执行
    public void resetTerminate() {
        terminateFlag.set(false);
    }
}

• 第二步：XML配置绑定拦截器
  首先将自定义拦截器注册为Spring Bean，再根据业务需求选择全局生效或者指定通道生效：

<!-- 注册自定义终止拦截器Bean，替换为你实际的类路径 -->
<bean id="terminableInterceptor" class="com.yourbusiness.package.TerminableChannelInterceptor"/>

<!-- 方式1：全局拦截器，对所有消息通道生效，pattern可自定义匹配规则 -->
<int:channel-interceptor ref="terminableInterceptor" pattern="*" order="1"/>

<!-- 方式2：仅给指定业务通道添加拦截器，不影响其他无关流程 -->
<int:channel id="yourBusinessProcessChannel">
    <int:interceptors>
        <ref bean="terminableInterceptor"/>
    </int:interceptors>
</int:channel>

• 第三步：手动触发流程终止
  在需要终止流程的业务逻辑（比如用户触发的终止接口、后台管控逻辑）中，注入terminableInterceptor Bean，调用triggerTerminate()方法即可触发流程终止，后续所有经过绑定了拦截器的通道的消息都会被直接拦截，流程停止。需要恢复时调用resetTerminate()方法即可。

• 该方案只能拦截后续新进入通道的消息，已经进入业务处理器正在执行的任务无法直接中断，如果需要中断运行中的任务，需要额外配合线程中断标识、Future取消等逻辑实现。
• 如果流程中使用了队列通道、异步通道，已经存入队列的未消费消息还是会继续执行，需要彻底终止时可以同步清空对应通道的未消费消息。
• 建议按需配置拦截器的匹配规则，仅给需要管控的业务流程对应的通道添加拦截器，避免影响其他无关的Spring Integration流程。

内容的提问来源于stack exchange，提问作者bageerathi rathi