# 列出所有插件
rabbitmq-plugins list

# 启用插件
rabbitmq-plugins enable <plugin_name>

# 禁用插件
rabbitmq-plugins disable <plugin_name>

# 启用所有插件（不推荐生产）
rabbitmq-plugins enable --all

# 禁用所有插件
rabbitmq-plugins disable --all

# 列出并过滤插件状态
rabbitmq-plugins list -e enabled    # 仅显示已启用
rabbitmq-plugins list -m available  # 仅显示可用

# 手动安装第三方插件
cp rabbitmq_custom_plugin.ez /usr/lib/rabbitmq/plugins/
rabbitmq-plugins enable rabbitmq_custom_plugin

rabbitmq-plugins enable rabbitmq_management

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

# 列出所有队列
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/queues/%2F/my_queue

# 发送测试消息
curl -u admin:admin123 -X POST http://localhost:15672/api/exchanges/%2F/amq.default/publish \
  -H "Content-Type: application/json" \
  -d '{
    "properties": {},
    "routing_key": "my_queue",
    "payload": "test message",
    "payload_encoding": "string"
  }'

# 消费消息
curl -u admin:admin123 -X POST http://localhost:15672/api/queues/%2F/my_queue/get \
  -H "Content-Type: application/json" \
  -d '{"count":1,"requeue":false,"encoding":"auto","ackmode":"ack_requeue_true"}'

# 下载
curl -o rabbitmqadmin http://localhost:15672/cli/rabbitmqadmin
chmod +x rabbitmqadmin

# 列出队列
./rabbitmqadmin list queues name messages consumers

# 发布消息
./rabbitmqadmin publish exchange=amq.default routing_key=test payload="hello"

# 获取消息
./rabbitmqadmin get queue=test ackmode=ack_requeue_true count=5

# 导出定义（配置备份）
./rabbitmqadmin export rabbitmq_definitions.json

# 导入定义
./rabbitmqadmin import rabbitmq_definitions.json

# 下载与 RabbitMQ 版本匹配的插件
# https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases
wget https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases/download/v3.13.0/rabbitmq_delayed_message_exchange-3.13.0.ez

# 复制到插件目录
cp rabbitmq_delayed_message_exchange-3.13.0.ez /usr/lib/rabbitmq/plugins/

# 启用
rabbitmq-plugins enable rabbitmq_delayed_message_exchange

import pika
import json

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# 声明延迟交换机
channel.exchange_declare(
    exchange='delayed_orders',
    exchange_type='x-delayed-message',
    durable=True,
    arguments={'x-delayed-type': 'direct'}  # 内部路由类型
)

channel.queue_declare(queue='order_timeout', durable=True)
channel.queue_bind(exchange='delayed_orders', queue='order_timeout', routing_key='timeout')

# 发送延迟消息
for delay_ms, message in [
    (5000,   {'order': '001', 'action': 'remind_payment'}),      # 5秒
    (1800000, {'order': '002', 'action': 'auto_cancel'}),         # 30分钟
    (86400000, {'order': '003', 'action': 'auto_complete'}),      # 24小时
]:
    channel.basic_publish(
        exchange='delayed_orders',
        routing_key='timeout',
        body=json.dumps(message),
        properties=pika.BasicProperties(
            delivery_mode=2,
            headers={'x-delay': delay_ms}
        )
    )
    print(f"[x] 延迟 {delay_ms/1000}s: {message}")

connection.close()

# 发送新消息时，使用相同 message_id 覆盖旧消息
channel.basic_publish(
    exchange='delayed_orders',
    routing_key='timeout',
    body=json.dumps({'action': 'updated_timeout'}),
    properties=pika.BasicProperties(
        delivery_mode=2,
        message_id='order_001_timeout',  # 用于去重/覆盖
        headers={'x-delay': 60000}
    )
)

rabbitmq-plugins enable rabbitmq_shovel
rabbitmq-plugins enable rabbitmq_shovel_management  # 管理界面（可选）

# /etc/rabbitmq/rabbitmq.conf 中添加 advanced.config

%% advanced.config
[{rabbitmq_shovel,
  [{shovels,
    [{my_shovel,
      [{source,
        [{protocol, amqp091},
         {uris, ["amqp://admin:admin123@source-host:5672"]},
         {queue, <<"source_queue">>}]},
       {destination,
        [{protocol, amqp091},
         {uris, ["amqp://admin:admin123@dest-host:5672"]},
         {exchange, <<"dest_exchange">>},
         {publish_properties, [{delivery_mode, 2}]}}]},
       {ack_mode, on_confirm},
       {reconnect_delay, 5}
      ]}
    ]}
  ]}
].

