RabbitMQ单活跃消费者在实例关闭时丢失消息顺序问题

我们采用典型发布-消费架构，核心要求是消息串行且严格按顺序消费，目标是多消费微服务实例部署时仍能维持该顺序。使用官方推荐的Single Active Consumers（SAC）机制在多数场景下表现正常，但在应用实例关闭时会出现顺序丢失问题。

注意：我们同时使用quorum queues（仲裁队列）和消费者确认机制。

异常场景细节 #

假设有实例A（活跃消费者）和实例B（备用），当主动关闭实例A时，实例B会被RabbitMQ选为新的活跃消费者并开始消费消息，但此时实例A仍在处理已获取但未确认（Unacked）的消息。

以预取值（pre-fetch）设为1的场景为例：

• 关闭实例A前：
• 实例A关闭过程中：

此时实例A的消费者已从队列中移除，但连接通道仍处于打开状态，RabbitMQ会同时看到两个实例的未确认消息，实际出现不同消息并行处理的情况。两条消息最终都能处理成功，但消息顺序丢失，且预取值越高，该问题的影响越严重。

版本与代码信息 #

队列定义代码 #

@Bean(name = "testSingleActiveConsumerQueue")
Queue testSingleActiveConsumerQueue() {
    final Map<String, Object> args = new HashMap<>();
    args.put("x-queue-type", "quorum");
    args.put("x-single-active-consumer", true); // 启用单活跃消费者
    return new Queue(APP_IDENTIFIER + ".test.single_active_consumer", true, false, false, args);
}

RabbitMQ Docker部署配置 #

services:
  rabbitmq:
    image: rabbitmq:3.12.0-management
    ports:
      - 5672:5672
      - 15672:15672
    restart: always
    environment:
      - RABBITMQ_DEFAULT_USER=guest
      - RABBITMQ_DEFAULT_PASS=guest

Spring Integration AMQP依赖版本 #

<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-amqp</artifactId>
    <version>5.5.15</version>
  </dependency>

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