Docker多台主机安装RabbitMQ集群

本文是基于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