RabbitMQ-鏡像隊(duì)列配置相關(guān)

Kyxy 發(fā)布于2019-07-01 11:24 / 1441人閱讀

摘要：設(shè)置方法例如我們將滿足規(guī)則的隊(duì)列設(shè)置為鏡像隊(duì)列之后申請的所有滿足規(guī)則的隊(duì)列都是鏡像隊(duì)列通過測試表明，使用的正則規(guī)則，可以設(shè)置鏡像隊(duì)列。如果沒有設(shè)置，在申明隊(duì)列的時候方法使用這個參數(shù)設(shè)置的鏡像隊(duì)列是無效的。所以隊(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"}"
之后申請的所有滿足“*_mirrored_queue”規(guī)則的隊(duì)列都是鏡像隊(duì)列

tips:通過測試表明，使用policy的正則規(guī)則，可以設(shè)置鏡像隊(duì)列。如果沒有設(shè)置policy，在申明隊(duì)列的時候（queue_declare方法）使用x-ha-policy這個參數(shù)設(shè)置的鏡像隊(duì)列是無效的。設(shè)置了policy正則規(guī)則，不使用x-ha-policy參數(shù)，只要滿足正則規(guī)則的queue也會自動變成鏡像隊(duì)列，（許多博客上是說明了用隊(duì)列的x-ha-policy參數(shù)來設(shè)置鏡像隊(duì)列，卻沒有指明需要提前創(chuàng)建好policy規(guī)則）。

rabbitmq文檔說明：

鏡像隊(duì)列的同步機(jī)制

當(dāng)一個隊(duì)列申明為鏡像隊(duì)列之后，并且ha-mode:all,集群中所有的節(jié)點(diǎn)都會有該隊(duì)列的鏡像，當(dāng)隊(duì)列已經(jīng)有一些數(shù)據(jù)之后，往集群中加入一個新節(jié)點(diǎn)，新節(jié)點(diǎn)加入集群之后會自動創(chuàng)建該隊(duì)列的鏡像，但是隊(duì)列之前是有數(shù)據(jù)的，這些數(shù)據(jù)是立馬同步到新節(jié)點(diǎn)還是手動同步，這時候需要鏡像隊(duì)列的同步機(jī)制
queue_declare()方法中arg參數(shù)中有該配置：
ha-sync-mode manual 手動同步 | automatic 自動同步

tips:一個隊(duì)列正在同步的時候，改隊(duì)列的所有操作都會阻塞，因?yàn)楦鞣N原因可能會阻塞幾分鐘、幾小時甚至幾天。（所以隊(duì)列同步需謹(jǐn)慎）