通过 Erlang 的分布式特性&＃xff08;通过 magic COOKIE 认证节点&＃xff09;进行 RabbitMQ 集群&＃xff0c;各 RabbitMQ 服务为对等节点&＃xff0c;即每个节点都提供服务给客户端连接&＃xff0c;进行消息发送与接收。
这些节点通过 RabbitMQ HA 队列&＃xff08;镜像队列&＃xff09;进行消息队列结构复制。本方案中搭建 3 个节点&＃xff0c;并且都是磁盘节点&＃xff08;所有节点状态保持一致&＃xff0c;节点完全对等&＃xff09;&＃xff0c;只要有任何一个节点能够工作&＃xff0c;RabbitMQ 集群对外就能提供服务。
- CentOS 6.4&＃xff0c;64位
- RabbitMQ 3.1.5
- HAProxy 1.4.22
RabbitMQ 集群安装在 3 个节点上&＃xff1a;192.168.1.1、192.168.1.2、192.168.1.3&＃xff1b;
HAProxy 安装在 192.168.1.4 上&＃xff0c;用于对外提供 RabbitMQ 均衡。
所需安装包下载。
1. 安装 erlang、rabbitmq
在 192.168.1.1、192.168.1.2、192.168.1.3 三个节点上安装&＃xff0c;然后开启 RabbitMQ 监控插件&＃xff1a;
rabbitmq-plugins enable rabbitmq_management |
2. 修改 /etc/hosts
加入集群 3 个节点的描述&＃xff1a;
192.168.1.1 node1192.168.1.2 node2192.168.1.3 node3 |
3. 设置 Erlang COOKIE
Erlang COOKIE 文件&＃xff1a;/var/lib/rabbitmq/.erlang.COOKIE。这里将 node1 的该文件复制到 node2、node3&＃xff0c;由于这个文件权限是 400&＃xff0c;所以需要先修改 node2、node3 中的该文件权限为 777&＃xff1a;
# chmod 777 /var/lib/rabbitmq/.erlang.COOKIE |
然后将 node1 中的该文件拷贝到 node2、node3&＃xff0c;最后将权限和所属用户/组修改回来&＃xff1a;
# chmod 400 /var/lib/rabbitmq/.erlang.COOKIE# chown rabbitmq /var/lib/rabbitmq/.erlang.COOKIE# chgrp rabbitmq /var/lib/rabbitmq/.erlang.COOKIE |
4. 使用 -detached 参数运行各节点
# rabbitmqctl stop# rabbitmq-server -detached |
5. 组成集群
将 node2、node3 与 node1 组成集群&＃xff1a;
node2 # rabbitmqctl stop_app node2 # rabbitmqctl join_cluster rabbit&＃64;node1node2 # rabbitmqctl start_app node3 # rabbitmqctl stop_app node3 # rabbitmqctl join_cluster rabbit&＃64;node1node3 # rabbitmqctl start_app |
此时 node2 与 node3 也会自动建立连接&＃xff1b;如果要使用内存节点&＃xff0c;则可以使用
node2 # rabbitmqctl join_cluster --ram rabbit&＃64;node1 加入集群。
集群配置好后&＃xff0c;可以在 RabbitMQ 任意节点上执行 rabbitmqctl cluster_status 来查看是否集群配置成功。
6. 设置镜像队列策略
在任意一个节点上执行&＃xff1a;
# rabbitmqctl set_policy ha-all "^" &＃39;{"ha-mode":"all"}&＃39; |
将所有队列设置为镜像队列&＃xff0c;即队列会被复制到各个节点&＃xff0c;各个节点状态保持一直。
完成这 6 个步骤后&＃xff0c;RabbitMQ 高可用集群就已经搭建好了&＃xff0c;最后一个步骤就是搭建均衡器。
7. 安装并配置 HAProxy
在 192.168.1.4 上安装 HAProxy&＃xff0c;然后修改 /etc/haproxy/haproxy.cfg&＃xff1a;
listen rabbitmq_cluster 0.0.0.0:5672mode tcpbalance roundrobinserver node1 192.168.1.1:5672 check inter 2000 rise 2 fall 3 server node2 192.168.1.2:5672 check inter 2000 rise 2 fall 3server node2 192.168.1.3:5672 check inter 2000 rise 2 fall 3 |
京公网安备 11010802041100号