一、集群结构
集群模式非常经典的就是Mirror镜像模式，保证100%数据不丢失，在实际工作中也是用的最多的。并且实现集群非常的简单，一般互联网大厂都会构建这种镜像集群模式。
Mirror镜像队列，目的是为了保证rabbitmq数据的高可靠性解决方案，主要就是实现数据的同步，一般来讲是2-3个节点实现数据同步(对于100%数据可靠性解决方案一般是3节点)。
| 服务器IP | hostname | 节点说明 | 端口 | 管控台地址 |
| 192.168.31.101 | master | rabbitmq master | 5672 | http://192.168.11.71:15672 |
| 192.168.31.102 | slave1 | rabbitmq slave | 5672 | http://192.168.11.72:15672 |
| 192.168.31.103 | slave2 |
rabbitmq slave | 5672 | http://192.168.11.73:15672 |
为了方便之后的操作，这里通过执行 vim /etc/hostname 修改了三台服务器的主机名，主机名如上表中hostname所示，之后在三台服务器上均执行 vim /etc/hosts ,加入以下语句：
192.168.31.101 master
192.168.31.102 slave1
192.168.31.103 slave2目的是三台服务器能够网络互通（使用 ping 命令可以ping通）。
修改 /etc/hosts 和 /etc/hostname 之后正常情况应该是保存之后立即生效的，但是有时不是。
如果没生效的话可采取以下其中一个方案：
- 1）重启服务器
- 2）重启网络服务：sudo /etc/init.d/network restart
二、集群搭建
1. 首先在三个服务器节点上都安装上 RabbitMQ
安装教程参考：Centos7.x安裝 RabbitMQ
2. 文件同步
首先将三台服务器都处于启动状态；
然后选择三个服务器中任意一个节点为Master（这里选择 192.168.31.101 为Master），也就是说我们需要把192.168.31.101的Cookie文件同步到其他两个节点上去，执行以下命令
scp /var/lib/rabbitmq/.erlang.cookie 192.168.31.102:/var/lib/rabbitmq/
scp /var/lib/rabbitmq/.erlang.cookie 192.168.31.103:/var/lib/rabbitmq/
# scp 是 secure copy 的缩写, scp 是 linux 系统下基于 ssh 登陆进行安全的远程文件拷贝命令。3. 组建集群
3.1 停止MQ服务
这里不能使用原来的停止命令：/etc/init.d/rabbitmq-server stop，而是使用下面的停止命令（三个节点都执行一下）：
rabbitmqctl stop执行完可以用这个命令看下是否关闭成功：
lsof -i:5672 # lsof -i 是指列出符合条件的进程 5672是端口号，格式是 lsof -i:端口号3.2 组成集群
首先对3个服务器节点都执行启动命令，命令如下：
rabbitmq-server -detached # 对应的关闭命令:rabbitmqctl stop然后将 slave 从节点加入集群中：
对于192.168.31.102和192.168.31.103两个从节点分别执行以下命令：
注意执行下面的命令的时候：需要配置/etc/hosts 必须相互能够寻址到，在第一步中有操作说明
rabbitmqctl stop_app
# --ram 是指以内存的方式运行 不加这个参数的话是默认以 disk 硬盘的方式执行
rabbitmqctl join_cluster --ram rabbit@master
rabbitmqctl start_app如果要从集群中移除某个节点的话，可以在另外其他节点上操作要移除的集群节点
# 在其他服务器节点上移除节点rabbit@slave1
rabbitmqctl forget_cluster_node rabbit@slave1集群启动顺序（内存和磁盘的区别是 rabbitmqctl join_cluster --ram rabbit@master 加入集群命令中有没有使用 --ram），也可以在 rabbitmq控制台查看
集群启动的顺序是固定的，并且是相反的。 如下所述： 启动顺序：磁盘节点 => 内存节点 关闭顺序：内存节点 => 磁盘节点 最后关闭必须是磁盘节点，不然可能回造成集群启动失败、数据丢失等异常情况。集群关闭命令:rabbitmqctl stop，在每个节点上都执行一下。
4. 修改集群名称
PS:修改集群名称（默认为第一个节点的名称）：
rabbitmqctl set_cluster_name rabbitmq_cluster15. 查看集群状态
PS:最后在集群的任意一个节点执行命令：查看集群状态
rabbitmqctl cluster_status
6. 配置镜像队列
设置镜像队列策略（在其中任意一个节点上执行即可）
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'将所有队列设置为镜像队列，并且队列会被复制到所有节点，各个节点状态一致，RabbitMQ高可用集群就已经搭建好了，然后重启服务，可以测试一下其队列是否在从节点同步。
命令行配置策略格式：
rabbitmqctl set_policy [-p <vhost>] [--priority <priority>] [--apply-to <apply-to>] <name> <pattern> <definition>
- -p <vhost>：可选参数，针对指定vhost下的queue进行设置
- --priority：可选参数，policy的优先级
- --apply-to：可选参数，策略适用对象类型，可选queues，exchanges，all
- name：policy策略的名称
- pattern：queue的匹配模式(正则表达式)，^表示匹配所有队列
- definition：镜像定义，包括三个部分ha-mode, ha-params, ha-sync-mode
- 1、ha-mode:指明镜像队列的模式，有效值为 all/exactly/nodes
- all：表示在集群中所有的节点上进行镜像
- exactly：表示在指定个数的节点上进行镜像，节点的个数由ha-params指定
- nodes：表示在指定的节点上进行镜像，节点名称通过ha-params指定
- 2、ha-params：ha-mode模式需要用到的参数
- 3、ha-sync-mode：进行队列中消息的同步方式，有效值为automatic和manual，默认manual
拓展：三、 RabbitMQ安装延迟消息发送的插件 rabbitmq_delayed_message_exchange-0.0.1
1 下载
下载地址：rabbitmq-delayed-message-exchange-0.0.1
2 上传
分别上传到 三台服务器中的 /usr/lib/rabbitmq/lib/rabbitmq_server-3.6.5/plugins/ 目录下
3. 启用
使用 rabbitmq-server -detached 启动RabbitMQ集群，之后再使用下面命令启用 延时消息发送的插件
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
4. 添加延迟队列
访问：192.168.31.101:15672/#/exchanges
，添加延迟队列
之后建立一个 queue，并和该交换机按照 routingKey 绑定，
只是在发送延迟消息时需要注意一下这里：
文章来源：https://www.toymoban.com/news/detail-623421.html
就能实现延迟发送到队列中了。文章来源地址https://www.toymoban.com/news/detail-623421.html
到了这里，关于RabbitMQ集群环境搭建-镜像模式的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
