1. 環境準備
JDK需要先安裝好。
1. RocketMQ是用Java語言寫的,所以需要JDK的支持。
?2. 下載RocketMQ
建議下載這個低版本的
https://rocketmq.apache.org/release-notes/2020/12/21/4.8.0/
?下載之后解壓即可,目錄結構如下:
?3. 配置RocketMQ環境變量
我的電腦,鼠標右鍵 >> 屬性
選擇 高級系統設置:
選擇 環境變量:
選擇 新建:
變量名:ROCKETMQ_HOME
變量值:自己RecketMQ的安裝目錄
最后確定 保存即可。
4. 啟動RecoketMQ
RocketMQ自身分為?NameServer?和?Broker?兩個部分,因此,用作本機開發調試用的最小應用,應該分別啟動一個NameServer和一個Broker節點。
(1)啟動name?server
進入自己的RocketMQ安裝目錄下的bin目錄,輸入下面命令啟動 nameserver:
start mqnamesrv.cmd
?啟動成功會有如下提示,切記下面窗口不能關閉。
?(2)啟動broker
打開 命令提示符 界面,進入自己的RocketMQ安裝目錄下的bin目錄,輸入下面命令啟動 broker:
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
啟動成功會提示如下窗口,切記也不能關閉:
5、驗證RocketMQ功能
RocketMQ自帶了恬送與接收消息的腳本tools.cmd
,用來驗證RocketMQ的功能是否正常。
tool.cmd腳本需要帶參數執行,無法用簡單的雙擊方式啟動。因此,我們打開一個cmd窗口,并跳轉到bin目錄下。
打開cmd窗口并跳轉到bin目錄下
(1)啟動消費者
與mqbroker.cmd
腳本類似,啟動tool.cmd
命令之前我們要指定NameServer地址。
這里我們采用命令方式指定,并啟動消費者。依次執行如下命令:
set NAMESRV_ADDR=localhost:9876
tools.cmd org.apache.rocketmq.example.quickstart.Consumer
啟動消費者成功
(2)啟動生產者
再打開一個cmd窗口,依次執行如下命令:
set NAMESRV_ADDR=localhost:9876
tools.cmd org.apache.rocketmq.example.quickstart.Producer
生產者啟動命令
當生產者啟動之后,會發送1000個消息,然后自動推出,當退出結束時會返回true:
生產者發送消息并退出
此時,在消費者界面按下Ctrl + C
,就會收到剛剛生產者發出的消息。
消費者接收消息
表示RocketMQ功能正常啟動。
RocketMQ最小應用己經可以正常工作,能滿足我們開發環境下調試代碼的需求。
需要RocketMQ可視化部署的,可以點擊下面的鏈接
?RocketMQ可視化插件部署(細節實操版)