普通集群：多個(gè)節(jié)點(diǎn)組成的普通集群，消息隨機(jī)發(fā)送到其中一個(gè)節(jié)點(diǎn)的隊(duì)列上，其他節(jié)點(diǎn)僅保留元數(shù)據(jù)，各個(gè)節(jié)點(diǎn)僅有相同的元數(shù)據(jù)，即隊(duì)列結(jié)構(gòu)、交換器結(jié)構(gòu)、vhost等。消費(fèi)者消費(fèi)消息時(shí)，會(huì)從各個(gè)節(jié)點(diǎn)拉取消息，如果保存消息的節(jié)點(diǎn)故障，則無(wú)法消費(fèi)消息，如果做了消息持久化，那么得等該節(jié)點(diǎn)恢復(fù)，然后才可被消費(fèi)；如果沒(méi)有持久化的話，就會(huì)產(chǎn)生消息丟失的現(xiàn)象。

鏡像集群：它是在普通模式的基礎(chǔ)上，把需要的隊(duì)列做成鏡像隊(duì)列，存在于多個(gè)節(jié)點(diǎn)來(lái)實(shí)現(xiàn)高可用(HA)。該模式解決了上述問(wèn)題，Broker會(huì)主動(dòng)地將消息實(shí)體在各鏡像節(jié)點(diǎn)間同步，在consumer取數(shù)據(jù)時(shí)無(wú)需臨時(shí)拉取。該模式帶來(lái)的副作用也很明顯，除了降低系統(tǒng)性能外，如果鏡像隊(duì)列數(shù)量過(guò)多，加之大量的消息進(jìn)入，集群內(nèi)部的網(wǎng)絡(luò)帶寬將會(huì)被大量消耗。通常地，對(duì)可靠性要求較高的場(chǎng)景建議采用鏡像模式。

一、搭建RabbitMq的運(yùn)行環(huán)境

我本機(jī)是window10，通過(guò)docker搭建兩個(gè)rabbitmq節(jié)點(diǎn)。

1.通過(guò)search查詢(xún)r(jià)abbitmq鏡像

docker search rabbitmq

2.通過(guò)pull拉取rabbitmq的官方最新鏡像

這里最好帶上tag為management的版本，否則拉最新的latest，web管理頁(yè)無(wú)法顯示全，會(huì)提示overview:management only mode

docker pull rabbitmq:3.8.25-management

3.創(chuàng)建容器

docker run -d --name rabbitmq1 -p 5672:5672 -p 15672:15672 --hostname myRabbit1 -e RABBITMQ_DEFAULT_VHOST=my_vhost1 -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin a4eb038c2ecb

--name：容器名稱(chēng)

-p:端點(diǎn)映射

--hostname：rabbitmq的節(jié)點(diǎn)名稱(chēng)

-e RABBITMQ_DEFAULT_VHOST：虛擬主機(jī)名稱(chēng)

-e RABBITMQ_DEFAULT_USER：登錄賬號(hào)

-e RABBITMQ_DEFAULT_PASS：登錄密碼

a4eb038c2ecb是鏡像id，根據(jù)自己情況替換。

4.啟動(dòng)管理頁(yè)面

我們的鏡像默認(rèn)沒(méi)有開(kāi)啟web管理頁(yè)面，所以我們通過(guò)exec命令進(jìn)入容器啟動(dòng)，這個(gè)鏡像的環(huán)境是ubuntu的

PS C:\> docker exec -it 639a151c5440 /bin/bash
root@myRabbit:/# rabbitmq-plugins enable rabbitmq_management

瀏覽器中訪問(wèn)http://localhost:15672/即可打開(kāi)，另一個(gè)rabbitmq如法炮制，區(qū)別之處在于更換端口為5673和15673等，并且創(chuàng)建容器時(shí)使用--link連接第一個(gè)rabbitmq節(jié)點(diǎn)（也可創(chuàng)建橋接網(wǎng)絡(luò)network連接），如下

