CentOSDocker安装RabbitMQ集群(rabbitmq:3.8.9management)

准备工作

1.机器资源(分别安装docker环境)

建议机器配置&＃xff1a; centos7.x 4G及以上 100GB及以上 2核及以上

192.168.1.101
192.168.1.102
192.168.1.103

2.分别配置hosts文件&＃xff0c;追加
$ vim /home/rabbitmq/hosts

192.168.1.101 rabbit1 rabbit1
192.168.1.102 rabbit2 rabbit2
192.168.1.103 rabbit3 rabbit3

下载镜像&＃xff08;每台机器&＃xff09;

$ docker pull rabbitmq:3.8.9-management

创建目录 &＃xff08;每台机器&＃xff09;

$ mkdir -p /home/rabbitmq

运行镜像&＃xff08;每台机器&＃xff09;

创建容器(rabbit1)

$ docker run --restart&＃61;unless-stopped -h rabbit1 -d -p 5672:5672 -p 15672:15672 -p 25672:25672 -p 4369:4369 --name myrabbit1 \
-v /home/rabbitmq:/var/lib/rabbitmq:z -v /home/rabbitmq/hosts:/etc/hosts \
-e RABBITMQ_DEFAULT_USER&＃61;admin -e RABBITMQ_DEFAULT_PASS&＃61;123456 rabbitmq:3.8.9-management

创建容器(rabbit2)

$ docker run --restart&＃61;unless-stopped -h rabbit2 -d -p 5672:5672 -p 15672:15672 -p 25672:25672 -p 4369:4369 --name myrabbit2 \
-v /home/rabbitmq:/var/lib/rabbitmq:z -v /home/rabbitmq/hosts:/etc/hosts \
rabbitmq:3.8.9-management

创建容器(rabbit3)

$ docker run --restart&＃61;unless-stopped -h rabbit3 -d -p 5672:5672 -p 15672:15672 -p 25672:25672 -p 4369:4369 --name myrabbit3 \
-v /home/rabbitmq:/var/lib/rabbitmq:z -v /home/rabbitmq/hosts:/etc/hosts \
rabbitmq:3.8.9-management

参数说明
#容器后台运行
-d
#容器的主机名为 rabbit1&＃xff0c;容器内部的hostname
-h rabbit1
#将宿主机目录/home/rabbitmq挂载到容器的/var/lib/rabbitmq目录。z是一个标记&＃xff0c;在selinux环境下使用。
-v /home/rabbitmq:/var/lib/rabbitmq:z
#设置rabbitmq的COOKIE可以自定义为其他文本&＃xff0c;三个容器保持一致即可。
-e RABBITMQ_ERLANG_COOKIE&＃61;&＃39;xxx_2020&＃39; 参数已过期&＃xff0c;需要修改erlang.COOKIE

机器分别配置并重启容器(erlang.COOKIE)

$ chmod 600 /home/rabbitmq/.erlang.COOKIE

$ vim /home/rabbitmq/.erlang.COOKIE

xxx_2020

绑定集群

将myrabbit1节点重置

$ docker exec -it myrabbit1 bash

$ rabbitmqctl stop_app && \
rabbitmqctl reset && \
rabbitmqctl start_app

将myrabbit2节点加入集群

$ docker exec -it myrabbit2 bash

$ rabbitmqctl stop_app && \
rabbitmqctl reset && \
rabbitmqctl join_cluster rabbit&＃64;rabbit1 && \
rabbitmqctl start_app

将myrabbit3节点加入集群

$ docker exec -it myrabbit3 bash

$ rabbitmqctl stop_app && \
rabbitmqctl reset && \
rabbitmqctl join_cluster rabbit&＃64;rabbit2 && \
rabbitmqctl start_app

查询集群状态

$ rabbitmqctl cluster_status

故障节点的处理

$ docker exec -it rabbit2 /bin/bash

$ rabbitmqctl stop_app

#在一个正常的节点上移除有问题的节点

$ docker exec -it rabbit1 /bin/bash

$ rabbitmqctl forget_cluster_node rabbit&＃64;rabbit2

使用说明

springboot集成

spring.rabbitmq.addresses&＃61;192.168.1.101:5672,192.168.1.102:5672,192.168.1.103:5672
spring.rabbitmq.username&＃61;admin
spring.rabbitmq.password&＃61;123456
spring.rabbitmq.virtual-host&＃61;/

#支持手动ack模式
spring.rabbitmq.listener.simple.acknowledge-mode&＃61;manual
#每个并发的预取条数
spring.rabbitmq.listener.simple.prefetch&＃61;10
#并发数
spring.rabbitmq.listener.simple.concurrency&＃61;3
#最大并发数
spring.rabbitmq.listener.simple.max-concurrency&＃61;10
spring.rabbitmq.listener.direct.acknowledge-mode&＃61;manual

队列模式分为普通模式和镜像模式&＃xff0c;集群模式建议直接使用镜像队列

1.全部节点镜像策略创建