1 角色

RocketMQ由四個角色組成：

• Producer 消息生產(chǎn)者

• Consumer 消息消費(fèi)者

• Broker MQ服務(wù)，負(fù)責(zé)接收、分發(fā)消息

• NameServer 負(fù)責(zé)MQ服務(wù)之間的協(xié)調(diào)

2 架構(gòu)設(shè)計

NameServer-MQ服務(wù)注冊發(fā)現(xiàn)中心

提供輕量級服務(wù)發(fā)現(xiàn)和路由。
每個名稱服務(wù)器記錄完整的路由信息，提供相應(yīng)的讀寫服務(wù)，并支持快速存儲擴(kuò)展。

NameServer 充當(dāng)路由信息提供者。生產(chǎn)者/消費(fèi)者客戶查找主題以查找相應(yīng)的broker列表。

3 搭建

配置

• runserver.sh設(shè)置小點
  

• runbroker.sh?設(shè)置小點
  

啟動

nohup?sh?bin/mqnamesrv?>?logs/namesrv.log?2>&1?&nohup sh bin/mqbroker -n localhost:9876 > ~/logs/rocketmqlogs/broker.log 2>&1 &

• 啟動報錯
  

• 查看日志

• 改啟動文件,添加JAVA_HOME變量

• 啟動成功
  
  

啟動broker

nohup sh bin/mqbroker   -c conf/broker.conf   -n localhost:9876 >   logs/broker.log 2>&1 &

3 remoting模塊架構(gòu)

往期推薦