RabbitMQ集群部署之镜像模式

谁借莪１个温暖的怀抱￠ 2024-03-16 16:45 48阅读 0赞

`RabbitMQ`集群的普通模式中，一旦创建队列的主机宕机，队列就会不可用。不具备高可用能力。如果要解决这个问题，必须使用官方提供的镜像集群方案。

官方文档地址：[https://www.rabbitmq.com/ha.html][https_www.rabbitmq.com_ha.html]

### 1.镜像模式的特征 ###

默认情况下，队列只保存在创建该队列的节点上。而镜像模式下，创建队列的节点被称为该队列的**主节点**，队列还会拷贝到集群中的其它节点，也叫做该队列的**镜像**节点。

但是，不同队列可以在集群中的任意节点上创建，因此不同队列的主节点可以不同。甚至，**一个队列的主节点可能是另一个队列的镜像节点**。

用户发送给队列的一切请求，例如发送消息、消息回执默认都会在主节点完成，如果是从节点接收到请求，也会路由到主节点去完成。**镜像节点仅仅起到备份数据作用**。

当主节点接收到消费者的`ACK`时，所有镜像都会删除节点中的数据。

总结如下：

*  镜像队列结构是一主多从（从就是镜像）
 *  所有操作都是主节点完成，然后同步给镜像节点
 *  主宕机后，镜像节点会替代成新的主（如果在主从同步完成前，主就已经宕机，可能出现数据丢失）
 *  不具备负载均衡功能，因为所有操作都会有主节点完成（但是不同队列，其主节点可以不同，可以利用这个提高吞吐量）

### 2.镜像模式的配置 ###

镜像模式的配置有3种模式：

<table> 
 <thead> 
  <tr> 
   <th align="left"><code>ha-mode</code></th> 
   <th align="left"><code>ha-params</code></th> 
   <th align="left">效果</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">准确模式<code>exactly</code></td> 
   <td align="left">队列的副本量<code>count</code></td> 
   <td align="left">集群中队列副本（主服务器和镜像服务器之和）的数量。<code>count</code>如果为1意味着单个副本：即队列主节点。<code>count</code>值为2表示2个副本：1个队列主和1个队列镜像。换句话说：<code>count</code> = 镜像数量 + 1。如果群集中的节点数少于<code>count</code>，则该队列将镜像到所有节点。如果有集群总数大于<code>count</code>+1，并且包含镜像的节点出现故障，则将在另一个节点上创建一个新的镜像。</td> 
  </tr> 
  <tr> 
   <td align="left"><code>all</code></td> 
   <td align="left">(<code>none</code>)</td> 
   <td align="left">队列在群集中的所有节点之间进行镜像。队列将镜像到任何新加入的节点。镜像到所有节点将对所有群集节点施加额外的压力，包括网络<code>I / O</code>，磁盘<code>I / O</code>和磁盘空间使用情况。推荐使用<code>exactly</code>，设置副本数为<code>（N / 2 +1）</code>。</td> 
  </tr> 
  <tr> 
   <td align="left"><code>nodes</code></td> 
   <td align="left"><code>node names</code></td> 
   <td align="left">指定队列创建到哪些节点，如果指定的节点全部不存在，则会出现异常。如果指定的节点在集群中存在，但是暂时不可用，会创建节点到当前客户端连接到的节点。</td> 
  </tr> 
 </tbody> 
</table>

这里我们以`rabbitmqctl`命令作为案例来讲解配置语法。

#### 2.1.`exactly`模式 ####

rabbitmqctl set_policy ha-two "^two\." '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'

*  `rabbitmqctl set_policy`：固定写法
 *  `ha-two`：策略名称，自定义
 *  `"^two\."`：匹配队列的正则表达式，符合命名规则的队列才生效，这里是任何以`two.`开头的队列名称
 *  `'{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'`: 策略内容
    
     *  `"ha-mode":"exactly"`：策略模式，此处是exactly模式，指定副本数量
     *  `"ha-params":2`：策略参数，这里是2，就是副本数量为2，1主1镜像
     *  `"ha-sync-mode":"automatic"`：同步策略，默认是manual，即新加入的镜像节点不会同步旧的消息。如果设置为automatic，则新加入的镜像节点会把主节点中所有消息都同步，会带来额外的网络开销

#### 2.2.`all`模式 ####

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

*  `ha-all`：策略名称，自定义
 *  `"^all\."`：匹配所有以`all.`开头的队列名
 *  `'{"ha-mode":"all"}'`：策略内容
    
     *  `"ha-mode":"all"`：策略模式，此处是all模式，即所有节点都会称为镜像节点

#### 2.3.`nodes`模式 ####

rabbitmqctl set_policy ha-nodes "^nodes\." '{"ha-mode":"nodes","ha-params":["rabbit@nodeA", "rabbit@nodeB"]}'

*  `rabbitmqctl set_policy`：固定写法
 *  `ha-nodes`：策略名称，自定义
 *  `"^nodes\."`：匹配队列的正则表达式，符合命名规则的队列才生效，这里是任何以`nodes.`开头的队列名称
 *  `'{"ha-mode":"nodes","ha-params":["rabbit@nodeA", "rabbit@nodeB"]}'`: 策略内容
    
     *  `"ha-mode":"nodes"`：策略模式，此处是nodes模式
     *  `"ha-params":["rabbit@mq1", "rabbit@mq2"]`：策略参数，这里指定副本所在节点名称

### 3.测试 ###

我们使用`exactly`模式的镜像，因为集群节点数量为3，因此镜像数量就设置为2。

运行下面的命令：

docker exec -it mq1 rabbitmqctl set_policy ha-two "^two\." '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'

![在这里插入图片描述][0b7619296e5147749b8a6e83c290b395.png_pic_center]

下面，我们创建一个新的队列：

![在这里插入图片描述][c2e7c90a323748938b134dbde7628c76.png_pic_center]

在任意一个`mq`控制台查看队列：

![在这里插入图片描述][d1dba6125e1f47d7ab7272acf12ef152.png_pic_center]

#### 3.1.测试数据共享 ####

给`two.queue`发送一条消息：

![在这里插入图片描述][794fb23fab144a8bbeaf8feef240088e.png_pic_center]

然后在`mq1`、`mq2`、`mq3`的任意控制台查看消息：

![在这里插入图片描述][db92dca49e964bb7a6f02f6f589f998d.png_pic_center]

#### 3.2.测试高可用 ####

现在，我们让`two.queue`的主节点`mq1`宕机：

docker stop mq1

查看集群状态：

![在这里插入图片描述][164bcb9fc5a44f5d8ce6a7990cbb3898.png_pic_center]

查看队列状态：

![在这里插入图片描述][84188be777e545c0b5a721ea4c67c4ec.png_pic_center]

发现依然是健康的！并且其主节点切换到了`rabbit@mq2`上。

[https_www.rabbitmq.com_ha.html]: https://www.rabbitmq.com/ha.html
[0b7619296e5147749b8a6e83c290b395.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/c34b01bc9b994ccba37d8b772ac72383.png
[c2e7c90a323748938b134dbde7628c76.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/064677a95d344afeb2944ee72291af03.png
[d1dba6125e1f47d7ab7272acf12ef152.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/9624c5b8533e44df9a05cfeb9d1d2644.png
[794fb23fab144a8bbeaf8feef240088e.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/7f4281bf29cd42c1956b107731902dcf.png
[db92dca49e964bb7a6f02f6f589f998d.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/01c5797391724c1882f37aaca04396c5.png
[164bcb9fc5a44f5d8ce6a7990cbb3898.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/8ba750f6a664489181bd9438b7e82dbb.png
[84188be777e545c0b5a721ea4c67c4ec.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/2a8fe612ceb6418694ec71b560d57796.png