Spring Boot RabbitMQ配置单消费线程不生效 如何保证顺序消费？

根因定位 #

你观察到的ntContainer#x-1格式的线程名中，#x是监听容器的序号，末尾的1是容器内的线程编号。出现多个该格式线程，说明你的队列绑定了多个独立的监听容器，每个容器都按你配置的concurrency=1启动了1个线程，最终导致多个线程并行消费。

解决方案 #

• 第一步：排查同一队列的监听器声明
  检查代码中是否给同一个队列绑定了多个@RabbitListener注解的方法，每个独立的@RabbitListener都会生成独立的监听容器，就算每个容器的并发数都设为1，也会出现多线程消费。确认后仅保留唯一的一个消费方法绑定目标队列即可。

• 第二步：自定义单并发监听容器工厂
  为了避免全局配置覆盖目标监听器的并发设置，自定义强制单线程的监听容器工厂，配置示例如下：

  import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
  import org.springframework.amqp.rabbit.connection.ConnectionFactory;
  import org.springframework.context.annotation.Bean;
  import org.springframework.context.annotation.Configuration;
  
  @Configuration
  public class RabbitMqConfig {
      @Bean
      public SimpleRabbitListenerContainerFactory singleThreadListenerFactory(ConnectionFactory connectionFactory) {
          SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
          factory.setConnectionFactory(connectionFactory);
          // 强制固定最小和最大并发数都是1
          factory.setConcurrentConsumers(1);
          factory.setMaxConcurrentConsumers(1);
          // 多实例部署场景可开启独占，保证全局只有一个消费者
          factory.setExclusive(true);
          return factory;
      }
  }
  

  之后在目标消费方法的@RabbitListener注解中指定使用该工厂：

  @RabbitListener(queues = "你的目标队列名", containerFactory = "singleThreadListenerFactory")
  public void handleOrderMessage(Message message) {
      // 消息处理逻辑
  }
  

• 第三步：校验全局配置
  检查application配置文件中是否存在全局RabbitMQ监听并发配置，若未自定义容器工厂，该配置会作为默认值生效，示例配置参考：

  spring:
    rabbitmq:
      listener:
        simple:
          concurrency: 1 # 全局默认并发数，不自定义工厂时不要设置大于1的值
  

• 多实例部署补充：如果应用是集群部署，要保证全局只有一个消费线程，除上述配置外，还需保持exclusive=true配置，确保同一时间只有一个实例的消费者可以连接队列，当前实例宕机后其他实例的消费者才会接管消费，避免多实例并行消费。

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