当前位置：首页 > news >正文

docker搭建rabbit集群

news 2025/9/14 6:59:33

1.去rabbitMQ官网拉去images

我当前使用的是最新版本的镜像：rabbitmq:3.12-management

2.创建一个集群专用网络

docker的容器相互隔离是不可通信的，我们自行创建一个网络后，创建容器时给他们放在一起，就可以通信了。

docker network create rabbit-net  --driver bridge

我们的网卡名称为：rabbit-net

3.构建出三个实例

我们在做容器时候：run后面参数依次简单说明一下
-name 镜像名称
–hostname 修改主机名
-v 做了宿主机与容器文件映射
-p 做了端口通信
–network 把这几个节点放到同一个网卡上
-d 让容器后台执行
选择镜像版本号

node01

docker run --name rabbit01 --hostname=node01  \
-v /mydata/rabbitMQ/node01:/var/lib/rabbitmq  \
-p 5672:5672  \
-p 15672:15672  \
--network rabbit-net  \
-d  \
rabbitmq:3.12-management

node02

docker run --name rabbit02 --hostname=node02  \
-v /mydata/rabbitMQ/node02:/var/lib/rabbitmq  \
-p 5673:5672  \
-p 15673:15672  \
--network rabbit-net  \
-d  \
rabbitmq:3.12-management

node03

docker run --name rabbit03 --hostname=node03  \
-v /mydata/rabbitMQ/node03:/var/lib/rabbitmq  \
-p 5674:5672  \
-p 15674:15672  \
--network rabbit-net  \
-d  \
rabbitmq:3.12-management

4.修改各个容器的cookie

CLI如何验证节点：Erlang Cookie
RabbitMQ节点和 CLI 工具（例如rabbitmqctl）使用cookie来确定是否允许它们相互通信。
为了使两个节点能够通信，它们必须具有相同的共享密钥，称为 Erlang cookie。cookie 只是一串最多 255 个字符的字母数字字符。
每个集群节点都必须有相同的cookie。

下面将统一使用node01的cookie，以保证每个节点有相同的cookie。

[root@localhost node01]# cat .erlang.cookie 
QLPBURUFDGAORQHBQXIB
[root@localhost node02]# cat .erlang.cookie 
UJJVRAMWCGUDWFMUVZSK
[root@localhost node03]# cat .erlang.cookie 
QRMWUHLBULEHAYJNKPXZ

Node01的cookie：QLPBURUFDGAORQHBQXIB

把rabbit01容器中的/var/lib/rabbitmq/.erlang.cookie复制给rabbit02 rabbit03

由于我们已经做了宿主机与容器的文件映射，这里直接从宿主机网rabbit02 rabbit03即可

[root@localhost]# docker cp /mydata/rabbitMQ/node01/.erlang.cookie  rabbit02:/var/lib/rabbitmq/
Preparing to copy...
Copying to container - 2.048kB
Successfully copied 2.048kB to rabbit02:/var/lib/rabbitmq/
[root@localhost]# docker cp /mydata/rabbitMQ/node01/.erlang.cookie  rabbit03:/var/lib/rabbitmq/
Preparing to copy...
Copying to container - 2.048kB
Successfully copied 2.048kB to rabbit03:/var/lib/rabbitmq/

分别在宿主机node02 node03查看cookie文件

[root@localhost node02]# cat .erlang.cookie 
QLPBURUFDGAORQHBQXIB[root@localhost node02]# 
[root@localhost node03]# cat .erlang.cookie 
QLPBURUFDGAORQHBQXIB[root@localhost node03]#

Node02 node03都变成了：QLPBURUFDGAORQHBQXIB

给node02 node03 节点重启是他们cookie生效

[root@localhost]# docker restart rabbit02
rabbit02
[root@localhost]# docker restart rabbit03
rabbit03

5.容器相互挂接

rabbit01 - < rabbit02 -< rabbit03

在这里插入图片描述

我们这里让rabbit01当做主节点 rabbit02挂到rabbit01上 rabbit03挂到rabbit02上

rabbit01操作步骤：

1.进入容器（docker exec -it rabbit01 bash）
2.只关闭rabbitmq服务（rabbitmqctl stop_app）（rabbitmqctl stop 会将 Erlang 虚拟机关闭，rabbitmqctl stop_app只关闭RabbitMQ 服务）
3.重置这个节点（rabbitmqctl reset）
4.启动服务（rabbitmqctl start_app）
5. exit

[root@localhost]# docker exec -it rabbit01 bash
root@node01:/# rabbitmqctl stop_app
Stopping rabbit application on node rabbit@node01 ...
root@node01:/# rabbitmqctl reset
Resetting node rabbit@node01 ...
root@node01:/# rabbitmqctl start_app
Starting node rabbit@node01 ...
root@node01:/# exit
exit

rabbit02操作步骤：

1.进入容器（docker exec -it rabbit02 bash）
2.只关闭rabbitmq服务（rabbitmqctl stop_app）（rabbitmqctl stop 会将 Erlang 虚拟机关闭，rabbitmqctl stop_app只关闭RabbitMQ 服务）
3.重置这个节点（rabbitmqctl reset）
4.加入节点rabbit01（rabbitmqctl join_cluster rabbit@node01）
5.启动服务（rabbitmqctl start_app）
6. exit

[root@localhost rabbitMQ]# docker exec -it rabbit02 bash
root@node02:/# rabbitmqctl stop_app
Stopping rabbit application on node rabbit@node02 ...
root@node02:/# rabbitmqctl reset
Resetting node rabbit@node02 ...
root@node02:/# rabbitmqctl join_cluster rabbit@node01
Clustering node rabbit@node02 with rabbit@node01
root@node02:/# rabbitmqctl start_app
Starting node rabbit@node02 ...
root@node02:/# exit
exit

rabbit03步骤：

1.进入容器（docker exec -it rabbit03 bash）
2.只关闭rabbitmq服务（rabbitmqctl stop_app）（rabbitmqctl stop 会将 Erlang 虚拟机关闭，rabbitmqctl stop_app只关闭RabbitMQ 服务）
3.重置这个节点（rabbitmqctl reset）
4.加入节点rabbit02（rabbitmqctl join_cluster rabbit@node02）
5.启动服务（rabbitmqctl start_app）
6. exit

[root@localhost]# docker exec -it rabbit03 bash
root@node03:/# rabbitmqctl stop_app
Stopping rabbit application on node rabbit@node03 ...
root@node03:/# rabbitmqctl reset
Resetting node rabbit@node03 ...
root@node03:/# rabbitmqctl join_cluster rabbit@node02
Clustering node rabbit@node03 with rabbit@node02
root@node03:/# rabbitmqctl start_app
Starting node rabbit@node03 ...
root@node03:/# exit
exit