准备工作
1.机器资源(分别安装docker环境)
192.168.1.101
192.168.1.102
192.168.1.103
2.分别配置hosts文件，追加
$?vim /home/rabbitmq/hosts
192.168.1.101 rabbit1 rabbit1
192.168.1.102 rabbit2 rabbit2
192.168.1.103 rabbit3 rabbit3
下载镜像（每台机器）
$?docker pull ?rabbitmq:3.8.9-management
创建目录 （每台机器）
$?mkdir -p /home/rabbitmq
运行镜像（每台机器）
创建容器(rabbit1)
$?docker run --restart=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=admin -e RABBITMQ_DEFAULT_PASS=123456?rabbitmq:3.8.9-management
创建容器(rabbit2)
$?docker run --restart=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=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，容器内部的hostname
-h rabbit1
#将宿主机目录/home/rabbitmq挂载到容器的/var/lib/rabbitmq目录。z是一个标记，在selinux环境下使用。
-v /home/rabbitmq:/var/lib/rabbitmq:z
#设置rabbitmq的cookie可以自定义为其他文本，三个容器保持一致即可。
下面的几句可以不用了 已经过期了，
-e RABBITMQ_ERLANG_COOKIE='xxx_2020'? ? 参数已过期，需要修改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@rabbit1?&& \
rabbitmqctl start_app
将myrabbit3节点加入集群
$?docker exec -it?myrabbit3?bash
$?rabbitmqctl stop_app && \
rabbitmqctl reset && \
rabbitmqctl join_cluster rabbit@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@rabbit2
使用说明
springboot集成
spring.rabbitmq.addresses=192.168.1.101:5672,192.168.1.102:5672,192.168.1.103:5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=123456
spring.rabbitmq.virtual-host=/#支持手动ack模式
spring.rabbitmq.listener.simple.acknowledge-mode=manual
#每个并发的预取条数
spring.rabbitmq.listener.simple.prefetch=10
#并发数
spring.rabbitmq.listener.simple.concurrency=3
#最大并发数
spring.rabbitmq.listener.simple.max-concurrency=10
spring.rabbitmq.listener.direct.acknowledge-mode=manual
队列模式分为普通模式和镜像模式，集群模式建议直接使用镜像队列
ui设置镜像模式
1.全部节点镜像策略创建
2.指定节点数镜像策略创建
参数说明
Pattern 模式："^"为全部；"^all-"为所有all-开头
Priority 优先级：建议10，比较耗费资源
Definition 定义参数：
ha-mode=all 或 exactly；
ha-sync-mode=automatic；
ha-params=2(ha-mode=exactly)；
在cluster中任意节点启用策略，策略会自动同步到集群节点
1 rabbitmqctl set_policy-p/ha-all"^"'{"ha-mode":"all"}'
这行命令在vhost名称为hrsystem创建了一个策略，策略名称为ha-allqueue,策略模式为 all 即复制到所有节点，包含新增节点，策略正则表达式为 “^” 表示所有匹配所有队列名称。例如：
1 rabbitmqctl set_policy-p/ha-all"^message"'{"ha-mode":"all"}'
注意：“^message” 这个规则要根据自己修改，这个是指同步“message”开头的队列名称，我们配置时使用的应用于所有队列，所以表达式为“^”
?
命令设置镜像模式
在任意一个节点上执行：
1 root@live-mq-01:~# rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'
将所有队列设置为镜像队列，即队列会被复制到各个节点，各个节点状态保持一直。
我们去live-mq-02上查看策略。
root@live-mq-02:~# rabbitmqctl list_policies
Listing policies...
/ha-allall^{"ha-mode":"all"}0
...done.
此时镜像集群就已经完成了，可以在任意节点上创建队列，看看其他两个节点是否会同步。
mq添加管理员账号访问ui
rabbitmqctl add_user test 123456
rabbitmqctl set_user_tags test administrator