RocketMQ環(huán)境搭建

1. 安裝包下載。

Apache官網(wǎng)下載 RocketMQ官網(wǎng)
下載文件解壓后,可以看到conf文件夾里有2m-noslave、2m-2s-async、2m-2s-sync文件夾:

  • 2m-noslave 兩主,無從的配置
  • 2m-2s-async 兩主,兩從,同步復制數(shù)據(jù)的配置
  • 2m-2s-sync 兩主,兩從,異步復制數(shù)據(jù)的配置


    image.png

上述配置是需要配置集群模式配置的內(nèi)容,如果配置單機模式,可以不用理會。
上述配置文件的詳細配置可參考官網(wǎng)。

環(huán)境變量配置

  • linux
    環(huán)境變量配置(JAVA_HOME和ROCKETMQ_HOME)
    vim /etc/profile
    修改如下配置
export JAVA_HOME=/usr/java/jdk1.8.0_102
export ROCKETMQ_HOME=/usr/local/rocketmq
export PATH=$PATH:$JAVA_HOME/bin:$ROCKETMQ_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib
  • window
    計算機-高級配置-環(huán)境變量
image.png

2. 修改nameServer和broker中內(nèi)存大小。(如果linux或者windows內(nèi)存不夠的話)

由于本地內(nèi)存不足4G,因此修改如下

  • runServer.cmd:


    image.png
  • runBroker.cmd:


    image.png

linux環(huán)境對應修改上述sh文件即可

3. 管理平臺下載

請參考文章 windows下Apache.RocketMQ安裝部署 第三節(jié)插件部署模塊,這里不做詳述。
【注意要修改下console項目的applicate屬性文件中namesrvAddr,默認為空】
打包編譯命令

mvn clean package -Dmaven.test.skip=true

4. 啟動命令

  • 啟動mqnamesrv
    windows:
    如果需要指定日志路徑,先去指定目錄創(chuàng)建logs文件夾,這樣啟動命令后面就可以指定日志路徑了。
cd F:\soft-install\rocketmq-4.4.0\bin

start  mqnamesrv.cmd >F:\soft-install\rocketmq-4.4.0\logs\mqnamesrv.log 

linux:

nohup sh mqnamesrv >/usr/local/rocketmq/logs/mqnamesrv.log 2>&1 &

  • 啟動mqbroker
    windows:
cd F:\soft-install\rocketmq-4.4.0\bin

start mqbroker.cmd -n "127.0.0.1:9876" autoCreateTopicEnable=true >F:\soft-install\rocketmq-4.4.0\logs\mqbroker.log

linux:

nohup sh mqbroker -n "127.0.0.1:9876" autoCreateTopicEnable=true> /usr/local/rocketmq/logs/mqbroker.log  2>&1 &

要設置自動創(chuàng)建Topic,需要加上 
autoCreateTopicEnable=true

關閉Broker服務 
sh mqshutdown broker

(還可以加上-c broker文件,指定使用哪個broker文件-c /usr/local/rocketmq/conf/2m-noslave/broker-a.properties )

  • 啟動管理平臺
    windows:進入編譯好的target目錄,執(zhí)行java -jar命令(可以通過參數(shù)動態(tài)修改服務端口號,以及nameServer的地址和端口,如果編譯時沒指定的話可以在啟動的時候通過參數(shù)指定)。
java -jar rocketmq-console-ng-1.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=127.0.0.1:9876

linux 同windows。

5. 管理平臺使用

  • 部署成功,打開http://服務器IP:8080
image.png
  • 查看和創(chuàng)建topic


    image.png
  • 查看服務消費者(消費者組)


    image.png
  • 查看指定Topic的消息


    image.png

參考文章
1、 官方指南
2、 RocketMQ入門手冊
3、 RocketMQ運維指令

最后編輯于
?著作權歸作者所有,轉載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

友情鏈接更多精彩內(nèi)容