3.5 集群監(jiān)控平臺搭建
3.5.1 概述
RocketMQ
有一個對其擴展的開源項目incubator-rocketmq-externals鲸睛,這個項目中有一個子模塊叫rocketmq-console
辨泳,這個便是管理控制臺項目了剔应,先將incubator-rocketmq-externals拉到本地蚕钦,因為我們需要自己對rocketmq-console
進行編譯打包運行。
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
啟動rocketmq-console:
java -jar rocketmq-console-ng-1.0.0.jar
啟動成功后哀九,我們就可以通過瀏覽器訪問http://localhost:8080
進入控制臺界面了癌别,如下圖:
image.png
集群狀態(tài):
image.png
4. 消息發(fā)送樣例
- 導入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.啟動producer
4.創(chuàng)建消息對象拜马,指定主題Topic、Tag和消息體
5.發(fā)送消息
6.關(guān)閉生產(chǎn)者producer
- 消息消費者步驟分析
1.創(chuàng)建消費者Consumer沐绒,制定消費者組名
2.指定Nameserver地址
3.訂閱主題Topic和Tag
4.設(shè)置回調(diào)函數(shù)俩莽,處理消息
5.啟動消費者consumer