集群消費和廣播消費

2021-07-31 17:27:33 字數 571 閱讀 4395

mq 是基於發布訂閱模型的訊息系統。在 mq 訊息系統中訊息的訂閱方訂閱關注的 topic,以獲取並消費訊息。由於訂閱方應用一般是分布式系統,以集群方式部署有多台機器。因此 mq 約定以下概念。

集群:mq 約定使用相同 consumer id 的訂閱者屬於同乙個集群,同乙個集群下的訂閱者消費邏輯必須完全一致(包括 tag 的使用),這些訂閱者在邏輯上可以認為是乙個消費節點。

集群消費:當使用集群消費模式時,mq 認為任意一條訊息只需要被集群內的任意乙個消費者處理即可。

廣播消費:當使用廣播消費模式時,mq 會將每條訊息推送給集群內所有註冊過的客戶端,保證訊息至少被每台機器消費一次。

集群消費模式:

適用場景&注意事項

廣播消費模式:

適用場景&注意事項

使用集群模式模擬廣播:

適用場景&注意事項

RocketMQ 廣播消費模式與集群消費模式

rocketmq有兩種消費模式 broadcasting廣播模式,clustering集群模式,預設的是 集群消費模式。廣播消費指的是 一條訊息被多個consumer消費,即使這些consumer屬於同乙個consumergroup,訊息也會被consumergroup中的每個consumer都消費...

kafka集群新建topic,消費集群

集群中建立主題 bin kafka topics.sh create zookeeper 192.168.0.130 2181,192.168.0.131 2181,192.168.0.132 2181 replication factor 3 partitions 3 topic topictes...

Rocketmq訊息佇列廣播消費測試

一 機器部署 1 機器組成 7臺機器,均為16g記憶體 每台伺服器均有4個cpu,2核 2 執行環境配置 3 刷盤方式 每台機器master機器均採用非同步刷盤方式 二 效能評測 1 評測目的 測試consumer端的廣播模式消費。2 評測指標 所屬不同consumergroup組的consumer...