RocketMQ搭建

RocketMQ也已經加入了apache的開源項目，今天說說ｗｉｎｄｏｗｓ下的搭建

1 下載安裝包

• 方式１（本身編譯）

下載：https://www.apache.org/dyn/cl...

• 方式２，編譯好的

下載：https://www.apache.org/dyn/cl...

2.使用ｍａｖｅｎ編譯(方式一須要這一步)

> unzip rocketmq-all-4.4.0-source-release.zip
  > cd rocketmq-all-4.4.0/
  > mvn -Prelease-all -DskipTests clean install -U
  > cd distribution/target/apache-rocketmq

3.先啓動Name Server

> nohup sh bin/mqnamesrv &
  > tail -f ~/logs/rocketmqlogs/namesrv.log
  The Name Server boot success...

ｗｉｎｄｏｗｓ平臺：
配置環境變量：ROCKETMQ_HOME：解壓後的ｍｑ目錄路徑，注意是ｂｉｎ目錄所在的那層目錄

start mqnamesrv.cmd

4.啓動Broker

> nohup sh bin/mqbroker -n localhost:9876 &
  > tail -f ~/logs/rocketmqlogs/broker.log 
  The broker[%s, 172.30.30.233:10911] boot success...

windows平臺：

start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

5.關閉服務

> sh bin/mqshutdown broker
The mqbroker(36695) is running...
Send shutdown request to mqbroker(36695) OK

> sh bin/mqshutdown namesrv
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK

6.可視化管理控制檯rocketmq-console-ng

• 下載源碼　https://github.com/apache/inc...
• 進入rocketmq-console目錄，打包

mvn package

• 運行，須要ｊｄｋ１．８

進入ｔａｒｇｅｔ目錄

java -jar rocketmq-console-ng-1.0.0.jar --server.port=12581 --rocketmq.config.namesrvAddr=127.0.0.1:9876

若是不想配置這麼多參數，你能夠直接在rocketmq-console-ng目錄裏的application.properties文件中修改完畢後再打包，這樣就只須要運行java -jar rocketmq-console-ng-1.0.0.jar

• 啓動成功後，咱們就能夠經過瀏覽器訪問http://localhost:12581進入控制檯界面了，以下圖：