docker run -d --name rabbitmq2 -p 5673:5672 -p 15673:15672 --hostname myRabbit2 -e RABBITMQ_DEFAULT_VHOST=my_vhost2 -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin --link rabbitmq1:myRabbit1 a4eb038c2ecb

5.設(shè)置erlang cookie

erlang cookie原本可以通過(guò)run容器時(shí)設(shè)置參數(shù)-e RABBITMQ_ERLANG_COOKIE，但是現(xiàn)在過(guò)期棄用了。

我們先通過(guò)docker logs命令查看容器的運(yùn)行日志，尋找home dir參數(shù)如下

PS D:\> docker logs rabbitmq1
//.....這里省略
  Starting broker...2021-11-17 02:19:55.859245+00:00 [info] <0.222.0>
2021-11-17 02:19:55.859245+00:00 [info] <0.222.0>  node           : rabbit@myRabbit1
2021-11-17 02:19:55.859245+00:00 [info] <0.222.0>  home dir       : /var/lib/rabbitmq
2021-11-17 02:19:55.859245+00:00 [info] <0.222.0>  config file(s) : /etc/rabbitmq/conf.d/10-default-guest-user.conf
2021-11-17 02:19:55.859245+00:00 [info] <0.222.0>                 : /etc/rabbitmq/conf.d/management_agent.disable_metrics_collector.conf
2021-11-17 02:19:55.859245+00:00 [info] <0.222.0>  cookie hash    : Aed9pjd9vYWw3hng7Gjmkg==
2021-11-17 02:19:55.859245+00:00 [info] <0.222.0>  log(s)         : /var/log/rabbitmq/rabbit@myRabbit1_upgrade.log
2021-11-17 02:19:55.859245+00:00 [info] <0.222.0>                 : <stdout>
2021-11-17 02:19:55.859245+00:00 [info] <0.222.0>  database dir   : /var/lib/rabbitmq/mnesia/rabbit@myRabbit1

所以.erlang.cookie文件在此路徑下，我們進(jìn)入容器可以看到此文件

root@myRabbit1:~# ls -a /var/lib/rabbitmq
. .. .bash_history .erlang.cookie mnesia

我們?cè)僭O(shè)置erlang cookie的權(quán)限，在容器內(nèi)運(yùn)行如下代碼，如果權(quán)限不夠后續(xù)操作會(huì)報(bào)錯(cuò)

chmod 600 /var/lib/rabbitmq/.erlang.cookie

之后我們通過(guò)docker cp命令將rabbitmq1中的.erlang.cookie文件拷到物理機(jī)上再拷貝到rabbitmq2的容器中，物理機(jī)和容器之間復(fù)制命令如下：

• 容器復(fù)制文件到物理機(jī)：docker cp 容器名稱(chēng):容器目錄
• 物理機(jī)目錄物理機(jī)復(fù)制文件到容器：docker cp 物理機(jī)目錄 容器名稱(chēng):容器目錄

具體代碼如下：

docker cp rabbitmq1:/var/lib/rabbitmq/ d:\workspace\
docker cp d:\workspace\rabbitmq\.erlang.cookie rabbitmq2:/var/lib/rabbitmq/

復(fù)制之后需要重啟rabbitmq2容器，否則執(zhí)行rabbitmqctl命令報(bào)如下錯(cuò)誤：

[error] Cookie file /var/lib/rabbitmq/.erlang.cookie must be accessible by owner only

二、普通模式

重啟后進(jìn)入容器將rabbitmq2的節(jié)點(diǎn)加入rabbitmq1中創(chuàng)建普通集群，分別執(zhí)行如下代碼即可：

rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster --ram rabbit@myRabbit1    //myRabbitmq1為rabbitmq1容器中rabbitmq的hostname
rabbitmqctl start_app

之后我們?cè)賥eb管理頁(yè)可以看到兩個(gè)節(jié)點(diǎn)了。

在任意一個(gè)節(jié)點(diǎn)創(chuàng)建一個(gè)隊(duì)列，另一個(gè)節(jié)點(diǎn)也會(huì)生成相同的隊(duì)列。而且可以發(fā)現(xiàn)rabbitmq2的vhost從my_vhost2變?yōu)榱薽y_vhost1與rabbitmq相同了。

