Debian RabbitMQ如何监控队列状态 - 问答

Debian 上监控 RabbitMQ 队列状态的可落地方案

一快速查看与巡检

启用管理插件并登录控制台
启用插件：sudo rabbitmq-plugins enable rabbitmq_management
访问地址：http://:15672（默认账号 guest/guest，生产环境请创建专用监控账号）。在控制台可查看 Overview、Queues、Connections 等页面，关注队列的 Ready/Unacked/Messages、Consumers、Message Rates 等关键面板。
命令行即时查询
查看队列列表与关键计数：
sudo rabbitmqctl list_queues name messages_ready messages_unacknowledged consumers
如需查看某个 vhost 的队列：
sudo rabbitmqctl -p list_queues name messages_ready messages_unacknowledged consumers
其他常用：list_connections、list_channels、list_exchanges、list_vhosts。
HTTP API 获取队列详情
获取某队列信息（示例 vhost 为“/”，队列名为“my_queue”）：
curl -u : http://localhost:15672/api/queues/%2F/my_queue
返回 JSON 中包含 messages_ready、messages_unacknowledged、consumers、message_stats 等字段，便于脚本化巡检与对接外部监控系统。

二长期监控与告警 Prometheus Grafana

启用 Prometheus 指标插件
启用插件：sudo rabbitmq-plugins enable rabbitmq_prometheus
指标端点：http://:15692/metrics（默认端口 15692，可在配置中调整）。该端点提供 200+ 指标，涵盖队列长度、消息速率、节点资源等。
Prometheus 抓取配置示例
scrape_configs:
- job_name: ‘rabbitmq’ static_configs:
  - targets: [‘rabbitmq-node1:15692’,‘rabbitmq-node2:15692’] metrics_path: /metrics relabel_configs:
  - source_labels: [address] target_label: instance
Grafana 可视化
导入官方 Dashboard：ID 10991（RabbitMQ Management）。常用面板与 PromQL：
- 队列积压趋势：sum(rate(rabbitmq_queue_messages_ready[5m])) by (queue)
- 消息吞吐热力图：sum(rate(rabbitmq_channel_get_rates[1m])) by (node)
  可结合队列、节点、vhost 等变量实现多维下钻。
生产可用告警规则示例
groups:
- name: rabbitmq.rules rules:
  - alert: HighQueueBacklog expr: sum(rabbitmq_queue_messages_ready) by (queue) > 1000 for: 5m labels: {severity: critical} annotations: {summary: “队列 {{ $labels.queue }} 积压超过阈值”}
  - alert: MemoryPressure expr: erlang_vm_memory_system_bytes / erlang_vm_memory_bytes_total * 100 > 80 for: 2m labels: {severity: warning}

三健康检查与自动化脚本

节点存活性与基础健康
检查服务状态：sudo systemctl status rabbitmq-server
节点探活：rabbitmq-diagnostics ping（期望输出 “Ping succeeded”）
结构化健康检查：curl -u : ‘http://:15672/api/healthchecks/node’（关注返回状态是否为 ok）。
一键巡检脚本示例（Bash）
#!/usr/bin/env bash set -e USER=monitor PASS=password HOST=localhost QUEUE=my_queue VHOST=/ curl -s -u “$USER:$PASS” “http://$HOST:15672/api/queues/$(printf ‘%s’ “$VHOST” | jq -sRr @uri)/$QUEUE”
| jq -r ‘[.name, .messages_ready, .messages_unacknowledged, .consumers] | @tsv’

四关键指标与阈值建议

0 赞

0 踩