本文是基于Docker安装MQ，所以docker的安装不再说明。
Docker 的安装请参见：Docker的基本安装和使用
1. 环境准备
- 主机两台：192.168.3.92 ，192.168.3.93（也可多台）
- Docker服务已安装
2. RabbitMQ的下载
请大家根据自己的实际需求，下载对应的Docker镜像，公司的实际需要是需要管理界面、需要延迟队列，所以我们需要安装这个插件的镜像。查找方式如下：
docker search rabbitmq_delay
可以查询到对应的镜像
image
以上两个版本随便挑选，我选择的是exozet/rabbitmq-delay-management
docker pull exozet/rabbitmq-delay-management
3. 安装启动容器
1） 在192.168.3.92 的安装
直接运行docker命令启动一个容器
docker run -d --hostname rabbitmq1 \
--add-host="rabbitmq1":192.168.3.92 \
--add-host="rabbitmq2":192.168.3.93 \
--name rabbit1\
--restart=always\
-p "4369:4369" \
-p "5672:5672" \
-p "15672:15672" \
-p "25672:25672" \
-v /data/rabbitmq01:/var/lib/rabbitmq:z \
-e RABBITMQ_DEFAULT_USER=jffwuser \
-e RABBITMQ_DEFAULT_PASS=jffw123 \
-e RABBITMQ_ERLANG_COOKIE='jffwcookie' \
erikopa/rabbitmq-management-x-delayed-message
参数说明
-d 容器后台运行
--hostname rabbitmq1 容器的主机名为 rabbitmq1
--add-host="rabbitmq1":192.168.3.92 \ 修改容器内部的hosts
--add-host="rabbitmq2":192.168.3.93 \ 修改容器内部的hosts--name rabbit1 容器名为rabbit1，在宿主机上运行“docker ps”命令时显示的名称
--log-opt max-size=10m 日志文件单个最大10M
--log-opt max-file=3 日志文件最多保留3个
-p "4369:4369" 映射宿主机端口4369到容器端口4369，主机端口在前
-p "5672:5672" 略
-p "15672:15672" 略
-p "25672:25672" 略
-v /data/rabbitmq01:/var/lib/rabbitmq:z \ 将宿主机目录/data/rabbitmq挂载到容器的/data/rabbitmq01目录。z是一个标记，在selinux环境下使用。
-e RABBITMQ_DEFAULT_USER=jffwuser 设置rabbitmq默认用户为jffwuser
-e RABBITMQ_DEFAULT_PASS=jffw123 设置rabbitmq默认密码为password01
-e RABBITMQ_ERLANG_COOKIE='jffwcookie' 设置rabbitmq的cookie为“jffwcookie”，可以自定义为其他文本，容器保持一致即可。
2） 在192.168.3.93 的安装
直接运行docker命令启动一个容器
docker run -d --hostname rabbitmq2 \
--add-host="rabbitmq1":192.168.3.92 \
--add-host="rabbitmq2":192.168.3.93 \
--name rabbit2\
--restart=always\
-p "4369:4369" \
-p "5672:5672" \
-p "15672:15672" \
-p "25672:25672" \
-v /data/rabbitmq02:/var/lib/rabbitmq:z \
-e RABBITMQ_DEFAULT_USER=jffwuser \
-e RABBITMQ_DEFAULT_PASS=jffw123 \
-e RABBITMQ_ERLANG_COOKIE='jffwcookie' \
erikopa/rabbitmq-management-x-delayed-message
3. 集群的设置
上面的步骤，只是启动了两个不相干的MQ服务，现在我们要把两个服务设置为集群模式。
1） 在192.168.3.92 的设置
使用docker进入我们刚刚已成功运行的容器
docker ps #查询到我们的容器ID
docker exec -it [容器ID] /bin/bash #进入到容器里面
rabbitmqctl stop_app #停止MQ服务
rabbitmqctl reset #重置MQ
rabbitmqctl set_user_tags jffwuser administrator #设置管理员
rabbitmqctl start_app #启动MQ服务
2）在192.168.3.93的设置
也需要进入我们的容器
docker ps #查询到我们的容器ID
docker exec -it [容器ID] /bin/bash #进入到容器里面
rabbitmqctl stop_app #停止MQ服务
rabbitmqctl reset #重置MQ
rabbitmqctl join_cluster rabbit@rabbitmq1 #加入集群，主要是“rabbitmq1”，表示MQ加入到“，rabbitmq1”，rabbitmq1在容器启动的时候，已经定义好。
rabbitmqctl start_app #启动MQ服务
3） 需要再次在192.168.3.92 设置
这个也需要进入到容器里面配置，如果你已在容器里，请忽略进入命令
docker ps #查询到我们的容器ID
docker exec -it [容器ID] /bin/bash #进入到容器里面
rabbitmqctl set_policy -p /jffw ha-all "^jffw" '{"ha-mode":"all"}' #配置镜像队列
4. 遇到的问题
1）在第二个MQ启动时，一直报错，具体错误如下：
Error description:
{could_not_start,rabbit,
{{case_clause,
{timeout,
[rabbit_delayed_messagerabbit@rabbitmq2,
rabbit_delayed_messagerabbit@rabbitmq2_index]}},
[{rabbit_boot_steps,'-run_step/2-lc$^1/1-1-',1,
[{file,"src/rabbit_boot_steps.erl"},{line,49}]},
{rabbit_boot_steps,run_step,2,
[{file,"src/rabbit_boot_steps.erl"},{line,49}]},
{rabbit_boot_steps,'-run_boot_steps/1-lc$^0/1-0-',1,
[{file,"src/rabbit_boot_steps.erl"},{line,26}]},
{rabbit_boot_steps,run_boot_steps,1,
[{file,"src/rabbit_boot_steps.erl"},{line,26}]},
{rabbit,start,2,[{file,"src/rabbit.erl"},{line,713}]},
{application_master,start_it_old,4,
[{file,"application_master.erl"},{line,273}]}]}}
问题原因：
若搭建的集群需要用到延时队列，则加入集群的节点类型需要为磁盘节点，不能以内存节点的形式加入集群，否则无法启动节点。
修改如下：
原来第二个节点加入的方式使用如下命令
rabbitmqctl join_cluster --ram rabbit@rabbitmq1
删除掉"--ram"，加入集群
rabbitmqctl join_cluster rabbit@rabbitmq1
网友评论