如何让多实例STOMP消费者仅消费RabbitMQ队列消息一次

要实现多个应用实例通过STOMP协议共同消费RabbitMQ队列，且每条消息仅被消费一次，核心是依赖RabbitMQ的消息确认机制和合理的客户端配置，具体操作如下：

1. 启用RabbitMQ STOMP插件 #

先确保RabbitMQ已开启STOMP插件，执行命令：

rabbitmq-plugins enable rabbitmq_stomp

2. 关闭自动确认，使用手动消息确认 #

这是避免重复消费的核心配置：

• 订阅队列时，将STOMP的ack模式设为client（批量消息场景可用client-individual），而非默认的auto。auto模式下RabbitMQ推送消息后会立即标记为已消费，若实例崩溃或处理失败，消息会丢失；client模式要求消费者处理完消息后主动发送ACK，RabbitMQ才会移除该消息。
• 示例SUBSCRIBE帧：

  SUBSCRIBE
  destination:/queue/your-target-queue
  id:unique-sub-id-1
  ack:client
  
  ^@
  

• 消息处理完成后，发送ACK帧确认：

  ACK
  id:[消息的delivery-tag]
  
  ^@
  

  若处理失败，可发送NACK帧让RabbitMQ将消息重新分发给其他存活实例。

3. 依赖RabbitMQ轮询分发机制 #

RabbitMQ默认采用轮询分发策略，会将队列消息依次分配给不同的消费者实例。配合手动确认机制，每条消息只会被推送给一个实例，直到该实例发送ACK后，RabbitMQ才会继续给该实例分配下一条消息，或转分给其他空闲实例。

4. 业务层实现幂等性（可选但推荐） #

极端场景下（比如实例发送ACK后，RabbitMQ未收到导致消息重新分发），可能出现消息重复推送。此时需在业务层做幂等校验：

• 利用消息自带的唯一ID（如message-id），处理前先检查该ID是否已被处理过（可存储在数据库或缓存中）。
• 确保业务操作本身具备幂等性（重复执行不会产生额外副作用）。

5. 禁用独占订阅 #

订阅队列时不要设置exclusive属性，否则队列只能被单个实例订阅，无法实现多实例共同消费。

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