設為“

星標

”，好文章不錯過！

1 角色

RocketMQ由四個角色組成：

Producer 訊息生產者

Consumer 訊息消費者

Broker MQ服務，負責接收、分發訊息

NameServer 負責MQ服務之間的協調

2 架構設計

NameServer-MQ服務註冊發現中心

提供輕量級服務發現和路由。

每個名稱伺服器記錄完整的路由資訊，提供相應的讀寫服務，並支援快速儲存擴充套件。

NameServer 充當路由資訊提供者。生產者/消費者客戶查詢主題以查詢相應的broker列表。

3 搭建

配置

runserver。sh設定小點

runbroker。sh 設定小點

啟動

nohup sh bin/mqnamesrv > logs/namesrv。log2>&1 &nohup sh bin/mqbroker -n localhost：9876 > ~/logs/rocketmqlogs/broker。log2>&1 &

啟動報錯

檢視日誌

改啟動檔案，新增JAVA_HOME變數

啟動成功

啟動broker

nohup sh bin/mqbroker -c conf/broker。conf -n localhost：9876 > logs/broker。log2>&1 &

3 remoting模組架構