B站全套最詳細(xì)的RocketMQ核心源碼剖析教程(RocketMQ分布式消息中間

P4-RocketMQ_1_快速實戰(zhàn)3
rocketmq的安裝,只依賴jdk
最核心的是broken,實際處理業(yè)務(wù)的組件,包括消息的存儲、轉(zhuǎn)發(fā)都是通過broken進行
NameServer是保存broken的路由信息,包括服務(wù)IP、端口,以及上下線的情況,類似微服務(wù)里的注冊中心。因為broken是集群,服務(wù)可能會有變動,要能實現(xiàn)動態(tài)擴容、服務(wù)宕機要能感知。這就需要NameServer保存和更新這些信息
Producer(生產(chǎn)者)和Comsumer(消費者)都相當(dāng)于客戶端,交互的時候,只需要和NameServer打交道。通過nameserver找到某1個存活broken的,Producer向broken發(fā)送消息,Comsumer接收broken的消息。
先啟動NameServer,再啟動Broken
標(biāo)簽: