Spring Cloud Stream同应用配生产消费者 多副本时消息未进RabbitMQ仅本地消费

• 核心原因是同一应用内生产者和消费者使用了相同的绑定名Orders，Spring Cloud Stream默认会开启进程内消息直通优化，消息直接在当前Pod内部发送给本地消费者，不会提交到RabbitMQ broker，所以其他副本无法消费，RabbitMQ控制台也看不到消息记录。这也能解释注释掉消费者代码后消息就能正常发送到RabbitMQ的现象：没有同应用内的同名消费者绑定，就不会触发本地直通逻辑。
• 消费者侧配置存在多处错误，进一步导致绑定逻辑异常：
  1. 消费者绑定名配置不匹配：OrdersListenerChannel的@Input注解指定绑定名为Orders，但配置文件中错误使用OrdersListenerChannel作为绑定前缀，导致所有消费者配置不生效
  2. 消费者未配置监听的Exchange目标（destination），无法正确关联到生产者发送的GeneralExchange
  3. 消费者配置了spring.cloud.stream.rabbit.bindings.OrdersListenerChannel.consumer.bind-queue=false，会禁止Spring Cloud Stream将队列和Exchange绑定，即使消息到了Broker也无法路由到消费者队列

1. 调整消费者通道的绑定名，避免和生产者重名，关闭本地直通逻辑：

@Component
public interface OrdersListenerChannel {
   // 修改为和生产者不同的绑定名
   String BINDING = "OrdersInput";

   @Input(BINDING)
   SubscribableChannel input();
}

2. 修正消费者侧配置，匹配新的绑定名，补充必要配置、删除无效的bind-queue配置：

spring.cloud.stream.bindings.OrdersInput.destination=GeneralExchange
spring.cloud.stream.bindings.OrdersInput.group=OrdersQueue
spring.cloud.stream.bindings.OrdersInput.consumer.max-attempts=3
spring.cloud.stream.bindings.OrdersInput.consumer.concurrency=10
spring.cloud.stream.rabbit.bindings.OrdersInput.consumer.republish-to-dlq=false

3. 生产者侧代码和配置无需改动，保持原有逻辑即可。

修复后消息会正常发送到RabbitMQ的GeneralExchange，再路由到绑定的OrdersQueue，同组下的5个副本会按照负载均衡规则消费队列中的消息。

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