rocketmq-console

3.5 集群監(jiān)控平臺(tái)搭建

3.5.1 概述

RocketMQ有一個(gè)對其擴(kuò)展的開源項(xiàng)目incubator-rocketmq-externals，這個(gè)項(xiàng)目中有一個(gè)子模塊叫rocketmq-console，這個(gè)便是管理控制臺(tái)項(xiàng)目了，先將incubator-rocketmq-externals拉到本地，因?yàn)槲覀冃枰约簩?code>rocketmq-console進(jìn)行編譯打包運(yùn)行。

image.png

3.5.2 下載并編譯打包


git clone https://github.com/apache/rocketmq-externals

cd rocketmq-console

mvn clean package -Dmaven.test.skip=true

注意：打包前在rocketmq-console中配置namesrv集群地址：


rocketmq.config.namesrvAddr=192.168.25.135:9876;192.168.25.138:9876

啟動(dòng)rocketmq-console：


java -jar rocketmq-console-ng-1.0.0.jar

啟動(dòng)成功后，我們就可以通過瀏覽器訪問http://localhost:8080進(jìn)入控制臺(tái)界面了，如下圖：

image.png

集群狀態(tài)：

image.png

4. 消息發(fā)送樣例

  • 導(dǎo)入MQ客戶端依賴

<dependency>

    <groupId>org.apache.rocketmq</groupId>

    <artifactId>rocketmq-client</artifactId>

    <version>4.4.0</version>

</dependency>
  • 消息發(fā)送者步驟分析r

1.創(chuàng)建消息生產(chǎn)者producer，并制定生產(chǎn)者組名

2.指定Nameserver地址

3.啟動(dòng)producer

4.創(chuàng)建消息對象，指定主題Topic、Tag和消息體

5.發(fā)送消息

6.關(guān)閉生產(chǎn)者producer
  • 消息消費(fèi)者步驟分析

1.創(chuàng)建消費(fèi)者Consumer，制定消費(fèi)者組名

2.指定Nameserver地址

3.訂閱主題Topic和Tag

4.設(shè)置回調(diào)函數(shù)，處理消息

5.啟動(dòng)消費(fèi)者consumer
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

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