rabbitmq 在 docker 下的集群设置

• 本文实现在一个docker宿主机的环境下设置 rabbitmq 集群

RabbitMQ是基于高级消息队列协议（AMQP）实现的开源消息代理软件，主要提供消息队列服务。

首先 pull rabbitmq 的docker镜像

docker pull rabbitmq:management

首先我们要是设置docker 的网络环境， 以便于容器之间进行通讯， 这里我们使用 docker network 来进行网络设置,
现在创建一个网络名为my_net且driver为bridge的网络：（默认创建的就是bridge）

docker network create my_net

docker network ls
NETWORK ID          NAME                DRIVER              SCOPE
da6f92e9cb4f        bridge              bridge              local
1ce44ae321b6        host                host                local
f67c52c15141        my_net              bridge              local
7f8fe50b3756        none                null                local

网络环境设置好之后，就开始准备创建容器了， 在创建之前有几点需要注意的地方

1. 如果要做集群的话 一定要注意erlang 的 cookie的一致性， 使用 rabbitmq镜像里面RABBITMQ_ERLANG_COOKIE 这个来进行设置 (重要)
2. 设置每个rabbitmq 的节点名称 使用 RABBITMQ_NODENAME 来设置

所以我们的docker 容器的生成就是这样的：
在同一个RabbitMQ集群中，节点之间并没有主从之分，所有节点会同步相同的队列结构

某种意义上的主机

docker run -d --name=rabbitmq_master -e RABBITMQ_ERLANG_COOKIE=myerlangcookie -e RABBITMQ_NODENAME=mqmaster -p 5672:5672 -p 4369:4369 -p 25672 :25672 -p 15672:15672 --network my_net --network-alias network_mqmaster rabbitmq:management

某种意义上的从机 （留了端口的）

docker run -d --name=rabbitmq_slave1 -e RABBITMQ_ERLANG_COOKIE=myerlangcookie -e RABBITMQ_NODENAME=mqslave1 -p 5673:5672 -p 4370:7369 -p 25673 :25672 -p 15673:15672 --network my_net --network-alias network_mqslave1 rabbitmq:management

某种意义上的从机 （没有留端口的）

docker run -d --name=rabbitmq_slave2 -e RABBITMQ_ERLANG_COOKIE=myerlangcookie -e RABBITMQ_NODENAME=mqslave2 --network my_net --network-alias network_mqslave2 rabbitmq:management

进入到rabbitmq_master当中 使用 rabbitmqctl cluster_status 查看集群状态

docker exec -it rabbitmq_master bash

cd sbin
rabbitmqctl cluster_status

Cluster status of node mqmaster@28c2418baba1 ...
[{nodes,[{disc,[mqmaster@28c2418baba1]}]},
 {running_nodes,[mqmaster@28c2418baba1]},
 {cluster_name,<<"mqmaster@28c2418baba1">>},
 {partitions,[]},
 {alarms,[{mqmaster@28c2418baba1,[]}]}]

看到 nodes 里面 只有当前我们的这个节点并没有其他的节点
现在我们进入到rabbitmq_slave1中配置加入到集群当中,

docker exec -it rabbitmq_slave1 bash
cd sbin
# 再添加集群之前首先要 关闭当前的节点
rabbitmqctl stop_app
# 开始添加到 集群当中, @前面是 节点名称， 后面是 host， host 可以在 查看集群状态的时候获得
#--ram选项表示节点以内存存储方式运行，读写速度快，重启后内容会丢失；不加--ram选项，节点则以磁盘存储方式运行，
 虽然读写速度慢，但是内容一般可以持久保持

rabbitmqctl join_cluster --ram mqmaster@28c2418baba1

Clustering node mqslave1@0a038c6ae449 with mqmaster@28c2418baba1

#重新开启节点
rabbitmqctl start_app

重新回到 rabbitmq_master容器里面查看集群状态

root@28c2418baba1:/sbin# rabbitmqctl cluster_status
Cluster status of node mqmaster@28c2418baba1 ...
[{nodes,[{disc,[mqmaster@28c2418baba1]},
         {ram,[mqslave2@ddb963c55357,mqslave1@0a038c6ae449]}]},
 {running_nodes,[mqslave2@ddb963c55357,mqslave1@0a038c6ae449,
                 mqmaster@28c2418baba1]},
 {cluster_name,<<"mqmaster@28c2418baba1">>},
 {partitions,[]},
 {alarms,[{mqslave2@ddb963c55357,[]},
          {mqslave1@0a038c6ae449,[]},
          {mqmaster@28c2418baba1,[]}]}]

说明集群正常， 创建队列， 发送数据测试

root@28c2418baba1:/sbin# rabbitmqctl list_queues
Timeout: 60.0 seconds ...
Listing queues for vhost / ...
hello   2

每个节点里面数据正常，
一些运维操作
停止某个指定的节点，比如停止第2个节点：
./sbin/rabbitmqctl -n rabbitmq_slave1 stop
查看节点3的集群状态：

./sbin/rabbitmqctl -n rabbitmq_slave2 cluster_status

附一张截图

QQ截图20181024171009.png

参考：
docker network https://www.cnblogs.com/jsonhc/p/7823286.html