# 通过 rabbitmqctl 创建动态 Shovel
rabbitmqctl set_parameter shovel my_shovel \
  '{"src-protocol":"amqp091","src-uri":"amqp://admin:admin123@source:5672","src-queue":"source_queue","dest-protocol":"amqp091","dest-uri":"amqp://admin:admin123@dest:5672","dest-exchange":"dest_exchange","ack-mode":"on-confirm","reconnect-delay":5}'

# 查看 Shovel 状态
rabbitmqctl list_shovels

# 删除 Shovel
rabbitmqctl clear_parameter shovel my_shovel

import requests
import json

# 创建动态 Shovel
response = requests.put(
    'http://localhost:15672/api/parameters/shovel/%2F/my_shovel',
    auth=('admin', 'admin123'),
    json={
        'value': {
            'src-protocol': 'amqp091',
            'src-uri': 'amqp://admin:admin123@source:5672',
            'src-queue': 'source_queue',
            'dest-protocol': 'amqp091',
            'dest-uri': 'amqp://admin:admin123@dest:5672',
            'dest-exchange': 'dest_exchange',
            'ack-mode': 'on-confirm',
            'reconnect-delay': 5
        }
    }
)
print(response.status_code)

rabbitmq-plugins enable rabbitmq_federation
rabbitmq-plugins enable rabbitmq_federation_management  # 管理界面

# 设置 upstream
rabbitmqctl set_parameter federation-upstream my_upstream \
  '{"uri":"amqp://admin:admin123@upstream-host:5672","prefetch-count":1000,"reconnect-delay":5,"ack-mode":"on-confirm"}'

# 设置策略（将特定交换机联邦到 upstream）
rabbitmqctl set_policy federate-exchanges "^federated\." \
  '{"federation-upstream-set":"my_upstream"}' \
  --apply-to exchanges

# 设置联邦队列策略
rabbitmqctl set_policy federate-queues "^federated\." \
  '{"federation-upstream-set":"my_upstream"}' \
  --apply-to queues

# DC1 的 upstream 指向 DC2
rabbitmqctl set_parameter federation-upstream dc2_upstream \
  '{"uri":"amqp://admin:admin123@dc2-rabbit:5672"}'

# DC2 的 upstream 指向 DC1（形成环形）
rabbitmqctl set_parameter federation-upstream dc1_upstream \
  '{"uri":"amqp://admin:admin123@dc1-rabbit:5672"}'

rabbitmq-plugins enable rabbitmq_prometheus

# prometheus.yml
scrape_configs:
  - job_name: 'rabbitmq'
    scrape_interval: 15s
    static_configs:
      - targets: ['rabbitmq-host:15692']
    metrics_path: /metrics

{
  "dashboard": {
    "title": "RabbitMQ Overview",
    "panels": [
      {
        "title": "Queue Depth",
        "targets": [{
          "expr": "rabbitmq_queue_messages",
          "legendFormat": "{{queue}}"
        }]
      },
      {
        "title": "Message Rate",
        "targets": [
          {"expr": "rate(rabbitmq_channel_messages_published_total[5m])", "legendFormat": "publish"},
          {"expr": "rate(rabbitmq_channel_messages_delivered_total[5m])", "legendFormat": "deliver"}
        ]
      },
      {
        "title": "Connections",
        "targets": [{"expr": "rabbitmq_connections"}]
      }
    ]
  }
}

rabbitmq-plugins enable rabbitmq_mqtt
# 端口: 1883 (TCP), 8883 (TLS)

rabbitmq-plugins enable rabbitmq_stomp
# 端口: 61613 (TCP), 61614 (TLS)

rabbitmq-plugins enable rabbitmq_web_stomp
# 提供 WebSocket 端点

rabbitmq-plugins enable rabbitmq_auth_backend_http
# 使用 HTTP 服务进行认证

# 配置 HTTP 认证
auth_backends.1 = http
auth_http.http_method   = post
auth_http.user_path     = http://auth-service/rabbitmq/user
auth_http.vhost_path    = http://auth-service/rabbitmq/vhost
auth_http.resource_path = http://auth-service/rabbitmq/resource
auth_http.topic_path    = http://auth-service/rabbitmq/topic

rabbitmq-plugins enable rabbitmq_top
# 在管理界面显示进程资源使用排名