RabbitMQ集群部署之普通模式

古城微笑少年丶 2024-03-16 16:23 60阅读 0赞

### 1.集群分类 ###

在`RabbitMQ`的官方文档中，讲述了两种集群的配置方式：

*  普通模式：普通模式集群不进行数据同步，每个`MQ`都有自己的队列、数据信息（其它元数据信息如交换机等会同步）。例如我们有2个`MQ`：`mq1`，和`mq2`，如果你的消息在`mq1`，而你连接到了`mq2`，那么`mq2`会去`mq1`拉取消息，然后返回给你。如果`mq1`宕机，消息就会丢失。
 *  镜像模式：与普通模式不同，队列会在各个`mq`的镜像节点之间同步，因此你连接到任何一个镜像节点，均可获取到消息。而且如果一个节点宕机，并不会导致数据丢失。不过，这种方式增加了数据同步的带宽消耗。

我们先来看普通模式集群，我们的计划部署3节点的`mq`集群：

<table> 
 <thead> 
  <tr> 
   <th>主机名</th> 
   <th>控制台端口</th> 
   <th><code>amqp</code>通信端口</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td><code>mq1</code></td> 
   <td><code>15672---&gt;15672</code></td> 
   <td><code>25672---&gt; 5672</code></td> 
  </tr> 
  <tr> 
   <td><code>mq2</code></td> 
   <td><code>15673---&gt; 15672</code></td> 
   <td><code>25673---&gt; 5672</code></td> 
  </tr> 
  <tr> 
   <td><code>mq3</code></td> 
   <td><code>15674---&gt; 15672</code></td> 
   <td><code>25674 ---&gt; 5672</code></td> 
  </tr> 
 </tbody> 
</table>

集群中的节点标示默认都是：`rabbit@[hostname]`，因此以上三个节点的名称分别为：

*  `rabbit@mq1`
 *  `rabbit@mq2`
 *  `rabbit@mq3`

### 2.获取`cookie` ###

`RabbitMQ`底层依赖于`Erlang`，而`Erlang`虚拟机就是一个面向分布式的语言，默认就支持集群模式。集群模式中的每个`RabbitMQ`节点使用`cookie`来确定它们是否被允许相互通信。

要使两个节点能够通信，它们必须具有相同的共享秘密，称为`Erlang cookie`。`cookie`只是一串最多 255 个字符的字母数字字符。

每个集群节点必须具有**相同的`cookie`**。实例之间也需要它来相互通信。

我们先在之前启动的`mq`容器中获取一个`cookie`值，作为集群的`cookie`。执行下面的命令：

docker exec -it mq cat /var/lib/rabbitmq/.erlang.cookie

可以看到`cookie`值如下：

TUCJVNAONNFSSVRDJGSW

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

接下来，停止并删除当前的`mq`容器，我们重新搭建集群。

docker rm -f mq

### 3.准备集群配置 ###

在`/home/rabbitmq`目录新建一个配置文件`rabbitmq.conf`：

cd /home/rabbitmq
    # 创建文件
    touch rabbitmq.conf

文件内容如下：

loopback_users.guest = false
    listeners.tcp.default = 5672
    cluster_formation.peer_discovery_backend = rabbit_peer_discovery_classic_config
    cluster_formation.classic_config.nodes.1 = rabbit@mq1
    cluster_formation.classic_config.nodes.2 = rabbit@mq2
    cluster_formation.classic_config.nodes.3 = rabbit@mq3

再创建一个文件，记录`cookie`

cd /home/rabbitmq
    # 创建cookie文件
    touch .erlang.cookie
    # 写入cookie
    echo "TUCJVNAONNFSSVRDJGSW" > .erlang.cookie
    # 修改cookie文件的权限
    chmod 600 .erlang.cookie

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

准备三个目录`mq1`、`mq2`、`mq3`：

cd /home/rabbitmq
    # 创建目录
    mkdir mq1 mq2 mq3

