监控rocketmq 常用方法
2023-09-11 14:18:55 时间
一、mqcloud(https://github.com/sohutv/mqcloud/)
sohu出的集客户端SDK,运维,监控,预警等功能的RocketMQ企业级一站式服务平台
使用java开发,功能比较多,对集群数量较多的环境支持比较好
二、RocketmqExporter(https://github.com/apache/rocketmq-exporter.git)
官方源码,使用java开发,支持集成到prometheus
三、rocketmq-6(https://github.com/hepyu/RocketmqExporter)
golang实现的生产可用rocketmq-exporter
个人比较喜欢这个,但因为作者偷了点懒,需要从rocketmq-console的http请求获取数据。也就是说RocketmqExporter必须依赖rocketmq-console
四、rocketmq-console-ng(https://github.com/apache/rocketmq-externals)
一直有在用,没想到还可以实现监控报警(参考https://blog.csdn.net/luanlouis/article/details/88078657)
mqadmin常用参数
#创建更新主题(updateTopic) ./mqadmin updateTopic -b 127.0.0.1:10911 -t TopicCmd #删除主题(deleteTopic) ./mqadmin deleteTopic -n 127.0.0.1:9876 -c 127.0.0.1:10911 -t TopicCmd #创建更新消费组(updateSubGroup) ./mqadmin updateSubGroup -n 127.0.0.1:9876 -b 127.0.0.1:10911 -g GroupTest #删除消费组(deleteSubGroup) ./mqadmin deleteSubGroup -n 127.0.0.1:9876 -b 127.0.0.1:10911 -g GroupTest #主题队列信息(topicStatus) ./mqadmin topicStatus -n 127.0.0.1:9876 -t TopicTest #主题路由信息(topicRoute) ./mqadmin topicRoute -n 127.0.0.1:9876 -t TopicTest #主题列表(topicList) ./mqadmin topicList -n 127.0.0.1:9876 #Broker节点信息(brokerStatus) ./mqadmin brokerStatus -n 127.0.0.1:9876 -b 127.0.0.1:10911 #通过KEY查询消息(queryMsgByKey) ./mqadmin queryMsgByKey -n 127.0.0.1:9876 -k 2000000 -t TopicTest #通过KEY查询消息(queryMsgByKey) ./mqadmin queryMsgByKey -n 127.0.0.1:9876 -k 2000000 -t TopicTest #打印消息(printMsg) ./mqadmin printMsg -n 127.0.0.1:9876 -t TopicTest -b 2019-07-26#07:50:00:000 -e 2019-07-26#09:00:00:000 #查看消费状态(brokerConsumeStats) ./mqadmin brokerConsumeStats -b 127.0.0.1:10911 #集群的节点信息(clusterList) ./mqadmin clusterList -n 127.0.0.1:9876 #总体的消费的状态信息(statsAll) ./mqadmin statsAll -n 127.0.0.1:9876 #查看消费组下的消费者信息(consumerConnection) ./mqadmin consumerConnection -n 127.0.0.1:9876 -g group_name_1 #消费进度信息(consumerProgress) ./mqadmin consumerProgress -n 127.0.0.1:9876 #消费进度信息(consumerProgress) ./mqadmin consumerProgress -n 127.0.0.1:9876 #消息队列负载情况(allocateMQ) ./mqadmin allocateMQ -t TopicTest -i 127.0.0.1 -n 127.0.0.1:9876 #测试Broker接收消息的性能(sendMsgStatus) ./mqadmin sendMsgStatus -n 127.0.0.1:9876 -b broker-a -c 3 #测试Broker接收消息的性能(sendMsgStatus) ./mqadmin sendMsgStatus -n 127.0.0.1:9876 -b broker-a -c 3 #查看Broker配置信息(getBrokerConfig) ./mqadmin getBrokerConfig -b 127.0.0.1:10911
引用:https://mp.weixin.qq.com/s/CyYdss6kFlo9qRuGfM_OlA
相关文章
- 【华为云技术分享】华为云文档数据库服务DDS监控告警全新优化
- 【监控】jvisualvm之jmx远程连接 tomcat war启动应用
- Zabbix运维---监控tcp的11种状态
- 辉哥用的这种方法实现ZABBIX的MYSQL批量监控
- Shell脚本监控CPU、内存和硬盘利用率
- RabbitMQ 队列监控
- Activity管理器 获取启动时间 监控生命周期 MD
- Qt编写安防视频监控系统(支持win/linux/mac/海康/大华/宇视/264/265等)
- 池与线程池 技术点 目录 1. 线程池作用: 提升性能1 2. 使用流程1 3. 线程与线程池的监控 jvisual1 4. 线程常用方法2 5. 线程池相关概念2 5.1. 队列
- 基于KPCA 和 STFT 非侵入式负荷监控(Matlab代码实现)
- 股票软件、股票分析、股票推荐、股票监控提醒、股票策略、股票盈利方法
- Linux服务器性能监控利器 —— Nmon实战
- 老杨说运维 | 基于统一监控基础上的数据治理怎么开展
- 云原生系列之使用prometheus监控redis集群实战
- open-falcon 安装 gpu-mon 显卡监控