前言
項目中用到了延遲消息隊列，記錄下一win10下rocketmq的安裝
環境
win10 + rocketmq4.7.0
具體操作
下載
環境變量配置
- 配置環境變量
ROCKETMQ_HOME，值為rocketmq壓縮包解壓路徑，路徑中不能包含空格
- 否則會出現如下錯誤：
錯誤: 找不到或無法加載主類 Files\rocketmq\bin\Files\rocketmq\lib
- 注：
rocketmq還需配置jdk環境變量 ->JAVA_HOME
啟動
- Start Name Server，
cmd窗口rocketmq/bin目錄下執行
start mqnamesrv
- Start Broker，新
cmd窗口rocketmq/bin目錄下執行
start mqbroker -n localhost:9876 autoCreateTopicEnable=true
關閉
- 可以手動關閉
cmd終端，也可以使用mqshutdown腳本 - 關閉
broker
mqshutdown broker
- 關閉
namesrv
mqshutdown namesrv
生產、消費實例
- 設置
NAMESRV_ADDR:
set namesrv_addr=localhost:9876
- 生產者 Send Messages，
rocketmq/bin目錄下執行：
tools org.apache.rocketmq.example.quickstart.Producer
- 消費者 Receive Messages，
rocketmq/bin目錄下執行：
RocketMQ Console
RocketMQ Console是RocketMQ提供的可視化管理工具，方便可視化的操作，下載地址：https://github.com/apache/rocketmq-externals/tree/release-rocketmq-console-1.0.0- 修改配置文件
rocketmq-console\src\main\resources\application.properties如下：
rocketmq-console主目錄下運行打包命令：
mvn clean package -Dmaven.test.skip=true
- 打包后如下所示：
rocketmq-console\target目錄下運行啟動命令：
java -jar rocketmq-console-ng-1.0.0.jar
- 啟動成功后訪問
http://localhost:8088
