# 在所有节点上设置相同的 Erlang Cookie
sudo rabbitmqctl stop_app
sudo rabbitmqctl reset

# 在 node2 上执行
sudo rabbitmqctl join_cluster rabbit@node1

# 在 node3 上执行
sudo rabbitmqctl join_cluster rabbit@node1

# 启动所有节点
sudo rabbitmqctl start_app

# 验证集群状态
sudo rabbitmqctl cluster_status

version: '3.8'
services:
  rabbit1:
    image: rabbitmq:4-management
    container_name: rabbit1
    hostname: rabbit1
    environment:
      RABBITMQ_ERLANG_COOKIE: "SWQOKODSQALRPCLNMEQG"
      RABBITMQ_DEFAULT_USER: admin
      RABBITMQ_DEFAULT_PASS: admin123
    ports:
      - "5672:5672"
      - "15672:15672"
    volumes:
      - rabbit1_data:/var/lib/rabbitmq
    networks:
      - rabbit_net

  rabbit2:
    image: rabbitmq:4-management
    container_name: rabbit2
    hostname: rabbit2
    environment:
      RABBITMQ_ERLANG_COOKIE: "SWQOKODSQALRPCLNMEQG"
    ports:
      - "5673:5672"
      - "15673:15672"
    volumes:
      - rabbit2_data:/var/lib/rabbitmq
    networks:
      - rabbit_net
    depends_on:
      - rabbit1

  rabbit3:
    image: rabbitmq:4-management
    container_name: rabbit3
    hostname: rabbit3
    environment:
      RABBITMQ_ERLANG_COOKIE: "SWQOKODSQALRPCLNMEQG"
    ports:
      - "5674:5672"
      - "15674:15672"
    volumes:
      - rabbit3_data:/var/lib/rabbitmq
    networks:
      - rabbit_net
    depends_on:
      - rabbit1

volumes:
  rabbit1_data:
  rabbit2_data:
  rabbit3_data:

networks:
  rabbit_net:
    driver: bridge

# 组建集群
docker exec rabbit2 rabbitmqctl stop_app
docker exec rabbit2 rabbitmqctl reset
docker exec rabbit2 rabbitmqctl join_cluster rabbit@rabbit1
docker exec rabbit2 rabbitmqctl start_app

docker exec rabbit3 rabbitmqctl stop_app
docker exec rabbit3 rabbitmqctl reset
docker exec rabbit3 rabbitmqctl join_cluster rabbit@rabbit1
docker exec rabbit3 rabbitmqctl start_app

# 所有队列在所有节点上镜像
rabbitmqctl set_policy ha-all '.*' '{"ha-mode":"all","ha-sync-mode":"automatic"}' --apply-to queues

# 指定数量的镜像
rabbitmqctl set_policy ha-two '.*' '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}' --apply-to queues

# 指定节点的镜像
rabbitmqctl set_policy ha-nodes '.*' '{"ha-mode":"nodes","ha-params":["rabbit@node1","rabbit@node2"]}' --apply-to queues

channel.queue_declare(
    queue='critical_orders',
    durable=True,
    arguments={
        'x-queue-type': 'quorum',
        'x-quorum-initial-group-size': 3,  # 副本数
        'x-delivery-limit': 5,             # 最大投递次数
        'x-dead-letter-exchange': 'dlx',
        'x-dead-letter-routing-key': 'failed'
    }
)

# 查看仲裁队列状态
rabbitmq-queues quorum_status "critical_orders"

# 查看集群中的仲裁队列成员
rabbitmq-queues members "critical_orders"

# 扩展：添加成员
rabbitmq-queues add_member critical_orders rabbit@node4

# 收缩：移除成员
rabbitmq-queues remove_member critical_orders rabbit@node3

# 查看所有仲裁队列
rabbitmq-queues quorum_status

# 查看集群状态
rabbitmqctl cluster_status

# 查看节点信息
rabbitmqctl status

# 停止节点
rabbitmqctl stop_app

# 重置节点（清除所有数据）
rabbitmqctl reset
# force_reset 强制重置（谨慎使用）
rabbitmqctl force_reset

# 移除集群节点
# 在要移除的节点上执行
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app

# 或者在其他节点上强制移除
rabbitmqctl forget_cluster_node rabbit@node3

# 修改节点类型
rabbitmqctl change_cluster_node_type ram   # 修改为内存节点
rabbitmqctl change_cluster_node_type disc  # 修改为磁盘节点

# 基本健康检查
rabbitmq-diagnostics check_running
rabbitmq-diagnostics check_port_connectivity
rabbitmq-diagnostics check_if_node_is_quorum_critical

# 综合健康检查
rabbitmq-diagnostics health_check

# 列出所有健康检查
rabbitmq-diagnostics list_checks

# /etc/rabbitmq/rabbitmq.conf
cluster_partition_handling = ignore
# 或
cluster_partition_handling = pause_minority

# 1. 检测分区
rabbitmqctl cluster_status | grep partitions

# 2. 手动恢复（选择数据最新的节点作为主节点）
# 在其他节点上执行
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster rabbit@primary_node
rabbitmqctl start_app

# 3. 或使用自动恢复（如果配置了 autoheal）
rabbitmqctl eval 'rabbit_node_monitor:force_autoheal().'

# /etc/haproxy/haproxy.cfg
listen rabbitmq_amqp
    bind *:5672
    mode tcp
    balance roundrobin
    option tcpka
    server rabbit1 10.0.0.1:5672 check inter 5s rise 2 fall 3
    server rabbit2 10.0.0.2:5672 check inter 5s rise 2 fall 3
    server rabbit3 10.0.0.3:5672 check inter 5s rise 2 fall 3

listen rabbitmq_management
    bind *:15672
    mode http
    balance roundrobin
    server rabbit1 10.0.0.1:15672 check
    server rabbit2 10.0.0.2:15672 check
    server rabbit3 10.0.0.3:15672 check

import pika

# 方式 1: 连接负载均衡器
conn = pika.BlockingConnection(pika.ConnectionParameters('haproxy-host'))

# 方式 2: 多节点故障转移
from pika import SSLOptions
params = [
    pika.ConnectionParameters('node1'),
    pika.ConnectionParameters('node2'),
    pika.ConnectionParameters('node3'),
]

# 简单的故障转移
for param in params:
    try:
        conn = pika.BlockingConnection(param)
        break
    except Exception:
        continue