RabbitMQ雙活方案

IT那活兒發(fā)布于2023-01-11 13:20 / 715人閱讀

RabbitMQ雙活方案

點(diǎn)擊上方“IT那活兒”，關(guān)注后了解更多內(nèi)容，不管IT什么活兒，干就完了?。。?/span>

適用場(chǎng)景

RabbitMQ本身的優(yōu)點(diǎn)眾多，大家最看好的便是它的異步化提高系統(tǒng)抗峰值能力，然后便是系統(tǒng)及功能結(jié)構(gòu)解耦，那么照此兩點(diǎn)來說，它在整個(gè)系統(tǒng)中的作用是至關(guān)重要的。

那么如此重要，當(dāng)然要考慮他的高可用性；混合云、多可用區(qū)、多機(jī)房的部署架構(gòu)是大家普遍追尋的方案，但是怎么避免網(wǎng)絡(luò)因素帶來的影響呢？

RabbitMQ有很多種高可用方案，本文我們重點(diǎn)講述federation插件方式，此方案一般適用于大型的分布式集群，可以避免因網(wǎng)絡(luò)問題帶來的消息差異、腦裂等情況。

Federation插件使RabbitMQ在不同Broker節(jié)點(diǎn)間進(jìn)行消息傳遞而無須建立集群，在不同管理域(不同的用戶和vhost、不同版本的RabbitMQ Erlang上)中的Broker或集群間傳遞消息，能容忍不穩(wěn)定的網(wǎng)絡(luò)連接情況。

前期準(zhǔn)備

兩臺(tái)安裝rabbitmq的機(jī)器 ,進(jìn)行federation插件測(cè)試。

配置federation插件

1. 開啟federation插件

rabbitmq-plugins enable rabbitmq_federation

rabbitmq-plugins enable rabbitmq_federation_management

2. 登入控制臺(tái)配置策路

federation中的參數(shù)信息：

name: 新增的federation聯(lián)合插件的上游名稱，這個(gè)可以隨便取名。
uri：上游federation聯(lián)合rabbitmq的地址，上游是指訂閱的服務(wù)器節(jié)點(diǎn)。
prefect count：一次性從上游rabbitmq服務(wù)器預(yù)期數(shù)據(jù)的最大數(shù)量，默認(rèn)是1000。
reconnect delay：網(wǎng)絡(luò)連接失敗后下次重連的等待時(shí)間，默認(rèn)是5秒。
Acknowledgement Mode：消息確認(rèn)方式，on-confirm、on-publish和no-ack。含義分布如下：

① on-confirm，默認(rèn)的確認(rèn)方式，它需要下游消費(fèi)者進(jìn)行消息確認(rèn)后才刪除，是最可靠的消息處理方式。不管是網(wǎng)絡(luò)錯(cuò)誤還是消息節(jié)點(diǎn)失敗都不會(huì)丟失消息。這種方式處理最慢。

② on-publish，上游節(jié)點(diǎn)將消息發(fā)送給下游節(jié)點(diǎn)后消息就進(jìn)行確認(rèn)了，這種情況在網(wǎng)絡(luò)錯(cuò)誤時(shí)可以進(jìn)行重發(fā)，但是在消息節(jié)點(diǎn)失敗時(shí)會(huì)丟失消息。

③ no-ack，不需要確認(rèn)就可以進(jìn)行消息刪除。這種方式最不安全對(duì)于消息來說，但是卻是最快的。

Trust User-ID：是否信任從上游服務(wù)器傳來的用戶id，默認(rèn)是yes，設(shè)置成no，將會(huì)清空從上游服務(wù)器傳來的user id信息。

接下來是專門提供給federation exchange交換器的參數(shù)：

Exchange：定義上游服務(wù)器的聯(lián)合的exchange名稱，默認(rèn)情況下的取名與聯(lián)合的exchange名稱相同。
max hops：消息在被放棄或者說被消費(fèi)前消息可以傳遞的最大的聯(lián)合federation 連接長度，默認(rèn)是1，一般情況連接長度等于聯(lián)合的節(jié)點(diǎn)數(shù)量-1。
Expires：上游服務(wù)器節(jié)點(diǎn)保持節(jié)點(diǎn)信息的最長時(shí)間，單位毫秒，默認(rèn)的是永久保存。
Message TTL：在上游節(jié)點(diǎn)中消息未被傳遞時(shí)可以保存的時(shí)長，單位毫秒，默認(rèn)是永久保存。
HA Policy：檢查一個(gè)聯(lián)合exchange的上游queue中的x-ha-policy，用于確認(rèn)該queue是否是一個(gè)HA的queue，默認(rèn)是none表示不是一個(gè)HA的queue。

最后是federation queue的參數(shù)：

Queue：定義上游服務(wù)器的聯(lián)合的queue名稱，默認(rèn)情況下的取名與聯(lián)合的queue名稱相同。

3. 定義聯(lián)合查詢federation

4. 定義同步策略policy

name標(biāo)識(shí)名稱。
pattern表示匹配的表達(dá)式，用法是正則表達(dá)式。
apply to表示應(yīng)用在exchange還是queue上面，亦或兩者都使用。
priority表示優(yōu)先級(jí)，值越大，優(yōu)先級(jí)越高。
definition用于定義使用的配置，這里我們定義的是federation聯(lián)合，它有federation upstream set和 federation upstream兩種方式，set表示集合，定義需要該策略的所有上游名稱，一般我們都取值為all。

5. 狀態(tài)查詢

完成定義策略后，那么就會(huì)看到同步策略中開起的exchange、queue狀態(tài)。

通過界面已經(jīng)看到了federation聯(lián)合查詢對(duì)應(yīng)的exchange和queue已經(jīng)處于運(yùn)行狀態(tài)了，這個(gè)時(shí)候我們可以看到另一臺(tái)控制臺(tái)上的connection頁簽。

這個(gè)時(shí)候在rabbitmq服務(wù)器上面已經(jīng)有了federation標(biāo)志的連接，也就是我們剛才在前面定義的federation，在連接上面可以看到federation的名稱及policy，說明已經(jīng)同步到了另一臺(tái)機(jī)器上面，同時(shí)我們也可以在exchange頁簽及queue頁簽中看到在另一臺(tái)機(jī)器上面定義的federation聯(lián)合exchange和queue名稱。