RocketMQ运维监控的实现方法
本篇内容主要讲解“RocketMQ运维监控的实现方法”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“RocketMQ运维监控的实现方法”吧!
信阳网站制作公司哪家好,找创新互联!从网页设计、网站建设、微信开发、APP开发、响应式网站等网站项目制作,到程序开发,运营维护。创新互联于2013年创立到现在10年的时间,我们拥有了丰富的建站经验和运维经验,来保证我们的工作的顺利进行。专注于网站建设就选创新互联。
一个完善的消息中间件,监控是必不可少的功能。通过监控我们可以查看系统的运行情况,是否出现异常,是系统稳定性和运维的基础。
1、监控平台搭建
下载地址:https://github.com/apache/rocketmq-externals
RocketMQ控制台需要自己去下载编译打包,可以在编译时设置其namesrvAddr和端口号,也可以在程序启动时指定这些参数(SpringBoot项目)
使用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 &
浏览器访问
管控台不仅有相关的系统监控数据,还有运维功能,如创建主题、修改主题、删除主题、主题列表信息、主题的配置信息、主题所有的消费组信息、每个消费组的每个队列中消费进度、Broker数节点信息、消息的查询等简单的看几个
最常用的消息的查询、可以查看其详细的发送的消息信息
消费进度查询
其他的功能可以自己查看。
2、运维命令
我们查看一下关于RocketMQ自己提供的控制台命令有哪些
我们分析下重点的常用命令
2.1、创建更新主题(updateTopic)
./mqadmin updateTopic -b 10.10.15.247:10911 -t TopicCmd
具体的参数详情可以查看提示
2.2、删除主题(deleteTopic)
./mqadmin deleteTopic -n 10.10.15.246:9876 -c 10.10.15.246:10911 -t TopicCmd
2.3、创建更新消费组(updateSubGroup)
./mqadmin updateSubGroup -n 10.10.15.246:9876 -b 10.10.15.247:10911 -g GroupTest
2.4、删除消费组(deleteSubGroup)
./mqadmin deleteSubGroup -n 10.10.15.246:9876 -b 10.10.15.246:10911 -g GroupTest
2.5、主题队列信息(topicStatus)
./mqadmin topicStatus -n 10.10.15.246:9876 -t TopicTest
2.6、主题路由信息(topicRoute)
./mqadmin topicRoute -n 10.10.15.246:9876 -t TopicTest
2.7、主题列表(topicList)
./mqadmin topicList -n 10.10.15.246:9876
2.8、Broker节点信息(brokerStatus)
./mqadmin brokerStatus -n 10.10.15.246:9876 -b 10.10.15.246:10911
2.9、通过KEY查询消息(queryMsgByKey)
./mqadmin queryMsgByKey -n 10.10.15.246:9876 -k 2000000 -t TopicTest
注意由于KEY是用户自己设置的所有查询时可能有多条消息
2.10、通过消息的ID查询消息(queryMsgById)
./mqadmin queryMsgById -i 0A0A0FF600002A9F000000000180DD31
我们看一下消息的offsetMsgId怎么找到的,发送的消息返回的信息中就有相关的信息
我们再查看一下查询到的消息体的路径
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
2.12、查看消费状态(brokerConsumeStats)
./mqadmin brokerConsumeStats -b 10.10.15.246:10911
2.13、集群的节点信息(clusterList)
./mqadmin clusterList -n 10.10.15.246:9876
2.14、总体的消费的状态信息(statsAll)
./mqadmin statsAll -n 10.10.15.246:9876
2.15、查看消费组下的消费者信息(consumerConnection)
./mqadmin consumerConnection -n 10.10.15.246:9876 -g group_name_1
2.16、消费进度信息(consumerProgress)
./mqadmin consumerProgress -n 10.10.15.246:9876
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
2.18、消息队列负载情况(allocateMQ)
./mqadmin allocateMQ -t TopicTest -i 192.168.1.104,10.10.14.163 -n 10.10.15.246:9876
2.19、测试Broker接收消息的性能(sendMsgStatus)
./mqadmin sendMsgStatus -n 10.10.15.246:9876 -b broker-a -c 3
2.20、测试集群消息发送的性能(clusterRT)
./mqadmin clusterRT -n 10.10.15.246:9876 -s 128
2.21、查看Broker配置信息(getBrokerConfig)
./mqadmin getBrokerConfig -b 10.10.15.246:10911
到此,相信大家对“RocketMQ运维监控的实现方法”有了更深的了解,不妨来实际操作一番吧!这里是创新互联网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!
当前名称:RocketMQ运维监控的实现方法
文章URL:http://ybzwz.com/article/pdgscs.html