RocketMQ运维监控的实现方法

本篇内容主要讲解“RocketMQ运维监控的实现方法”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“RocketMQ运维监控的实现方法”吧!

信阳网站制作公司哪家好,找创新互联!从网页设计、网站建设、微信开发、APP开发、响应式网站等网站项目制作,到程序开发,运营维护。创新互联于2013年创立到现在10年的时间,我们拥有了丰富的建站经验和运维经验,来保证我们的工作的顺利进行。专注于网站建设就选创新互联

一个完善的消息中间件,监控是必不可少的功能。通过监控我们可以查看系统的运行情况,是否出现异常,是系统稳定性和运维的基础。

1、监控平台搭建

下载地址:https://github.com/apache/rocketmq-externals

RocketMQ控制台需要自己去下载编译打包,可以在编译时设置其namesrvAddr和端口号,也可以在程序启动时指定这些参数(SpringBoot项目)

RocketMQ运维监控的实现方法

使用maven打包

mvn clean package -Dmaven.test.skip=true

启动程序

nohup java -jar rocketmq-console-ng-1.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=10.10.15.246:9876;10.10.15.246:9876 &

浏览器访问

RocketMQ运维监控的实现方法

管控台不仅有相关的系统监控数据,还有运维功能,如创建主题、修改主题、删除主题、主题列表信息、主题的配置信息、主题所有的消费组信息、每个消费组的每个队列中消费进度、Broker数节点信息、消息的查询等简单的看几个

最常用的消息的查询、可以查看其详细的发送的消息信息

RocketMQ运维监控的实现方法

消费进度查询

RocketMQ运维监控的实现方法

其他的功能可以自己查看。

2、运维命令

我们查看一下关于RocketMQ自己提供的控制台命令有哪些

RocketMQ运维监控的实现方法

我们分析下重点的常用命令

2.1、创建更新主题(updateTopic)

./mqadmin updateTopic -b 10.10.15.247:10911 -t TopicCmd

RocketMQ运维监控的实现方法

具体的参数详情可以查看提示

2.2、删除主题(deleteTopic)

./mqadmin deleteTopic -n 10.10.15.246:9876  -c 10.10.15.246:10911 -t TopicCmd

RocketMQ运维监控的实现方法

2.3、创建更新消费组(updateSubGroup)

./mqadmin updateSubGroup -n 10.10.15.246:9876 -b 10.10.15.247:10911 -g GroupTest

RocketMQ运维监控的实现方法

2.4、删除消费组(deleteSubGroup)

./mqadmin deleteSubGroup -n 10.10.15.246:9876 -b 10.10.15.246:10911 -g GroupTest

RocketMQ运维监控的实现方法

2.5、主题队列信息(topicStatus)

./mqadmin topicStatus -n 10.10.15.246:9876 -t TopicTest

RocketMQ运维监控的实现方法

2.6、主题路由信息(topicRoute)

./mqadmin topicRoute -n 10.10.15.246:9876 -t TopicTest

RocketMQ运维监控的实现方法

2.7、主题列表(topicList)

./mqadmin topicList -n 10.10.15.246:9876

RocketMQ运维监控的实现方法

2.8、Broker节点信息(brokerStatus)

./mqadmin brokerStatus -n 10.10.15.246:9876 -b 10.10.15.246:10911

RocketMQ运维监控的实现方法

2.9、通过KEY查询消息(queryMsgByKey)

./mqadmin queryMsgByKey -n 10.10.15.246:9876 -k 2000000 -t TopicTest

RocketMQ运维监控的实现方法

注意由于KEY是用户自己设置的所有查询时可能有多条消息

RocketMQ运维监控的实现方法

2.10、通过消息的ID查询消息(queryMsgById)

./mqadmin queryMsgById -i 0A0A0FF600002A9F000000000180DD31

RocketMQ运维监控的实现方法

我们看一下消息的offsetMsgId怎么找到的,发送的消息返回的信息中就有相关的信息

RocketMQ运维监控的实现方法

我们再查看一下查询到的消息体的路径

RocketMQ运维监控的实现方法

2.11、打印消息(printMsg)

./mqadmin printMsg -n 10.10.15.246:9876 -t TopicTest -b 2019-07-26#07:50:00:000 -e 2019-07-26#09:00:00:000

RocketMQ运维监控的实现方法

2.12、查看消费状态(brokerConsumeStats)

./mqadmin brokerConsumeStats -b 10.10.15.246:10911

RocketMQ运维监控的实现方法

2.13、集群的节点信息(clusterList)

./mqadmin clusterList -n 10.10.15.246:9876

RocketMQ运维监控的实现方法

2.14、总体的消费的状态信息(statsAll)

./mqadmin statsAll -n 10.10.15.246:9876

RocketMQ运维监控的实现方法

2.15、查看消费组下的消费者信息(consumerConnection)

./mqadmin consumerConnection -n 10.10.15.246:9876 -g group_name_1

RocketMQ运维监控的实现方法

2.16、消费进度信息(consumerProgress)

./mqadmin consumerProgress -n 10.10.15.246:9876

RocketMQ运维监控的实现方法

2.17、重置消费点位(resetOffsetByTime)

./mqadmin resetOffsetByTime -n 10.10.15.246:9876 -t TopicTest -g group_name_1 -s 2019-07-26#07:00:00:000

RocketMQ运维监控的实现方法

2.18、消息队列负载情况(allocateMQ)

./mqadmin allocateMQ -t TopicTest -i 192.168.1.104,10.10.14.163 -n 10.10.15.246:9876

RocketMQ运维监控的实现方法

2.19、测试Broker接收消息的性能(sendMsgStatus)

./mqadmin sendMsgStatus -n 10.10.15.246:9876 -b broker-a -c 3

RocketMQ运维监控的实现方法

2.20、测试集群消息发送的性能(clusterRT)

./mqadmin clusterRT -n 10.10.15.246:9876 -s 128

RocketMQ运维监控的实现方法

2.21、查看Broker配置信息(getBrokerConfig)

./mqadmin getBrokerConfig -b 10.10.15.246:10911

RocketMQ运维监控的实现方法

到此,相信大家对“RocketMQ运维监控的实现方法”有了更深的了解,不妨来实际操作一番吧!这里是创新互联网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!


当前名称:RocketMQ运维监控的实现方法
文章URL:http://ybzwz.com/article/pdgscs.html