1、下載RocketMQ的二進制安裝包
https://rocketmq.apache.org/dowloading/releases/
將安裝包解壓到本地即可,比如:D:\rocketmq
2、添加環境變量
ROCKETMQ_HOME="D:\rocketmq" NAMESRV_ADDR="localhost:9876"
3、啟動命名服務
進入到rocketmq的安裝目錄,運行
.\bin\mqnamesrv.cmd
注意:RocketMQ依賴於java1.8以上版本,然后java的安裝目錄不能有空格(如果裝在Program Files上就完蛋了,重裝吧)
報錯信息:Files前面有一個空格,說明這個路徑不可用
錯誤: 找不到或無法加載主類 Files\Java\jdk1.8.0_91\jre\lib\ext
4、啟動交易者服務
.\bin\mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true
5、發送消息
.\bin\tools.cmd org.apache.rocketmq.example.quickstart.Producer
6、消費消息
.\bin\tools.cmd org.apache.rocketmq.example.quickstart.Consumer