三、鏡像模式

鏡像模式就是在普通模式的基礎(chǔ)上進(jìn)入rabbitmq1容器輸入如下命令即可：

rabbitmqctl set_policy -p my_vhost1 ha-all "^" '{"ha-mode":"all"}' --apply-to all

具體的格式為

rabbitmqctl set_policy [-p Vhost] Name Pattern Definition [Priority]
-p Vhost： 可選參數(shù)，針對(duì)指定vhost下的queue進(jìn)行設(shè)置
Name: policy的名稱(chēng)
Pattern: queue的匹配模式(正則表達(dá)式)
Definition：鏡像定義，包括三個(gè)部分ha-mode, ha-params, ha-sync-mode
        ha-mode:指明鏡像隊(duì)列的模式，有效值為 all/exactly/nodes
            all：表示在集群中所有的節(jié)點(diǎn)上進(jìn)行鏡像
            exactly：表示在指定個(gè)數(shù)的節(jié)點(diǎn)上進(jìn)行鏡像，節(jié)點(diǎn)的個(gè)數(shù)由ha-params指定
            nodes：表示在指定的節(jié)點(diǎn)上進(jìn)行鏡像，節(jié)點(diǎn)名稱(chēng)通過(guò)ha-params指定
        ha-params：作為參數(shù)，為ha-mode的補(bǔ)充
        ha-sync-mode：進(jìn)行隊(duì)列中消息的同步方式，有效值為automatic和manual
priority：可選參數(shù)，policy的優(yōu)先級(jí)
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}' --apply-to all

或者登錄rabbitmq管理頁(yè)面 ——> Admin ——> Policies ——> Add / update a policy

name：策略名稱(chēng)

Pattern：^ 匹配符，只有一個(gè)^代表匹配所有。^message指同步“message”開(kāi)頭的隊(duì)列名稱(chēng)

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

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

簡(jiǎn)單說(shuō)明一下 Operator Policy 和 User Policy 的區(qū)別：

• Operator Policy 是給服務(wù)提供商或公司基礎(chǔ)設(shè)施部門(mén)用來(lái)設(shè)置某些需要強(qiáng)制執(zhí)行的通用規(guī)則
• User Policy 是給業(yè)務(wù)應(yīng)用用來(lái)設(shè)置的規(guī)則

Operator Policy 和 User Policy 會(huì)合并后作用于隊(duì)列，并且為防止 Operator Policy 對(duì)隊(duì)列某些關(guān)鍵屬性例如死信隊(duì)列交換器Dead Letter Exchange的覆蓋導(dǎo)致業(yè)務(wù)應(yīng)用產(chǎn)生非預(yù)期的結(jié)果，Operator Policy 只支持expire、message-ttl、max-length、max-length-bytes4個(gè)參數(shù)。

參考學(xué)習(xí)：

https://www.cnblogs.com/knowledgesea/p/6535766.html

https://blog.csdn.net/belonghuang157405/article/details/83540148

到此這篇關(guān)于Docker搭建RabbitMq的普通集群和鏡像集群的文章就介紹到這了,更多相關(guān)Docker搭建RabbitMq集群內(nèi)容請(qǐng)搜索本站以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持本站！

版權(quán)聲明：本站文章來(lái)源標(biāo)注為YINGSOO的內(nèi)容版權(quán)均為本站所有，歡迎引用、轉(zhuǎn)載，請(qǐng)保持原文完整并注明來(lái)源及原文鏈接。禁止復(fù)制或仿造本網(wǎng)站，禁止在非www.sddonglingsh.com所屬的服務(wù)器上建立鏡像，否則將依法追究法律責(zé)任。本站部分內(nèi)容來(lái)源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來(lái)，僅供學(xué)習(xí)參考，不代表本站立場(chǎng)，如有內(nèi)容涉嫌侵權(quán)，請(qǐng)聯(lián)系alex-e#qq.com處理。