当前位置: 首页 > news >正文

prometheus监控RocketMQ的方法

RocketMQ 官方提供了 rocketmq-exporter,通过连接 NameServer 拉取整个集群的 Broker、Topic、Consumer Group 指标,暴露为 Prometheus 格式。
只需部署一个 Exporter 实例,就能监控整个集群(所有 Broker),不需要每台机器都装。
如是是多集群监控,需要第一个集群对应一个rocketmq-exporter。

一、部署 Exporter
未开启 ACL,部署方式

docker run -d \ --name rocketmq-exporter \ -e JAVA_OPTS="-Xms256m -Xmx256m" \ -e "rocketmq.config.namesrvAddr=192.168.1.1:9876;192.168.1.2:9876;192.168.1.3:9876" \ -p 5557:5557 \ --restart=always \ -e TZ=Asia/Shanghai \ #apache/rocketmq-exporter swr.cn-north-4.myhuaweicloud.com/ddn-k8s/docker.io/slpcat/rocketmq-exporter:latest

已开启 ACL,部署方式

docker run -d \ --name rocketmq-exporter \ -e JAVA_OPTS="-Xms256m -Xmx256m" \ -e "rocketmq.config.namesrvAddr=192.168.1.1:9876;192.168.1.2:9876;192.168.1.3:9876" \ -e "rocketmq.config.accessKey=YourAccessKey" \ -e "rocketmq.config.secretKey=YourSecretKey" \ -e "rocketmq.config.enableACL=true" \ -p 5557:5557 \ --restart=always \ -e TZ=Asia/Shanghai \ #apache/rocketmq-exporter swr.cn-north-4.myhuaweicloud.com/ddn-k8s/docker.io/slpcat/rocketmq-exporter:latest

镜像可根据自己的的下载方式更换

备注:enableACL=true 这个参数必须加!默认是 false,即使你传了 accessKey/secretKey 也不会生效,
Exporter 会以无认证方式连接 Broker,然后报 username cannot be null

二、 验证

查看启动日志

docker logs -f -n 20 rocketmq-exporter

确认有指标输出

curl http://192.168.1.2:5557/metrics | head -20

看看有没有 broker 相关指标

curl -s http://192.168.1.2:5557/metrics | grep rocketmq_broker

看到 rocketmq_broker、rocketmq_producer_offset、rocketmq_consumer_offset 等指标就说明采集正常。

二、Prometheus 配置
在 Prometheus 配置文件 prometheus.yml 中添加 Exporter 的采集 Job:

scrape_configs: - job_name: 'rocketmq' static_configs: - targets: ['192.168.1.2:5557'] metrics_path: '/metrics' scrape_interval: 15s

同时确保告警规则文件已引入:

rule_files: - "/prometheus/rules/*.yml"

重载 Prometheus 配置:

#方式一:调用 API(推荐,需启动时加 --web.enable-lifecycle)
curl -X POST http://localhost:9090/-/reload

#方式二:发送信号(仅限非 Docker 部署,Docker 内 PID namespace 隔离,宿主机拿不到进程号)
kill -HUP $(pidof prometheus)

如果是多集群按如下方式配置

- job_name: rocketmq static_configs: - targets: ['10.1.1.1:5557'] labels: cluster: rmq-A - targets: ['10.1.2.1:5558'] labels: cluster: rmq-B - targets: ['10.1.3.1:5559'] labels: cluster: rmq-C - targets: ['10.1.4.1:5560'] labels: cluster: rmq-D - targets: ['10.1.5.1:5561'] labels: cluster: rmq-E - targets: ['10.1.6.1:5562'] labels: cluster: rmq-F

三、grafana模板
推荐 Grafana Dashboard 14612

http://www.jsqmd.com/news/690123/

相关文章:

  • 深度测评2026年精选小提琴入门推荐榜单,助你开启音乐之门
  • 2026年q2杭州浙音定向音乐艺考冲刺班实力排行:杭州器乐艺考培训,杭州声乐艺考培训,杭州艺考培训,优选推荐! - 优质品牌商家
  • 从游戏引擎到三维重建:一次搞懂MVP变换里的相机坐标系(附Blender/Unity对照)
  • 爬虫被封怕了?试试这几种动态代理IP的调度策略
  • FastAPI与Docker实现机器学习模型部署实战
  • Mapshaper:三分钟学会处理地理数据的全能工具
  • 极限概念解析与计算方法全攻略
  • AI机器人击败乒乓球精英选手,树立机器人技术新里程碑
  • Docker 27集群节点宕机后自动愈合全过程:从故障检测、服务漂移到状态同步的7步闭环策略
  • Autosar E2E保护机制深度解析:从P01配置参数到车载网络实战避坑指南
  • 问卷设计对比实测:传统耗时易错 vs 虎贲等考 AI 一键生成,学术调研效率翻倍
  • 2026杭州工厂保洁技术评测:靠谱服务商核心标准解析 - 优质品牌商家
  • 【技术团队拆解】蔚来智驾“三重变奏”:人事地震、组织缝合与世界模型的生死赌局
  • 流式计算与动态并行化技术在机器学习加速中的应用
  • 从Wi-Fi到二维码:聊聊BCH码在你每天用的技术里是怎么‘默默纠错’的
  • 从 ESLint/Prettier 到 Java:代码格式化与检查工具的全面对标实战
  • 用MATLAB的Phased Array Toolbox快速上手:从常规脉冲到相位编码雷达的波形生成与可视化
  • 机器学习中的线性代数:从基础到实践应用
  • ClamAV扫U盘太慢?教你3个高级参数和正则排除法,让Ubuntu病毒扫描效率翻倍
  • 【大白话说Java面试题】【Java基础篇】第7题:HashMap的get流程是什么
  • NCMconverter:3步解锁网易云加密音乐,让音乐真正属于你
  • 从噪音困扰到静音掌控:FanControl如何让你重新定义电脑散热体验
  • AI提效20讲⑤:动机-行为-呈现——统一表达的三维坐标系
  • 2026年房产抵押品牌选择全维度技术分析指南 - 优质品牌商家
  • GEO从入门到精通:第3章 意图词研究
  • 如何免费将PPTX转为HTML?3分钟掌握纯JS神器PPTX2HTML的终极指南
  • 从零到一:数字孪生智慧园区整体建设方案与实施路径深度解析
  • 【国家级数字农场认证方案】:基于Docker 27的传感器数据容器化架构设计——含NIST可追溯日志、GDPR兼容采集模板与OTA升级容器
  • Mythos AI是什么?为何对全球网络安全构成威胁
  • 从电动车到充电器:拆解IGBT与MOSFET在新能源设备里的真实工作状态