- 本文实现在一个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
网络环境设置好之后，就开始准备创建容器了， 在创建之前有几点需要注意的地方
- 如果要做集群的话 一定要注意erlang 的 cookie的一致性， 使用 rabbitmq镜像里面
RABBITMQ_ERLANG_COOKIE这个来进行设置 (重要) - 设置每个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
