目錄
一、項目搭建和測試
1.1 代碼拉取
1.2 源碼結構目錄
1.3 下載下傳 Maven 依賴
1.4 調試
1.4.1 建立conf檔案夾
1.4.2 NameSrv 啟動
1.4.3 BrokerSrv 啟動
1.4.4 快速測試
一、項目搭建和測試
1.1 代碼拉取
從官方倉庫拉取： https://github.com/apache/rocketmq
百度網盤：連結：https://pan.baidu.com/s/11gDiQ41LFRdpl03q_l8_xw 提取碼：pjd8
1.2 源碼結構目錄
| 目錄名稱 | 作用 |
| broker | broker 子產品（broke 啟動程序） |
| client | 消息用戶端，包含消息生産者、消息消費者相關類 |
| common | 公共包 |
| dev | 開發者資訊（非源代碼） |
| distribution | 部署執行個體檔案夾（非源代碼） |
| example | RocketMQ 例代碼 |
| filter | 消息過濾相關基礎類 |
| filtersrv | 消息過濾伺服器實作相關類（Filter啟動程序） |
| logappender | 日志實作相關類 |
| namesrv | NameServer實作相關類（NameServer啟動程序） |
| openmessageing | 消息開放标準 |
| remoting | 遠端通信子產品，給予Netty |
| srcutil | 服務工具類 |
| store | 消息存儲實作相關類 |
| style | checkstyle相關實作 |
| test | 測試相關類 |
| tools | 工具類，監控指令相關實作類 |
1.3 下載下傳 Maven 依賴
# 填入指令，并回車
mvn clean install -Dmaven.test.skip=true
1.4 調試
1.4.1 建立conf檔案夾
1.4.2 NameSrv 啟動
此時提示：
即需要為 RocketMQ 配置環境變量
1.4.3 BrokerSrv 啟動
建立 data 檔案夾，位置自定義，用于存儲 broker 資料
修改 config 檔案夾下的 broker.conf 檔案
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
# namesrvAddr位址
namesrvAddr=127.0.0.1:9876
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
autoCreateTopicEnable=true
#### 配置為上面設定的檔案夾路徑
# 存儲路徑
storePathRootDir=E:\\project\\rocketmq\\rocketmq-master\\data\\dataDir
# commitLog路徑
storePathCommitLog=E:\\project\\rocketmq\\rocketmq-master\\data\\dataDir\\commitlog
# 消息隊列存儲路徑
storePathConsumeQueue=E:\\project\\rocketmq\\rocketmq-master\\data\\dataDir\\consumequeue
# 消息索引存儲路徑
storePathIndex=E:\\project\\rocketmq\\rocketmq-master\\data\\dataDir\\index
# checkpoint檔案路徑
storeCheckpoint=E:\\project\\rocketmq\\rocketmq-master\\data\\dataDir\\checkpoint
# abort檔案存儲路徑
abortFile=E:\\project\\rocketmq\\rocketmq-master\\data\\dataDir\\abort
找到 broker 項目，啟動項目
發現又要配置環境變量，配置方式與 1.4.2 相同
設定引用的配置檔案：
-c E:\project\rocketmq\rocketmq-master\conf\broker.conf
啟動項目
1.4.4 快速測試
找到 example 項目下的 quickstart
修改啟動檔案，配置 namesrv 服務位址
先啟動 Producer
再啟動 Consumer 消費