官網下載RocketMQ
下載版本為windows版,以下啟動命令也是win命令。(運行環境說明:jdk1.8必須,maven3.5.4)
下載地址:https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip
下載后在本機解壓,並設置系統變量ROCKETMQ_HOME X盤:\devtool\rocketmq\rocketmq-4.9.x\rocketmq-4.9.x 以自己的為准
並添加到Path %ROCKETMQ_HOME%\bin
啟動RoctetMQ
- 啟動nameserver
打開cmd,切換到RocketMQ的安裝目錄(bin的上一層)
start mqnamesrv.cmd
顯示下圖表示成功
- 啟動broker,新建一個cmd窗口
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable = true
顯示下圖表示已成功
- 啟動可視化console
GitHub下載項目,新版的在dashboard https://github.com/apache/rocketmq-dashboard
下載的是源碼,需要編譯項目。打開cmd,進入下載的rocketmq-dashboard-master目錄下,運行以下代碼編譯項目。
mvn clean package -Dmaven.test.skip=true
編譯成功后,rocketmq-dashboard目錄下會多出一個target目錄,打開它
運行得到的jar
java -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar
啟動成功如下:
打開http://localhost:8080/,就可以看到頁面了
測試RoctetMQ
- 發送消息
用demo測試是否可以發送消息,新建一個cmd窗口,進入rocketmq-4.9.2\bin目錄下
set NAMESRV_ADDR=localhost:9876
tools.cmd org.apache.rocketmq.example.quickstart.Producer
成功發送消息如下:
- 接收消息
同樣新建一個cmd窗口,進入rocketmq-4.9.2\bin目錄下,執行
set NAMESRV_ADDR=localhost:9876
tools.cmd org.apache.rocketmq.example.quickstart.Consumer
成功接收消息如下:
rocket基礎環境搭建到此基本結束
可以在剛才打開的監控網頁看到消息發送情況