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