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
