前提:假如有三臺(tái)機(jī)器:192.168.1.1音比,192.168.1.2,192.168.1.3各臺(tái)機(jī)器都已安裝rabbitMQ,并且可以啟動(dòng)成功昔馋。
1)查看各機(jī)器的主機(jī)名:
cat /etc/hostname
修改三臺(tái)機(jī)器的主機(jī)映射沦寂,在最后添加各機(jī)器的IP和主機(jī)名:
sudo vim /etc/hosts
eg:
192.168.1.1 node1
192.168.1.2 node2
192.168.1.3 node3
2)同步.erlang.cookie谐丢,此文件中的內(nèi)容必須一致杨伙,可以為任意值其监,這是三臺(tái)機(jī)器通信的身份認(rèn)證
進(jìn)入第一臺(tái)機(jī)器:
scp /home/rabbitmq/.erlang.cookie 192.168.1.2:/home/rabbitmq/
scp /home/rabbitmq/.erlang.cookie 192.168.1.3:/home/rabbitmq/
3)分別啟動(dòng)三臺(tái)機(jī)器:
cd /home/rabbitmq/rabbitmq/sbin/
./rabbitmq-server -detached
查看進(jìn)程,得有erlang進(jìn)程和mq進(jìn)程
4)集群搭建:
在兩臺(tái)機(jī)器上分別執(zhí)行:
./rabbitmqctl stop_app
./rabbitmqctl join_cluster rabbit@node1
./rabbitmqctl start_app
說(shuō)明:
rabbitmqctl join_cluster --ram rabbit@node1
rabbitmqctl join_cluster --disc rabbit@node1
在RabbitMQ集群中的節(jié)點(diǎn)只有兩種類(lèi)型:內(nèi)存節(jié)點(diǎn)/磁盤(pán)節(jié)點(diǎn)限匣,單節(jié)點(diǎn)系統(tǒng)只運(yùn)行磁盤(pán)類(lèi)型的節(jié)點(diǎn)抖苦。而在集群中,可以選擇配置部分節(jié)點(diǎn)為內(nèi)存節(jié)點(diǎn)米死。
為了保證集群的高可用性锌历,必須保證集群中有兩個(gè)以上的磁盤(pán)節(jié)點(diǎn),來(lái)保證當(dāng)有一個(gè)磁盤(pán)節(jié)點(diǎn)崩潰了峦筒,集群還能對(duì)外提供訪問(wèn)服務(wù)究西。
5)然后查看集群狀態(tài):
rabbitmqctl cluster_status
會(huì)顯示集群中各幾點(diǎn)的狀態(tài)以及節(jié)點(diǎn)類(lèi)型等信息
6)配置鏡像隊(duì)列:
普通模式:默認(rèn)的集群模式。
鏡像模式:把需要的隊(duì)列做成鏡像隊(duì)列勘天,存在于多個(gè)節(jié)點(diǎn)怔揩,屬于RabbitMQ的HA方案。只有配置了此模式脯丝,才能在主節(jié)點(diǎn)宕機(jī)后商膊,正常使用。
策略 結(jié)果
all 隊(duì)列鏡像到所有節(jié)點(diǎn)
exactly
配置方式:
rabbitmqctl set_policy [-p <vhost>] [--priority <priority>] [--apply-to <apply-to>] <name> <pattern> <definition>
參數(shù)名稱(chēng) 描述
-p 可選參數(shù)宠进,針對(duì)指定 vhost 下的exchange或 queue
–priority 可選參數(shù)晕拆,policy 的優(yōu)先級(jí)
–apply-to 可選參數(shù),策略適用的對(duì)象類(lèi)型材蹬,其值可為 “queues”, “exchanges” 或 “all”.默認(rèn)是”all”
name policy 的名稱(chēng)
pattern 匹配模式(正則表達(dá)式)
definition 鏡像定義实幕,json 格式,包括三部分(ha-mode,ha-params,ha-sync-mode)具體配置見(jiàn)下表
definition參數(shù)詳情
參數(shù)名稱(chēng) 描述
ha-mode 指名鏡像隊(duì)列模式堤器,其值可為”all”,”exactly”或”nodes”昆庇,all:表示在集群所有節(jié)點(diǎn)上進(jìn)行鏡像;exactly 表示在指定個(gè)數(shù)的節(jié)點(diǎn)上鏡像闸溃,節(jié)點(diǎn)個(gè)數(shù)由 ha-params 指定整吆;nodes:表示在指定節(jié)點(diǎn)上進(jìn)行鏡像,節(jié)點(diǎn)名稱(chēng)通過(guò)ha-params 指定辉川。
ha-params ha-mode模式需要用到的參數(shù):exactly 模式下為數(shù)字表述鏡像節(jié)點(diǎn)數(shù)表蝙,nodes 模式下為節(jié)點(diǎn)列表表示需要鏡像的節(jié)點(diǎn)。
ha-sync-mode 鏡像隊(duì)列中消息的同步方式乓旗,其值可為”automatic”或”manually”.
例子:
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'
清除策略:
rabbitmqctl clear_policy [-p <vhost>] <name>
查看策略:
查看
rabbitmqctl list_policies [-p <vhost>]
實(shí)際操作:
cd /home/rabbitmq/rabbitmq/sbin/
./rabbitmqctl set_policy -p oa-uat ha-oauat "^" '{"ha-mode":"all"}'
./rabbitmqctl set_policy -p oa ha-oa "^" '{"ha-mode":"all"}'
./rabbitmqctl list_policies -p oa
./rabbitmqctl list_policies -p oa-uat