rocketmq有兩種消費模式：broadcasting廣播模式，clustering集群模式，預設的是 集群消費模式。
廣播消費指的是：一條訊息被多個consumer消費，即使這些consumer屬於同乙個consumergroup,訊息也會被consumergroup中的每個consumer都消費一次，廣播消費中consumergroup概念可以認為在訊息劃分方面無意義。
集群消費模式：乙個consumergroup中的consumer例項平均分攤消費訊息。例如某個topic有9條訊息，其中乙個consumergroup有3個例項（可能是3個程序，或者3臺機器），那麼每個例項只消費其中部分，消費完的訊息不能被其他例項消費。
例如：某個topic有9條訊息，有3個消費者，廣播模式就是每個消費者都收到9條訊息，集群模式就是消費者平均分攤9條訊息
**核心地方
consumer.setmessagemodel(messagemodel.broadcasting);//設定廣播消費模式
就是在消費者這裡設定一下，其餘的**不變
Rocketmq訊息佇列廣播消費測試
一 機器部署 1 機器組成 7臺機器，均為16g記憶體 每台伺服器均有4個cpu，2核 2 執行環境配置 3 刷盤方式 每台機器master機器均採用非同步刷盤方式 二 效能評測 1 評測目的 測試consumer端的廣播模式消費。2 評測指標 所屬不同consumergroup組的consumer...
細談RocketMQ的消費模式
目錄 集群消費 廣播消費 使用集群消費模擬廣播消費 首先明確一點，rocketmq 是基於發布訂閱模型的訊息中介軟體。所謂的發布訂閱就是說，consumer 訂閱了 broker 上的某個 topic，當 producer 發布訊息到 broker 上的該 topic 時，consumer 就能收到...
rocketmq 順序消費
org.apache.rocketmq rocketmq spring boot starter 2.0.3 有序訊息需要生產者，消費者一起配合，生產者要保證每次訊息都要投遞到broker的同乙個佇列裡，消費者需要設定 關鍵點 生產這傳送 同步訊息且指定佇列 syncsendorderly 消費者指...