集群概述
通過(guò) Erlang 的分布式特性(magic cookie 認(rèn)證節(jié)點(diǎn))進(jìn)行 RabbitMQ 集群,各 RabbitMQ 服務(wù)為對(duì)等節(jié)點(diǎn)遵蚜,即每個(gè)節(jié)點(diǎn)都提供服務(wù)給客戶(hù)端連接帖池,進(jìn)行消息發(fā)送與接收。
這些節(jié)點(diǎn)通過(guò) RabbitMQ HA 隊(duì)列(鏡像隊(duì)列)進(jìn)行消息隊(duì)列結(jié)構(gòu)復(fù)制吭净。本文中搭建 3 個(gè)節(jié)點(diǎn)睡汹,并且都是磁盤(pán)節(jié)點(diǎn)(所有節(jié)點(diǎn)狀態(tài)保持一致,節(jié)點(diǎn)完全對(duì)等)寂殉,只要有任何一個(gè)節(jié)點(diǎn)能夠工作囚巴,RabbitMQ 集群對(duì)外就能提供服務(wù)。
環(huán)境
- CentOS 7友扰,64位
- RabbitMQ 3.6.3
- HAProxy 1.6.0
RabbitMQ 集群安裝在 3 個(gè)節(jié)點(diǎn)上:192.168.1.1彤叉、192.168.1.2、192.168.1.3村怪;HAProxy 安裝在 192.168.1.4 上秽浇,用于對(duì)外提供 RabbitMQ 負(fù)載均衡服務(wù)。
配置步驟
1. 修改 /etc/hosts甚负,并配置ssh相互免密登錄
[root@node1 ~]# vi /etc/hosts
192.168.1.1 node1
192.168.1.2 node2
192.168.1.3 node3
2. 安裝 erlang柬焕、rabbitmq
在 192.168.1.1、192.168.1.2腊敲、192.168.1.3 三個(gè)節(jié)點(diǎn)上安裝击喂,然后開(kāi)啟 RabbitMQ 監(jiān)控插件。
[root@node1 ~]# wget http://www.rabbitmq.com/releases/erlang/erlang-18.1-1.el7.centos.x86_64.rpm
[root@node1 ~]# wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.3/rabbitmq-server-3.6.3-1.noarch.rpm
[root@node1 ~]# rpm -ivh erlang-18.1-1.el7.centos.x86_64.rpm
[root@node1 ~]# rpm -ivh rabbitmq-server-3.6.3-1.noarch.rpm
[root@node1 ~]# rabbitmq-plugins enable rabbitmq_management
3. 設(shè)置 Erlang Cookie
Erlang Cookie 文件:/var/lib/rabbitmq/.erlang.cookie。這里將 node1 的該文件復(fù)制到 node2、node3寝志,由于這個(gè)文件權(quán)限是 400螺捐,所以需要先修改 node2、node3 中的該文件權(quán)限為 777变屁,然后將 node1 中的該文件拷貝到 node2、node3,最后將權(quán)限和所屬用戶(hù)/組修改回來(lái)铲敛。
[root@node1 ~]# chmod 777 /var/lib/rabbitmq/.erlang.cookie
[root@node1 ~]# scp -r /var/lib/rabbitmq/.erlang.cookie root@node2:/var/lib/rabbitmq/.erlang.cookie
[root@node1 ~]# scp -r /var/lib/rabbitmq/.erlang.cookie root@node3:/var/lib/rabbitmq/.erlang.cookie
[root@node1 ~]# chmod 400 /var/lib/rabbitmq/.erlang.cookie
[root@node1 ~]# chown rabbitmq /var/lib/rabbitmq/.erlang.cookie
[root@node1 ~]# chgrp rabbitmq /var/lib/rabbitmq/.erlang.cookie
4. 使用 -detached 參數(shù)運(yùn)行各節(jié)點(diǎn)
[root@node1 ~]# rabbitmqctl stop
[root@node1 ~]# rabbitmq-server -detached
5. 組成集群
將 node2、node3 與 node1 組成集群
[root@node2 ~]# rabbitmqctl stop_app
[root@node2 ~]# rabbitmqctl join_cluster rabbit@node1
[root@node2 ~]# rabbitmqctl start_app
#---------------------------------------------------------------------------------#
[root@node3 ~]# rabbitmqctl stop_app
[root@node3 ~]# rabbitmqctl join_cluster rabbit@node1
[root@node3 ~]# rabbitmqctl start_app
此時(shí) node2 與 node3 也會(huì)自動(dòng)建立連接会钝;如果要使用內(nèi)存節(jié)點(diǎn)伐蒋,則可以使用下面的命令加入集群工三。
[root@node2 ~]# rabbitmqctl join_cluster *--ram* rabbit@node1
集群配置好后,可以在 RabbitMQ 任意節(jié)點(diǎn)上執(zhí)行下面的命令來(lái)查看是否集群配置成功先鱼。
rabbitmqctl cluster_status
6. 設(shè)置鏡像隊(duì)列策略
在任意一個(gè)節(jié)點(diǎn)上執(zhí)行下面的命令
[root@node1 ~]# rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'
將所有隊(duì)列設(shè)置為鏡像隊(duì)列俭正,即隊(duì)列會(huì)被復(fù)制到各個(gè)節(jié)點(diǎn),各個(gè)節(jié)點(diǎn)狀態(tài)保持一直焙畔。完成這 6 個(gè)步驟后掸读,RabbitMQ 高可用集群就已經(jīng)搭建好了,最后一個(gè)步驟就是搭建均衡器宏多。
提示:
RabbitMQ的配置文件為:/etc/rabbitmq/rabbitmq.config
RabbitMQ的環(huán)境配置文件為:/etc/rabbitmq/rabbitmq-env.conf
7. 安裝并配置 HAProxy
在 192.168.1.4 上安裝 HAProxy儿惫,然后修改 /etc/haproxy/haproxy.cfg。
[root@snails ~]# haproxy -vv
[root@snails ~]# vi /etc/haproxy/haproxy.cfg
listen rabbitmq_cluster 0.0.0.0:5672
mode tcp
balance roundrobin
server 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 3
server node2 192.168.1.3:5672 check inter 2000 rise 2 fall 3
listen private_monitoring :8100
mode http
option httplog
stats enable
#設(shè)置haproxy監(jiān)控地址為http://localhost:8100/rabbitmq-stats
stats uri /rabbitmq-stats
stats refresh 5s
[root@snails ~]# /usr/sbin/haproxy -D -f /etc/haproxy/haproxy.cfg -p /var/run/haproxy.pid