一款由阿里巴巴集團開發(fā),對付雙11削峰填谷的消息中間件。
一個注冊中心,需要比Broker先啟動,具有以下作用:
Broker定時向它打報告,注冊自己
(資料圖片)
生產(chǎn)者會從它這打聽Broker的地址
消費者會從它這打聽Broker的地址
負責消息的存儲與轉(zhuǎn)發(fā)工作
負責生產(chǎn)消息
負責消費消息
1.NameServer啟動
2.Broker啟動,并向NamerServer注冊自己
3.生產(chǎn)者從NameServer打聽Broker的地址,生產(chǎn)者根據(jù)地址向Broker發(fā)送某個主題(Topic)的消息
4.消費者從NameServer打聽Broker的地址,找到Broker,根據(jù)自己感興趣的主題(Topic)那里拿取到消息,進行消費
消息的發(fā)送方式
使用同一個Group Id的消息訂閱者屬于同一個集群,一條消費只會被集群中的一個消費者消費。
RocketMQ會將消息推送給所有的客戶端。
標簽:
熱門