教你如何從0開始搭建rabbitmq集群
一绘闷、準(zhǔn)備工作
1橡庞、三臺(tái)centos虛擬機(jī)
2、三臺(tái)虛擬機(jī)都安裝了docker
3印蔗、假設(shè)三臺(tái)虛擬機(jī)的ip是192.168.2.128扒最,192.168.2.129,192.168.2.130
二华嘹、搭建rabbitmq集群
1吧趣、3臺(tái)機(jī)子分別配置host文件
vim /etc/hosts
填入內(nèi)容:
192.168.2.128 rabbit1
192.168.2.129 rabbit2
192.168.2.130 rabbit3
2、運(yùn)行rabbit容器
在rabbit1機(jī)器運(yùn)行
docker run -d --hostname rabbit1 --net=host --name myrabbit1 -p 4369:4369 -p 15672:15672 -p 5672:5672 -e RABBITMQ_ERLANG_COOKIE='rabbitcookie' rabbitmq:3.6.15-management
在rabbit2機(jī)器運(yùn)行
docker run -d --hostname rabbit2 --net=host --name myrabbit2 -p 4369:4369 -p 15672:15672 -p 5672:5672 -e RABBITMQ_ERLANG_COOKIE='rabbitcookie' rabbitmq:3.6.15-management
在rabbit3機(jī)器運(yùn)行
docker run -d --hostname rabbit3 --net=host --name myrabbit3 -p 4369:4369 -p 15672:15672 -p 5672:5672 -e RABBITMQ_ERLANG_COOKIE='rabbitcookie' rabbitmq:3.6.15-management
3耙厚、加入集群
在rabbit2機(jī)器執(zhí)行命令
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster rabbit@rabbit1
rabbitmqctl start_app
exit
在rabbit3機(jī)器執(zhí)行命令
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster rabbit@rabbit1
rabbitmqctl start_app
exit
進(jìn)入 192.168.2.130:15672 查看狀態(tài)賬號(hào)密碼是guest/guest
如果要摘除節(jié)點(diǎn)强挫,在rabbit1機(jī)器執(zhí)行:
docker exec -it myrabbit1 bash
rabbitmqctl forget_cluster_node rabbit@rabbit3
exit
點(diǎn)擊queues,填寫隊(duì)列名薛躬,然后新增一個(gè)隊(duì)列
此時(shí)隊(duì)列內(nèi)容沒冗余俯渤,只存在rabbit1中,當(dāng)rabbit1的隊(duì)列服務(wù)掛了型宝,此隊(duì)列也不可用了八匠。
在rabbit1機(jī)器執(zhí)行
docker stop myrabbit1
再查看管理臺(tái)
三、創(chuàng)建鏡像隊(duì)列
重新啟動(dòng)rabbit1
docker start myrabbit1
新建2個(gè)隊(duì)列extqueue和nodesqueue
rabbitmqctl set_policy [-p <vhost>] [--priority <priority>] [--apply-to <apply-to>] <name> <pattern> <definition>
指令參數(shù)詳情
參數(shù)名稱 描述
-p 可選參數(shù)趴酣,針對(duì)指定 vhost 下的exchange或 queue
--priority 可選參數(shù)梨树,policy 的優(yōu)先級(jí)
--apply-to 可選參數(shù),策略適用的對(duì)象類型价卤,其值可為 "queues", "exchanges" 或 "all".默認(rèn)是"all"
name policy 的名稱
pattern 匹配模式(正則表達(dá)式)
definition 鏡像定義,json 格式渊涝,包括三部分(ha-mode,ha-params,ha-sync-mode)具體配置見下表
definition參數(shù)詳情
參數(shù)名稱 描述
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)名稱通過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".
例子:要對(duì)規(guī)則是^ext*的隊(duì)列增加鏡像隊(duì)列瑰排,一共是2個(gè)隊(duì)列
docker exec -it myrabbit1 bash
rabbitmqctl set_policy --apply-to queues extpolicy "^ext*" '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'
exit
例子:要對(duì)規(guī)則是^nodes*的隊(duì)列增加鏡像隊(duì)列,分別在rabbit@rabbit2和rabbit@rabbit3兩臺(tái)服務(wù)器上鏡像
docker exec -it myrabbit1 bash
rabbitmqctl set_policy --apply-to queues nodespolicy "^nodes*" '{"ha-mode":"nodes","ha-params":["rabbit@rabbit2","rabbit@rabbit3"],"ha-sync-mode":"automatic"}'
exit
可以看到都匹配到對(duì)應(yīng)的規(guī)則暖侨,有1個(gè)冗余的隊(duì)列椭住。
此時(shí)我們把rabbit2停掉看一看效果;
在rabbit2的機(jī)器上執(zhí)行
docker stop myrabbit2
nodesqueue隊(duì)列依舊工作
extqueue隊(duì)列的鏡像隊(duì)列換了一個(gè)。