Spring Integration中Executor与Direct Channel差异及消息重复问题排查

问题背景 #

我正在排查基于Spring Integration框架的Java应用中Executor Channel与Direct Channel的行为差异，验证故障转移流程以确保消息不重复——两种场景下JmsOutboundGateway->secondGateway都会抛出错误。

场景一（消息重复） #

inputLocalChannel - Executor Channel
inputGateway - Direct Channel
inputGatewayBck - Direct Channel (secondGateway - 故障流程)

发送3条消息后，响应队列出现6条，存在重复问题。

场景二（符合预期） #

inputLocalChannel - Executor Channel
inputGateway - Executor Channel
inputGatewayBck - Executor Channel (secondGateway - 故障流程)

发送3条消息后收到3条，无重复。

相关代码 #

网关定义

@MessagingGateway(name = "LocalGateway")
public interface LocalGateway {

    @Gateway(requestChannel = "inputLocalChannel")
    ListenableFuture<Message<String>> sendMsg(Message<String> request);

}

处理器与网关Bean

@Bean
@ServiceActivator(inputChannel = "inputLocalChannel")
public Message<String> firstHandler(){
    // some code
}

@Bean
@ServiceActivator(inputChannel = "inputLocalChannel")
public Message<String> secondHandler(){
    // some code
}

@Bean
@ServiceActivator(inputChannel = "inputGateway")
public JmsOutboundGateway firstGateway(){
    // some code
}

@Bean
@ServiceActivator(inputChannel = "inputGatewayBck")
public JmsOutboundGateway secondGateway(){
    // some code
}

疑问解答 #

1. 能否在inputLocalChannel->inputGateway、inputLocalChannel->inputGatewayBck的通道流程中使用同一线程，避免上下文切换？ #

可以实现。inputLocalChannel作为Executor Channel，会从线程池分配线程处理消息。如果下游的inputGateway和inputGatewayBck使用Direct Channel，由于Direct Channel是同步阻塞式通道，消息会直接在inputLocalChannel分配的线程上被下游JmsOutboundGateway处理，不会发生线程上下文切换——Direct Channel本质是直接调用订阅者的handle方法，没有额外的线程调度环节。

需要注意：如果故障转移逻辑涉及异步错误处理（比如通过ErrorChannel异步转发），则可能引入新线程；若为同步故障转移（比如在handler的advice中同步切换到备份通道），则全程复用inputLocalChannel的线程。

2. 为何使用Direct Channel时会出现消息重复？ #

核心原因是Direct Channel的同步特性与JmsOutboundGateway的请求响应模式结合后的异常处理逻辑：

• 同步调用的异常时机误判：当inputGateway为Direct Channel时，firstGateway的调用是同步的。如果firstGateway成功发送JMS请求后，在等待响应阶段抛出异常（如响应超时、连接断开），框架会触发故障转移调用secondGateway。但此时JMS请求已经成功发送到目标队列，导致firstGateway和secondGateway各发送一次相同消息，最终响应队列出现重复。
• Executor Channel的异步隔离：当inputGateway和inputGatewayBck使用Executor Channel时，JmsOutboundGateway的调用是异步的，故障转移逻辑在独立线程中处理。框架能更准确判断firstGateway的发送状态：只有发送阶段抛出异常（未成功发送JMS消息）时，才会触发secondGateway调用；若发送成功后响应失败，不会重复触发备份通道调用，因此无重复消息。

另外，需检查故障转移配置（如RetryTemplate、ExpressionEvaluatingRequestHandlerAdvice），若同步场景下重试逻辑未正确判断JMS发送的实际状态，也会导致重复发送。

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