# 系统概览
curl -u admin:admin123 http://localhost:15672/api/overview

# 节点信息
curl -u admin:admin123 http://localhost:15672/api/nodes

# 队列列表
curl -u admin:admin123 http://localhost:15672/api/queues

# 连接列表
curl -u admin:admin123 http://localhost:15672/api/connections

# 通道列表
curl -u admin:admin123 http://localhost:15672/api/channels

# 交换机列表
curl -u admin:admin123 http://localhost:15672/api/exchanges

# 健康检查
curl -u admin:admin123 http://localhost:15672/api/health/checks/alarms
curl -u admin:admin123 http://localhost:15672/api/health/checks/local-alarms
curl -u admin:admin123 http://localhost:15672/api/health/checks/protocol-listeners

import requests
import json

RABBITMQ_API = "http://localhost:15672/api"
AUTH = ("admin", "admin123")

def get_metrics():
    # 节点信息
    nodes = requests.get(f"{RABBITMQ_API}/nodes", auth=AUTH).json()
    for node in nodes:
        print(f"节点: {node['name']}")
        print(f"  内存使用: {node['mem_used'] / 1024**3:.2f} GB")
        print(f"  磁盘可用: {node['disk_free'] / 1024**3:.2f} GB")
        print(f"  Erlang 进程: {node['proc_used']}/{node['proc_total']}")
        print(f"  文件描述符: {node['fd_used']}/{node['fd_total']}")
    
    # 队列信息
    queues = requests.get(f"{RABBITMQ_API}/queues", auth=AUTH).json()
    for q in queues:
        if q['messages'] > 0:
            print(f"队列: {q['name']}, 消息: {q['messages']}, "
                  f"就绪: {q['messages_ready']}, 未确认: {q['messages_unacknowledged']}")
    
    # 连接信息
    connections = requests.get(f"{RABBITMQ_API}/connections", auth=AUTH).json()
    print(f"当前连接数: {len(connections)}")

get_metrics()

rabbitmq-plugins enable rabbitmq_prometheus

# prometheus.yml
global:
  scrape_interval: 15s

scrape_configs:
  - job_name: 'rabbitmq'
    static_configs:
      - targets: ['rabbitmq:15692']
    metrics_path: /metrics/per-object
    params:
      family:
        - queue_messages
        - queue_messages_ready
        - queue_messages_unacked

{
  "dashboard": {
    "title": "RabbitMQ Dashboard",
    "panels": [
      {
        "title": "Queue Depth",
        "type": "stat",
        "targets": [{
          "expr": "sum(rabbitmq_queue_messages)",
          "legendFormat": "Total Messages"
        }]
      },
      {
        "title": "Message Rate",
        "type": "graph",
        "targets": [
          {
            "expr": "rate(rabbitmq_channel_messages_published_total[5m])",
            "legendFormat": "Publish Rate"
          },
          {
            "expr": "rate(rabbitmq_channel_messages_delivered_total[5m])",
            "legendFormat": "Deliver Rate"
          }
        ]
      },
      {
        "title": "Connections",
        "type": "stat",
        "targets": [{
          "expr": "rabbitmq_connections"
        }]
      },
      {
        "title": "Memory Usage",
        "type": "gauge",
        "targets": [{
          "expr": "rabbitmq_process_resident_memory_bytes / rabbitmq_resident_memory_limit_bytes * 100",
          "legendFormat": "Memory %"
        }]
      }
    ]
  }
}

# rabbitmq_alerts.yml
groups:
  - name: rabbitmq
    rules:
      # 队列堆积告警
      - alert: RabbitMQQueueDepthHigh
        expr: rabbitmq_queue_messages > 10000
        for: 5m
        labels:
          severity: warning
        annotations:
          summary: "队列 {{ $labels.queue }} 消息堆积: {{ $value }}"

      # 未确认消息过多
      - alert: RabbitMQUnackedMessagesHigh
        expr: rabbitmq_queue_messages_unacked > 1000
        for: 5m
        labels:
          severity: warning
        annotations:
          summary: "队列 {{ $labels.queue }} 未确认消息过多: {{ $value }}"

      # 内存告警
      - alert: RabbitMQMemoryHigh
        expr: rabbitmq_process_resident_memory_bytes / rabbitmq_resident_memory_limit_bytes > 0.8
        for: 2m
        labels:
          severity: critical
        annotations:
          summary: "RabbitMQ 内存使用超过 80%"

      # 磁盘告警
      - alert: RabbitMQDiskSpaceLow
        expr: rabbitmq_disk_space_available_bytes < 2147483648
        for: 2m
        labels:
          severity: critical
        annotations:
          summary: "RabbitMQ 磁盘空间不足 2GB"

      # 连接数告警
      - alert: RabbitMQConnectionsHigh
        expr: rabbitmq_connections > 5000
        for: 5m
        labels:
          severity: warning
        annotations:
          summary: "RabbitMQ 连接数过高: {{ $value }}"

      # 节点不健康
      - alert: RabbitMQNodeDown
        expr: up{job="rabbitmq"} == 0
        for: 1m
        labels:
          severity: critical
        annotations:
          summary: "RabbitMQ 节点宕机"

#!/bin/bash
# rabbitmq_monitor.sh

API="http://localhost:15672/api"
AUTH="admin:admin123"

echo "=== RabbitMQ 监控报告 ==="
echo "时间: $(date)"
echo

# 集群状态
echo "--- 集群节点 ---"
curl -s -u $AUTH $API/nodes | jq -r '.[] | "\(.name): \(.running)"'

# 队列堆积
echo -e "\n--- 队列堆积 (>100) ---"
curl -s -u $AUTH $API/queues | jq -r '.[] | select(.messages > 100) | "\(.name): \(.messages) (\(.messages_ready) ready, \(.messages_unacknowledged) unacked)"'

# 连接数
echo -e "\n--- 连接数 ---"
conn_count=$(curl -s -u $AUTH $API/connections | jq 'length')
echo "当前连接数: $conn_count"

# 内存使用
echo -e "\n--- 内存使用 ---"
curl -s -u $AUTH $API/nodes | jq -r '.[] | "\(.name): \(.mem_used / 1073741824 | round)GB / \(.mem_limit / 1073741824 | round)GB"'

# 告警
echo -e "\n--- 系统告警 ---"
alarms=$(curl -s -u $AUTH $API/health/checks/alarms)
echo "告警状态: $alarms"