一、安裝JDK
安裝RocketMQ需要先安裝Java環境,可以從官網下載最新版本的JDK安裝包。
// 下載JDK安裝包,選擇適合自己操作系統版本的安裝包
https://www.oracle.com/java/technologies/javase-downloads.html
// 雙擊安裝包進行安裝
二、下載RocketMQ
從Apache官網下載最新的RocketMQ壓縮包,解壓到指定目錄下。
// 下載RocketMQ壓縮包,選擇最新穩定版本進行下載
https://rocketmq.apache.org/dowloading/releases/
// 解壓至指定目錄,例如解壓後的目錄為 E:\rocketmq-all-4.9.0-incubating
三、配置環境變量
為RocketMQ配置環境變量,方便在任何目錄下都能夠使用RocketMQ的相關工具。
// 在系統變量中新增ROCKETMQ_HOME變量,變量值為RocketMQ的安裝路徑
ROCKETMQ_HOME=E:\rocketmq-all-4.9.0-incubating
// 在Path變量中新增%ROCKETMQ_HOME%\bin
Path=%Path%;%ROCKETMQ_HOME%\bin
四、啟動RocketMQ服務
啟動Name Server服務和Broker服務,可以使用RocketMQ提供的啟動腳本文件。
// 啟動Name Server服務
cd %ROCKETMQ_HOME%\bin
start mqnamesrv.cmd
// 啟動Broker服務
cd %ROCKETMQ_HOME%\bin
start mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true
五、驗證安裝是否成功
使用RocketMQ提供的Shell命令行工具進行驗證,確認RocketMQ安裝成功。
// 啟動消費者,接收消息
cd %ROCKETMQ_HOME%\bin
mqconsume.cmd -n localhost:9876 -t TopicTest
// 啟動生產者,發送消息
cd %ROCKETMQ_HOME%\bin
mqsend.cmd -n localhost:9876 -t TopicTest -m "Hello, RocketMQ"
原創文章,作者:小藍,如若轉載,請註明出處:https://www.506064.com/zh-hant/n/251799.html