一、RocketMQ介紹
RocketMQ 是阿里巴巴開源的分布式消息中間件。支持事務(wù)消息、順序消息、批量消息、定時(shí)消息、消息回溯等。它里面有幾個(gè)區(qū)別于標(biāo)準(zhǔn)消息中件間的概念，如Group、Topic、Queue等。系統(tǒng)組成則由Producer、Consumer、Broker、NameServer等。
二、RocketMQ安裝方式
RocketMQ可以在Linux、Unix、macOS、Windows上安裝，前三者可以參考
RocketMQ官網(wǎng)(https://rocketmq.apache.org/zh/docs/quickStart/01quickstart/)進(jìn)行安裝操作。但在項(xiàng)目開發(fā)過(guò)程中，為了方便開發(fā)，有時(shí)候我們需要在本機(jī)開發(fā)環(huán)境也搭一套R(shí)ocketMQ的運(yùn)行環(huán)境，而我們大部分人用的開發(fā)機(jī)是Window電腦，因此，下面我將介紹在Windows11上怎么安裝運(yùn)行RocketMQ。
三、下載RocketMQ
下載地址：http://rocketmq.apache.org/release_notes
四、配置系統(tǒng)環(huán)境變量
- 變量名：ROCKETMQ_HOME
- 變量值：MQ解壓路徑，本人的安裝路徑是（D:\service\rocketmq-all-5.1.0-bin-release），注意，安裝目錄不能有空格，否則mqnamesrv服務(wù)將啟動(dòng)失敗。
注意：配置完環(huán)境變量后不需要重啟電腦就能生效了，如果啟動(dòng)服務(wù)的時(shí)候報(bào)錯(cuò)提示需要配置ROCKETMQ_HOME環(huán)境變量，大概率是你的目錄地址配置錯(cuò)了，特別要注意zip解壓縮工具解壓時(shí)默認(rèn)會(huì)多解壓一層目錄。
五、修改MQ配文件
進(jìn)入到RocketMQ解壓的bin目錄下，修改runbroker.cmd和runserver.cmd文件。把%CLASSPATH%用引號(hào)引起來(lái)"%CLASSPATH%",否則啟動(dòng)會(huì)報(bào)錯(cuò)。如果發(fā)現(xiàn)該文件已經(jīng)添加了引號(hào)，則跳過(guò)該配置階段。
報(bào)錯(cuò)信息如下：
六、啟動(dòng)服務(wù)
6.1 進(jìn)入RocketMQ的bin目錄
先打開cmd命令窗口，cd進(jìn)入到RocketMQ解壓的bin目錄下，再執(zhí)行啟動(dòng)命令。在Windows11下這里有一個(gè)坑，你會(huì)發(fā)現(xiàn)無(wú)論你怎么cd好像都沒(méi)辦法進(jìn)入到你想要的目錄下，cd命令無(wú)效。以下我將提供兩種cd到目錄的方式：
- 方式1：分兩步走，先輸入磁盤符，如D:，再cd 目錄，如下：
D:
cd temp\ac
- 方式2：一步到位，在cd后加/d，如：
cd /d D:\temp\ac
6.2 啟動(dòng)服務(wù)
首先啟動(dòng)mqnamesrv.cmd,再啟動(dòng)mqbroker.cmd
啟動(dòng)mqnamesrv.cmd命令：
start mqnamesrv.cmd，啟動(dòng)mqbroker.cmd命令：
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
七、驗(yàn)證是否安裝成功
RocketMQ自帶了發(fā)送與接收消息的腳本tools.cmd，用來(lái)驗(yàn)證RocketMQ的功能是否正常。
7.1 第一步
打開一個(gè)cmd窗口，跳轉(zhuǎn)到bin目錄下，啟動(dòng)消費(fèi)者。
set NAMESRV_ADDR=localhost:9876
tools.cmd org.apache.rocketmq.example.quickstart.Consumer
7.2 第二步
再打開一個(gè)cmd窗口，跳轉(zhuǎn)到bin目錄下，啟動(dòng)生產(chǎn)者。
set NAMESRV_ADDR=localhost:9876
tools.cmd org.apache.rocketmq.example.quickstart.Producer
消費(fèi)者中能收到消息說(shuō)明程序正常。
八、使用RocketMQ Dashboard管理RocketMQ
8.1 下載RocketMQ Dashboard
下載管理臺(tái)插件：https://github.com/apache/rocketmq-dashboard，將rocketmq-dashboard插件克隆到本地磁盤，或者打開地址下載zip壓縮包。
8.2 啟動(dòng)RocketMQ Dashboard
8.2.1 使用maven編譯并啟動(dòng)RocketMQ Dashboard插件
第一步：編譯項(xiàng)目
直接在解壓的文件的根目錄，輸入mvn clean package -Dmaven.test.skip=true
第二步：?jiǎn)?dòng)jar包
啟動(dòng) 打包成功后會(huì)生成target目錄，進(jìn)入target目錄cmd，啟動(dòng)工程：java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar
8.2.2 使用IDEA導(dǎo)入項(xiàng)目，直接啟動(dòng)
如果手動(dòng)maven編譯項(xiàng)目再啟動(dòng)jar包比較麻煩，在本地開發(fā)環(huán)境可以直接將項(xiàng)目導(dǎo)入IDEA中進(jìn)行啟動(dòng)，RocketMQ Dashboard就是用Java開發(fā)的一個(gè)常規(guī)項(xiàng)目而已。
8.3 測(cè)試RocketMQ Dashboard
啟動(dòng)成功后，在瀏覽器里輸入插件地址127.0.0.1:8080 打開RocketMQ控制臺(tái)，能打開控制臺(tái)頁(yè)面表示插件啟動(dòng)成功。
