集群模式介紹

RabbitMQ集群模式有兩種：普通模式和鏡像模式

• 普通模式：默認模式，多個節(jié)點組成的普通集群，消息隨機發(fā)送到其中一個節(jié)點的隊列上，其他節(jié)點僅保留元數(shù)據(jù)，各個節(jié)點僅有相同的元數(shù)據(jù)，即隊列結構、交換器結構、交換器與隊列綁定關系、vhost。消費者消費消息時，會從各個節(jié)點拉取消息，如果保存消息的節(jié)點故障，則無法消費消息，如果做了消息持久化，那么得等該節(jié)點恢復，然后才可被消費；如果沒有持久化的話，就會產(chǎn)生消息丟失的現(xiàn)象。
• 鏡像模式：它是在普通模式的基礎上，把需要的隊列做成鏡像隊列，存在于多個節(jié)點來實現(xiàn)高可用(HA)。該模式解決了上述問題，Broker會主動地將消息實體在各鏡像節(jié)點間同步，在consumer取數(shù)據(jù)時無需臨時拉取。該模式帶來的副作用也很明顯，除了降低系統(tǒng)性能外，如果鏡像隊列數(shù)量過多，加之大量的消息進入，集群內部的網(wǎng)絡帶寬將會被大量消耗。通常地，對可靠性要求較高的場景建議采用鏡像模式。

1、普通集群的搭建

1.1、普通集群架構介紹

架構圖

1.2、環(huán)境準備

拉取RabbitMQ鏡像

docker pull rabbitmq:3.7-management

創(chuàng)建并運行三個RabbitMQ容器節(jié)點，一主兩從

命令如下：

#rabbitmqCluster01 主節(jié)點
docker run -d --hostname rabbitmq01 --name rabbitmqCluster01 -v `pwd`/rabbitmq01:/var/lib/rabbitmq -p 15672:15672 -p 5672:5672 -e RABBITMQ_ERLANG_COOKIE='rabbitmqCookie' rabbitmq:3.7-management

#rabbitmqCluster02 從節(jié)點
docker run -d --hostname rabbitmq02 --name rabbitmqCluster02 -v `pwd`/rabbitmq02:/var/lib/rabbitmq -p 7002:15672 -p 5673:5672 -e RABBITMQ_ERLANG_COOKIE='rabbitmqCookie'  --link rabbitmqCluster01:rabbitmq01 rabbitmq:3.7-management

#rabbitmqCluster03 從節(jié)點
docker run -d --hostname rabbitmq03 --name rabbitmqCluster03 -v `pwd`/rabbitmq03:/var/lib/rabbitmq -p 8002:15672 -p 5674:5672 -e RABBITMQ_ERLANG_COOKIE='rabbitmqCookie'  --link rabbitmqCluster01:rabbitmq01 --link rabbitmqCluster02:rabbitmq02  rabbitmq:3.7-management

-d 后臺運行容器；

–name 指定容器名；

-p 指定服務運行的端口（5672：應用訪問端口；15672：控制臺Web端口號），控制臺端口用于管理rabbitmq，應用訪問端口號為rabbitclient等應用訪問。；

-v 映射目錄或文件，pwd 當前目錄；

–hostname 主機名（RabbitMQ的一個重要注意事項是它根據(jù)所謂的 “節(jié)點名稱” 存儲數(shù)據(jù)，默認為主機名）；

-e 指定環(huán)境變量；（RABBITMQ_DEFAULT_VHOST：默認虛擬機名；RABBITMQ_DEFAULT_USER：默認的用戶名；RABBITMQ_DEFAULT_PASS：默認用戶名的密碼，RABBITMQ_ERLANG_COOKIE 節(jié)點認證作用，部署集成時 需要同步該值）

–link 用于容器的鏈接

查看運行中的三個RabbitMQ容器：

登錄 RabbitMQ 控制臺界面：

rabbitmq01 節(jié)點：

rabbitmq02 節(jié)點：

rrabbitmq03 節(jié)點

1.3、集群搭建

將rabbitmqCluster02 節(jié)點和 rabbitmqCluster03 節(jié)點加入 rabbitmqCluster01 創(chuàng)建集群

進入 rabbitmqCluster02 節(jié)點和 rabbitmqCluster03 節(jié)點，在兩個節(jié)點分別執(zhí)行一下加入集群的命令：

rabbitmqctl stop_app

rabbitmqctl reset
#rabbitmq01為rabbitmqCluster01容器中的hostname
rabbitmqctl join_cluster --ram rabbit@rabbitmq01

rabbitmqctl start_app

rabbitmqCluster02 節(jié)點:

rabbitmq-slave1 節(jié)點：

執(zhí)行完后在任意節(jié)點查看集群狀態(tài)：

rabbitmqctl cluster_status

如果出現(xiàn)如下顯示，集群搭建成功：

之后我們在主節(jié)點的web管理頁可以看到兩個從節(jié)點了：

2、鏡像集群的搭建

鏡像集群的結構圖

2.1、配置鏡像集群的策略

1、使用命令配置策略：

rabbitmqctl set_policy [-p Vhost] [--priority <priority>] [--apply-to <apply-to>] Name Pattern Definition

參數(shù)說明：

-p Vhost： 可選參數(shù)，針對指定 vhost 下的 queue 進行設置

Name: policy 的名稱

Pattern: queue 的匹配模式(正則表達式)

Definition：鏡像定義，包括三個部分 ha-mode, ha-params, ha-sync-mode

ha-mode：指明鏡像隊列的模式，有效值為 all/exactly/nodes

all：表示在集群中所有的節(jié)點上進行鏡像

exactly：表示在指定個數(shù)的節(jié)點上進行鏡像，節(jié)點的個數(shù)由 ha-params 指定

nodes：表示在指定的節(jié)點上進行鏡像，節(jié)點名稱通過 ha-params 指定

ha-params：作為參數(shù)，為 ha-mode 的補充

ha-sync-mode：進行隊列中消息的同步方式，有效值為 automatic 和 manual

pririty：可選參數(shù)，policy的優(yōu)先級

在任意節(jié)點上添加策略：

#^hello 匹配hello開頭的隊列
rabbitmqctl set_policy ha-all "^hello" '{"ha-mode":"all","ha-sync-mode":"automatic"}'

在所有節(jié)點的以hello開頭的隊列上都添加了策略：以后當主節(jié)點宕機時，hello隊列里未消費的消息也不會丟失，會復制到其他節(jié)點上。

刪除策略：

#rabbitmqctl clear_policy 策略名稱
rabbitmqctl clear_policy ha-all

2、管理界面配置策略

登錄 rabbitmq 管理頁面 ——> Admin ——> Policies ——> Add / update a policy

name：策略名稱

Pattern：^匹配符，只有一個^代表匹配所有。^message指同步“message”開頭的隊列名稱

Definition：ha-mode=all 為匹配類型，分為3種模式：all（表示所有的queue）

Priority:優(yōu)先級，首先根據(jù)priority排序，值越大的優(yōu)先級越高；相同priority則根據(jù)創(chuàng)建時間排序，越晚創(chuàng)建的優(yōu)先級越高。

Operator Policy 和 User Policy 的區(qū)別：

• Operator Policy 是給服務提供商或公司基礎設施部門用來設置某些需要強制執(zhí)行的通用規(guī)則
• User Policy 是給業(yè)務應用用來設置的規(guī)則

到此這篇關于Docker搭建RabbitMQ集群的方法步驟的文章就介紹到這了,更多相關Docker搭建RabbitMQ集群內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

最新評論