RocketMQ(一)啟動及測試


官網下載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

  1. 啟動nameserver
    打開cmd,切換到RocketMQ的安裝目錄(bin的上一層)
  start mqnamesrv.cmd

顯示下圖表示成功

  1. 啟動broker,新建一個cmd窗口
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable = true

顯示下圖表示已成功

  1. 啟動可視化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

  1. 發送消息
    用demo測試是否可以發送消息,新建一個cmd窗口,進入rocketmq-4.9.2\bin目錄下
set NAMESRV_ADDR=localhost:9876
tools.cmd org.apache.rocketmq.example.quickstart.Producer

成功發送消息如下:

  1. 接收消息

同樣新建一個cmd窗口,進入rocketmq-4.9.2\bin目錄下,執行

set NAMESRV_ADDR=localhost:9876
tools.cmd  org.apache.rocketmq.example.quickstart.Consumer

成功接收消息如下:

rocket基礎環境搭建到此基本結束
可以在剛才打開的監控網頁看到消息發送情況


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM