摘要:設(shè)置方法例如我們將滿足規(guī)則的隊(duì)列設(shè)置為鏡像隊(duì)列之后申請(qǐng)的所有滿足規(guī)則的隊(duì)列都是鏡像隊(duì)列通過(guò)測(cè)試表明,使用的正則規(guī)則,可以設(shè)置鏡像隊(duì)列。如果沒(méi)有設(shè)置,在申明隊(duì)列的時(shí)候方法使用這個(gè)參數(shù)設(shè)置的鏡像隊(duì)列是無(wú)效的。所以隊(duì)列同步需謹(jǐn)慎
設(shè)置policy方法
例如我們將滿足規(guī)則“*_mirrored_queue”的隊(duì)列設(shè)置為鏡像隊(duì)列
./rabbitmqctl set_policy -p wenda-action mirrored_queue_policy_all ".*_mirrored_queue" "{"ha-mode":"all"}"
之后申請(qǐng)的所有滿足“*_mirrored_queue”規(guī)則的隊(duì)列都是鏡像隊(duì)列
tips:通過(guò)測(cè)試表明,使用policy的正則規(guī)則,可以設(shè)置鏡像隊(duì)列。如果沒(méi)有設(shè)置policy,在申明隊(duì)列的時(shí)候(queue_declare方法)使用x-ha-policy這個(gè)參數(shù)設(shè)置的鏡像隊(duì)列是無(wú)效的。設(shè)置了policy正則規(guī)則,不使用x-ha-policy參數(shù),只要滿足正則規(guī)則的queue也會(huì)自動(dòng)變成鏡像隊(duì)列,(許多博客上是說(shuō)明了用隊(duì)列的x-ha-policy參數(shù)來(lái)設(shè)置鏡像隊(duì)列,卻沒(méi)有指明需要提前創(chuàng)建好policy規(guī)則)。
rabbitmq文檔說(shuō)明:
鏡像隊(duì)列的同步機(jī)制當(dāng)一個(gè)隊(duì)列申明為鏡像隊(duì)列之后,并且ha-mode:all,集群中所有的節(jié)點(diǎn)都會(huì)有該隊(duì)列的鏡像,當(dāng)隊(duì)列已經(jīng)有一些數(shù)據(jù)之后,往集群中加入一個(gè)新節(jié)點(diǎn),新節(jié)點(diǎn)加入集群之后會(huì)自動(dòng)創(chuàng)建該隊(duì)列的鏡像,但是隊(duì)列之前是有數(shù)據(jù)的,這些數(shù)據(jù)是立馬同步到新節(jié)點(diǎn)還是手動(dòng)同步,這時(shí)候需要鏡像隊(duì)列的同步機(jī)制
queue_declare()方法中arg參數(shù)中有該配置:
ha-sync-mode manual 手動(dòng)同步 | automatic 自動(dòng)同步
tips:一個(gè)隊(duì)列正在同步的時(shí)候,改隊(duì)列的所有操作都會(huì)阻塞,因?yàn)楦鞣N原因可能會(huì)阻塞幾分鐘、幾小時(shí)甚至幾天。(所以隊(duì)列同步需謹(jǐn)慎)
文章版權(quán)歸作者所有,未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址:http://m.hztianpu.com/yun/30190.html
摘要:官方鏡像倉(cāng)庫(kù)地址本地運(yùn)行訪問(wèn)可視化面板地址默認(rèn)賬號(hào)默認(rèn)密碼集成基本參數(shù)配置配置配置定義優(yōu)先級(jí)隊(duì)列定義交換器定義參考官方文檔應(yīng)用啟動(dòng)后,會(huì)自動(dòng)創(chuàng)建和,并相互綁定,優(yōu)先級(jí)隊(duì)列會(huì)有如圖所示標(biāo)識(shí)。 showImg(https://upload-images.jianshu.io/upload_images/3424642-6085f3f9e43c7a4c.png?imageMogr2/auto...
摘要:消息隊(duì)列帶來(lái)的問(wèn)題系統(tǒng)可用性降低系統(tǒng)引入的外部依賴越多,系統(tǒng)越容易出問(wèn)題。系統(tǒng)復(fù)雜性提高加入消息隊(duì)列后,需要保證消息沒(méi)有被重復(fù)消費(fèi),保證消息傳遞的順序性等等。 消息隊(duì)列相關(guān)筆記 消息隊(duì)列的應(yīng)用場(chǎng)景: 消費(fèi)者執(zhí)行過(guò)程比較長(zhǎng)且生產(chǎn)者不需要消費(fèi)者返回結(jié)果。用于更新索引庫(kù),生成商品詳情頁(yè),發(fā)短信。 為什么要使用消息隊(duì)列: 通過(guò)異步處理提高系統(tǒng)性能(削峰、減少響應(yīng)所需時(shí)間); 降低系統(tǒng)耦合性。...
摘要:一關(guān)鍵字和之間的連接關(guān)系實(shí)際存儲(chǔ)消息。生產(chǎn)者進(jìn)行接受應(yīng)答,用來(lái)確定這條消息是否正常的發(fā)送到了,這種方式也是消息的可靠性投遞的核心保障。支持消息的過(guò)期時(shí)間,在消息發(fā)送時(shí)可以進(jìn)行指定??梢员O(jiān)聽這個(gè)隊(duì)列中消息做相應(yīng)的處理。 一、rabbitmq關(guān)鍵字 Binding:Exchange和Exchange、Queue之間的連接關(guān)系Queue:實(shí)際存儲(chǔ)消息。Durability:是否持久化,Du...
摘要:可以在地址看到如何使用講解下上面命令行表示控制臺(tái)端口號(hào),可以在瀏覽器中通過(guò)控制臺(tái)來(lái)執(zhí)行的相關(guān)操作。同時(shí)從控制臺(tái)可以看到發(fā)送的速率多線程測(cè)試性能開了個(gè)線程,每個(gè)線程發(fā)送條消息。 showImg(http://ww2.sinaimg.cn/large/006tNc79ly1g5jjb62t88j30u00gwdi2.jpg); 前提 上次寫了篇文章,《SpringBoot Kafka 整合...
閱讀 2215·2021-11-05 09:42
閱讀 2938·2021-09-23 11:21
閱讀 2921·2019-08-30 14:00
閱讀 3376·2019-08-30 13:15
閱讀 547·2019-08-29 17:18
閱讀 3619·2019-08-29 16:29
閱讀 2847·2019-08-29 14:06
閱讀 2864·2019-08-23 14:41