1、從git倉庫克隆源碼:https://gitee.com/apache/rocketmq.git
2、通過控制台的方式啟動rocketmq:
2.1、cmd 進入到rocketmq 檔案夾,通過mvn打包:
mvn -Prelease-all -DskipTests clean install -U
2.2、配置ROCKET_HOME時需要配置的位址不是你下載下傳下來的源碼的位置,而是編譯後的位置: ~\rocketmq\distribution\target\rocketmq-4.8.0\rocketmq-4.8.0
2.3、進入 cd distribution/target/apache-rocketmq
啟動nameserver:
start mqnamesrv.cmd
啟動broker:
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
3、通過IDEA打開源碼,調用main函數的方式啟動:
3.1、啟動nameserver
3.2、加入broker啟動程式的參數:
-c D:\code\java_yuanma\rocketmq\distribution\conf\broker.conf
3.3、在broker.conf加入以下參數:
autoCreateTopicEnable = true
namesrvAddr = 127.0.0.1:9876
3.4、啟動broker
4、下載下傳可視化管理工具
https://gitee.com/mirrors/RocketMQ-Externals.git
3.1、設定application.properties 中的nameserver位址:
rocketmq.config.namesrvAddr=localhost:9876
3.2、啟動裡面的 rocket-console 項目
5、rocketmq的發送和消費,可參考rocketmq中的example工程,裡面包含各種消息類型的發送和消費