然后拷贝`rabbitmq.conf`、`cookie`文件到`mq1`、`mq2`、`mq3`：

# 进入/home/rabbitmq
    cd /home/rabbitmq
    # 拷贝
    cp rabbitmq.conf mq1
    cp rabbitmq.conf mq2
    cp rabbitmq.conf mq3
    cp .erlang.cookie mq1
    cp .erlang.cookie mq2
    cp .erlang.cookie mq3

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

### 4.启动集群 ###

创建一个网络：

docker network create mq-net

运行命令

docker run -d --net mq-net \
    -v ${PWD}/mq1/rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf \
    -v ${PWD}/.erlang.cookie:/var/lib/rabbitmq/.erlang.cookie \
    -e RABBITMQ_DEFAULT_USER=dcxuexi \
    -e RABBITMQ_DEFAULT_PASS=123456 \
    --name mq1 \
    --hostname mq1 \
    -p 25672:5672 \
    -p 15672:15672 \
    rabbitmq:3.11-management

docker run -d --net mq-net \
    -v ${PWD}/mq2/rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf \
    -v ${PWD}/.erlang.cookie:/var/lib/rabbitmq/.erlang.cookie \
    -e RABBITMQ_DEFAULT_USER=dcxuexi \
    -e RABBITMQ_DEFAULT_PASS=123456 \
    --name mq2 \
    --hostname mq2 \
    -p 25673:5672 \
    -p 15673:15672 \
    rabbitmq:3.11-management

docker run -d --net mq-net \
    -v ${PWD}/mq3/rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf \
    -v ${PWD}/.erlang.cookie:/var/lib/rabbitmq/.erlang.cookie \
    -e RABBITMQ_DEFAULT_USER=dcxuexi \
    -e RABBITMQ_DEFAULT_PASS=123456 \
    --name mq3 \
    --hostname mq3 \
    -p 25674:5672 \
    -p 15674:15672 \
    rabbitmq:3.11-management

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

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

### 5.测试 ###

在`mq1`这个节点上添加一个队列：

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

如图，在`mq2`和`mq3`两个控制台也都能看到：

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

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

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

点击这个队列，进入管理页面：

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

然后利用控制台发送一条消息到这个队列：

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

结果在`mq2`、`mq3`上都能看到这条消息：

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

#### 5.2.可用性测试 ####

我们让其中一台节点`mq1`宕机：

docker stop mq1

然后登录`mq2`或`mq3`的控制台，发现`simple.queue`也不可用了：

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

说明数据并没有拷贝到`mq2`和`mq3`。

[ff224e74047c4e25b44429e6d5dc35db.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/40dbf3d768d54cc18beaea5aba122737.png
[5a1c7189ffbe46d9af763bdf3bb2b219.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/557b984a6aea436eb44158b9084ad32d.png
[9c77012957df4d479f8568801c9a68a8.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/6f101e12d98c4ec28f28bedf79b1d69c.png
[941f0bfd54664d8cb945f3bc6395115e.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/47aa4f23760f4c9c8c15b8793ae465b7.png
[d14ecee892104ea694eff9ac4c73e969.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/86512880e3fa4253bbc0fe902be37fc2.png
[34a4106c3d764346aa9a2df5c0386135.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/4d36d5080acb463ba0b13a4977dd8a22.png
[62d0b9973e284619a0513ada1ff1c6e5.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/7c44886af3fb4ab7ab719f4f074a4796.png
[20872b7b45a5472285f4850aa074feb5.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/bcdea364cc514062806cb3f01b918e1e.png
[baaa5913b1e942b0a6e4fad084caacb6.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/9664d0a909194b3988e07eec8651e2d2.png
[41b0672ab80a405aaec2ea63f03f40b3.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/4e75a2fff6694652af4de1e58bb853da.png
[325062df73cc42058fe676cbcbee99ea.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/b74453d196544b39b7cea0751a29c9cd.png
[5ff1861e33c740f3a1ad1fbf28cea60d.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/01e62cbcd1e643729f30b2689b2f31c2.png