RabbitMQ 镜像队列

1. 基本概念

镜像队列是一种特殊的队列类型，在 RabbitMQ 集群中，该队列的消息会被复制到集群中的其他节点上。

• 主队列（Master Queue）：每个镜像队列在集群中会有一个主节点（主副本）；
• 镜像队列（Mirror Queue）：主队列的所有消息和元数据会同步到一个或多个节点上的镜像副本；
• 仲裁机制：只有主队列节点对外提供消息入队和出队服务，镜像副本仅在后台保持数据同步；

2. 工作原理

1. 消息发布（Publish）：客户端发送消息到镜像队列时，消息先写入主队列；
2. 消息复制：主队列会将消息同步到所有镜像副本；
3. 消息确认：只有当消息成功复制到所有镜像后，RabbitMQ 才会向生产者发送确认；
4. 消费者读取（Consume）：消费者总是从主队列中拉取消息，镜像副本不直接参与消费；

3. 配置镜像队列

镜像队列的配置是通过策略（Policy）实现的。

1. 定义策略：

   使用 rabbitmqctl 命令或管理界面，为队列设置镜像策略。

2. 示例策略：

   rabbitmqctl set_policy ha-all "^ha\." '{"ha-mode":"all"}'

   • ha-all：是策略名称；
   • ^ha\.：是正则表达式，匹配所有以 ha. 开头的队列；
   • {"ha-mode":"all"}：是策略配置，镜像到所有节点；

3. 策略字段解释：

   • ha-mode：
     • all：镜像到所有节点；
     • exactly：指定固定数量的节点；
     • nodes：镜像到指定的节点；
   • ha-params：ha-mode 对应的参数；
   • ha-sync-mode：
     • automatic（默认）：新加入的节点会自动同步队列；
     • manual：需要手动触发同步；

4. 优势与局限

4.1. 优势

1. 高可用性：主节点故障时，RabbitMQ 自动将其中一个镜像节点提升为主节点；
2. 消息冗余：消息被复制到多个节点，即使某个节点数据丢失也能保障可靠性；

4.2. 局限

1. 性能开销：每条消息都需要同步到所有镜像节点，会增加网络和磁盘 I/O；
2. 分区问题：在网络分区情况下，可能导致主队列和镜像副本状态不一致；
3. 复杂性：节点间同步和管理较为复杂，容易出现性能瓶颈；

5. 镜像队列的高可用机制

当主节点发生故障时：

1. RabbitMQ 会根据仲裁机制，从剩余的镜像节点中选出一个新的主队列。
2. 消费者会自动切换到新的主节点继续消费。

6. 镜像队列与普通队列的对比

特性	普通队列	镜像队列
高可用性	主节点故障，队列不可用	主节点故障，镜像接管
数据冗余	无冗余，数据可能丢失	数据多副本，不易丢失
性能	性能较高	同步开销导致性能较低
配置复杂度	简单	需要额外的配置