RocketMQ 消息队列监控接入

支持的中间件条件

接入前请确认目标实例满足以下条件，否则可能出现采集不到数据或指标缺失。

前提条件

• 已开通可观测监控Prometheus版。

• 接入 CS 环境：目标 ACK 集群已接入云监控 2.0，且集群状态为运行中；目标 RocketMQ 服务可在该集群网络内连通。

• 接入 ECS(VPC) 环境：已选定目标 RocketMQ 所在 ECS，并确保托管探针交换机网段可访问该 ECS。

费用说明

• 根据产生的指标数据量，在 Prometheus产品中计费。无其他费用。

接入方法

步骤一：确认 ACL（如需）

Broker 未开启 ACL（aclEnable）时可跳过本步骤。若已开启 ACL，请准备具备管控权限的 AccessKey / SecretKey，并在接入表单中填写。

步骤二：选择接入环境

本插件支持 CS 与 ECS(VPC) 两种接入环境，工作原理不同，请按 RocketMQ 实际部署位置选择：

CS（容器服务）

• 将 Exporter 安装到用户指定的目标 ACK 集群，并复用该集群已有的采集器进行指标采集。

• 观测对象为 ACK 集群。

• 网络要求：目标 RocketMQ 服务可在该集群网络内连通即可（例如集群内 Service，或集群能访问到的 VPC 内网地址）。

ECS(VPC)

• 选择目标 RocketMQ 服务部署的 ECS 机器，系统根据该 ECS 的 VPC 信息部署全托管采集器。

• 不会在 ECS 上安装任何进程。

• 观测对象为 ECS 实例。

• 网络要求：托管探针所在交换机网段需允许访问目标 ECS（安全组、ACL 等需放行）。

步骤三：接入配置

1. 登录云监控2.0控制台，选择目标工作空间后，在左侧导航栏单击 接入中心 ，单击 RocketMQ 开始接入。

2. 选择接入环境（CS 或 ECS(VPC)），并在下拉列表中选择 观测对象 。

3. 接入配置，配置完成后单击 确定 ：

   基础配置

   配置项	是否必填	默认值	说明
   RocketMQ NameServer 地址	是	-	host:port 或 ip:port，多个用分号 ; 分隔
   云厂商 / 部署来源	否	self-hosted/rocketmq	写入 provider 标签。选项中不含阿里云托管版
   AccessKey / SecretKey（ACL）	否	空	仅 Broker 开启 ACL 时填写
   Metric 采集间隔（秒）	是	30	Prometheus 拉取 /metrics 的间隔。开启「按 Task 独立调度采集」时不再作为后台 RPC 全量采集周期
   自定义标签	否	空	注入到指标上的额外标签
   使用公网镜像地址	否	关闭	无法访问内网镜像仓库时开启

   采集调度与并发（可选，推荐大集群按默认值使用）

   配置项	是否必填	默认值	说明
   按 Task 独立调度采集	否	开启	开启后按下方各 Task 独立调度后台采集；关闭则回退为单一 collect_interval（等于 Metric 采集间隔）
   Topic/消费组采集并发（workers）	否	1	Topic / 消费组 RPC 并行度。大集群建议保持 1
   Broker 采集并发（broker_workers）	否	1	Broker 维度（runtime / stats）并行度。大集群建议保持 1
   指标缓存 TTL（秒）	否	0	0 表示自动（各 Task 间隔 × 2）；填正整数则使用固定 TTL
   客户端指标并发（client_metric_workers）	否	10	在线消费者客户端指标异步采集线程池大小
   客户端指标队列长度	否	5000	客户端指标异步任务队列容量
   采集消费延迟（storetime）	否	开启	是否采集 rocketmq_group_get_latency_by_storetime；大集群可关闭以减轻 RPC
   Topic 采集间隔（毫秒）	否	0	每个 Topic 处理后的 sleep，用于削峰（如 50–200）
   消费组采集间隔（毫秒）	否	0	每个消费组之间的 sleep

   Task 调度周期（仅「按 Task 独立调度采集」开启时生效）

   取值支持 Go duration（如 60s、15m）或 Spring cron；填 - 表示禁用该 Task。

   配置项	默认值	说明
   Task collect_topic_offset	-（禁用）	Topic 位点采集；默认禁用以降低 RPC
   Task collect_producer	120s	生产者指标
   Task collect_consumer_offset	15m	消费组堆积 / 位点（较重，大集群建议 ≥15m）
   Task collect_broker_stats_topic	120s	按 Topic 的 Broker stats（最重 Task，可配合 Topic 采集间隔削峰）
   Task collect_broker_stats	120s	Broker 汇总 stats
   Task collect_broker_runtime_stats	60s	Broker 运行时（线程池、TPS 等）

   说明

   大集群调参建议：保持 workers=1、broker_workers=1；优先拉长 collect_broker_stats_topic / collect_consumer_offset；若 Broker query 线程池队列持续上涨，可增大对应 Task 间隔或设置 topic_sleep_millis 为 50–200。

4. 接入成功后，可在 实体探索 查看接入的实体及相关可观测数据。

数据使用说明

实体说明

接入后，云监控定期从 rocketmq_broker_tps 等指标的标签中发现 RocketMQ 实例，并生成中间件实体：

实体字段来自采集标签，与安装次数无关：

可在 实体探索 或 中间件洞察 应用中按上述字段检索实例。

内置大盘

核心指标

以下为实体数据集 middleware.metric.rocketmq 的完整指标清单（共 89 个），可在实体详情、大盘与告警中直接使用：

常用查询示例

# 消费组堆积
rocketmq_group_diff

# Broker 生产 TPS
rocketmq_broker_tps

# CommitLog 磁盘使用率
rocketmq_brokeruntime_commitlog_disk_ratio

告警模板

本接入组件暂未内置告警规则。可在 告警中心 基于上述指标自行配置，例如对 rocketmq_broker_tps 存活指标不等于 1、连接数 / 堆积量超阈值等场景设置告警。

存储策略说明

接入 RocketMQ 后，云监控会创建对应的存储实例用于存储可观测数据。

卸载或修改接入策略

如果期望取消或修改 RocketMQ 的接入，可以在 接入中心 的 接入管理 页，找到对应的接入策略，进行 编辑 或 删除 。删除接入策略后，Exporter 与采集配置一并移除，已写入的历史指标按存储的生命周期策略保留。