快捷導(dǎo)航

Java?Rabbitmq中四種集群架構(gòu)的區(qū)別詳解

更新時(shí)間：2022年02月28日 16:08:22 作者：偉子涵

這篇文章主要為大家詳細(xì)介紹了Java?Rabbitmq中四種集群架構(gòu)的區(qū)別，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來(lái)幫助

主備模式

主備模式: warren 兔子窩一個(gè)主、一個(gè)備方案主節(jié)點(diǎn)如果掛了從節(jié)點(diǎn)提供服務(wù) 和Activemq 利用zk 做主/備一樣

請(qǐng)?zhí)砑訄D片描述

主備模式 -----------------------》HaProxy 配置

listen rabbitmq_cluster 
bind 0.0.0.0:5682 # 配置tcp 模式
mode tcp # 簡(jiǎn)單的輪詢
balance roundrobin #主節(jié)點(diǎn) 
server bhz76 192.168.11.78:5672 check inter 5000 rise 2 fall 2 
server bhz76 192.168.11.79:5672 backup check inter 5000 rise 2 fall 2   #備用節(jié)點(diǎn)

遠(yuǎn)程模式

遠(yuǎn)程模式遠(yuǎn)距離通信和復(fù)制可以實(shí)現(xiàn)雙活的一種模式，簡(jiǎn)稱 Shovel 模式配置麻煩現(xiàn)在使用不多

所謂Shovel 就是我們可以把消息進(jìn)行不同數(shù)據(jù)中心的復(fù)制工作，可以跨地域的讓兩個(gè)mq 集群互聯(lián)

請(qǐng)?zhí)砑訄D片描述

1.0 Step1 啟動(dòng)RabbitMq 插件  
?     rabbitmq-plugins enable amqp_client 
?     rabbitmq-plugins enable rabbitmq_shovel
2. 0 創(chuàng)建rabbitmq.config 文件
   touch /etc/rabbitmq/rabbitmq.config

請(qǐng)?zhí)砑訄D片描述

鏡像模式

集群模式非常經(jīng)典的就是Mirror 鏡像模式保證100%數(shù)據(jù)不丟失

在實(shí)際工作中用的最多并且實(shí)現(xiàn)集群非常的簡(jiǎn)單一般互聯(lián)網(wǎng)大廠都會(huì)使用這樣構(gòu)建這種鏡像集群模式

Mirror 鏡像隊(duì)列

高可靠 ----------》數(shù)據(jù)同步 —》elang 交換機(jī) ----》3節(jié)點(diǎn)

請(qǐng)?zhí)砑訄D片描述

缺點(diǎn) ：沒(méi)有保證橫向擴(kuò)容

多活模式

這種模式也是實(shí)現(xiàn)異地?cái)?shù)據(jù)復(fù)制的主流模式因?yàn)镾hovel 模式配置比較復(fù)雜所以一般來(lái)說(shuō)實(shí)現(xiàn)異地集群都是使用這種雙活或者多活模型來(lái)實(shí)現(xiàn)的

這種模型需要依賴RabbitMq 的federation 插件可以實(shí)現(xiàn)持續(xù)的可靠的Amqp 的數(shù)據(jù)通信多活模式實(shí)際配置與應(yīng)用非常簡(jiǎn)單

RabbitMq 部署架構(gòu)采用雙中心模式多中心那么在兩套或多套數(shù)據(jù)中心中客部署一套 RabbitMq 集群客中心的RabbitMq 服務(wù)除了需要為業(yè)務(wù)提供正常的消息服務(wù)外中心之間還需要實(shí)現(xiàn)部分隊(duì)列消息共享

請(qǐng)?zhí)砑訄D片描述

Federation 插件

Federation 插件是一個(gè)不需要構(gòu)建Cluster 而在Brokers 之間傳輸消息的高性能插件 Federation 插件可以在Brokers 或者Cluster 之間傳輸消息連接的雙方可以使用不同的users 和virtual hosts 雙方也可以使用版本不同的 RabbitMq 和Erlang Federation 插件使用AMQP 協(xié)議通訊可以接收不連接的傳輸

Federation Exchanges 可以看成Downstream 從Upstream 主動(dòng)拉取消息但并不是拉取所有消息必須是在Downstream 上已經(jīng)明確定義Bindings 關(guān)系的 Exchange 也就是有實(shí)際的物理 Queue 來(lái)接收消息才會(huì)從Upstream 拉取消息組合在一起，綁定/解除綁定命令將發(fā)送到Upstream 交換機(jī) 因此 Federation Exchanges 只接收具有訂閱的消息

請(qǐng)?zhí)砑訄D片描述