RocketMQ的消費模式有2種

 1 public enum MessageModel {
 2     BROADCASTING("BROADCASTING"),
 3     CLUSTERING("CLUSTERING");
 4 
 5     private String modeCN;
 6 
 7     private MessageModel(String modeCN) {
 8         this.modeCN = modeCN;
 9     }
10 
11     public String getModeCN() {
12         return this.modeCN;
13     }
14 }

查看一下源碼，在默認(rèn)情況下，就是集群消費（CLUSTERING）。另一種消費模式，是廣播消費（BROADCASTING）。

其實，對于RocketMQ而言，通過ConsumeGroup的機(jī)制，實現(xiàn)了天然的消息負(fù)載均衡！通俗點來說，RocketMQ中的消息通過ConsumeGroup實現(xiàn)了將消息分發(fā)到C1/C2/C3/……的機(jī)制，這意味著我們將非常方便的通過加機(jī)器來實現(xiàn)水平擴(kuò)展！

至于消息分發(fā)到C1/C2/C3，其實也是可以設(shè)置策略的：

默認(rèn)的分配算法是AllocateMessageQueueAveragely

還有另外一種平均的算法是AllocateMessageQueueAveragelyByCircle，也是平均分?jǐn)偯恳粭lqueue，只是以環(huán)狀輪流分queue的形式，如下圖：

廣播消費，類似于ActiveMQ中的發(fā)布訂閱模式，消息會發(fā)給Consume Group中的每一個消費者進(jìn)行消費。由于廣播模式下要求一條消息需要投遞到一個消費組下面所有的消費者實例，所以也就沒有消息被分?jǐn)傁M的說法。

RocketMQ-廣播消費模式設(shè)置：

總結(jié)

以上是生活随笔為你收集整理的RocketMQ消费模式的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。