Spring Integration 同一输入通道挂载两个处理器无法并行执行的问题

你观察到的“每次消息仅随机命中两个处理器中的一个”，本质是点对点直连通道（DirectChannel）的典型轮询分发行为，和配置了PublishSubscribeChannel后“给所有订阅者全量投递消息”的预期完全不符。常见触发原因有3个：

• 自定义的PublishSubscribeChannel Bean没有被优先加载，被Spring Integration自动装配的同名称DirectChannel覆盖了：框架默认会为未显式定义的通道自动创建DirectChannel，如果存在同名通道Bean，注册顺序靠后的Bean会优先被注入到各个处理器，直接把分发逻辑切回点对点轮询模式。
• 两个处理器（@Transformer标注的序列化组件、@ServiceActivator标注的AMQP出站组件）的输入通道绑定错位，实际没有绑定到你定义的Pub/Sub通道上。
• 你使用的是无并发能力的默认同步PublishSubscribeChannel，虽然能全量投递消息，但执行逻辑是串行的，不符合你要的并行处理预期。

• 第一步：显式定义带并行执行能力的objectOutputChannel Bean，避免自动装配的通道覆盖自定义配置

  @Bean
  @Primary // 确保自定义Pub/Sub通道优先被注入，避免同名DirectChannel冲突
  public MessageChannel objectOutputChannel() {
      // 构造时传入独立线程池，实现两个订阅处理器的并行执行
      return new PublishSubscribeChannel(Executors.newVirtualThreadPerTaskExecutor());
  }
  

• 第二步：核对两个处理器的通道绑定配置，确保输入通道完全匹配objectOutputChannel：
  • 序列化逻辑的@Transformer注解必须明确指定inputChannel = "objectOutputChannel"
  • AMQP出站逻辑的@ServiceActivator注解必须明确指定inputChannel = "objectOutputChannel"
    避免出现通道名拼写错误、绑定到其他通道的问题。
• 第三步：开启通道DEBUG日志验证实际运行的通道类型
  在配置文件中把通道组件的日志级别调整为DEBUG：

  logging.level.org.springframework.integration.channel=DEBUG
  

  观察日志中的投递逻辑：如果看到DirectChannel的轮询分发日志，说明通道仍未加载自定义的Pub/Sub实例，需要进一步排查上下文里的同名通道Bean冲突；如果看到PublishSubscribeChannel给所有订阅者依次投递消息的日志，说明通道配置已经生效。

• 不要让两个处理器的输出通道回环到objectOutputChannel：比如序列化组件处理完消息后，如果把输出通道也配为objectOutputChannel，会导致消息重复投递，进一步放大随机触发的假象。
• 如果不需要强实时并行处理，可以不引入独立线程池，但要明确知道默认的PublishSubscribeChannel是在消息发送线程内串行执行所有订阅者的，不属于并行处理逻辑。

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