# Erlang Cookie 위치 (Linux 기준)
cat /var/lib/rabbitmq/.erlang.cookie

# 모든 노드에 동일한 Cookie 값을 설정해야 한다

# node2에서 node1의 클러스터에 합류
rabbitmqctl stop_app
rabbitmqctl join_cluster rabbit@node1
rabbitmqctl start_app

# 클러스터 상태 확인
rabbitmqctl cluster_status

┌─────────────────────────────────────────────────┐
│              RabbitMQ Cluster                    │
│                                                 │
│  ┌───────────┐  ┌───────────┐  ┌───────────┐   │
│  │  Node 1   │  │  Node 2   │  │  Node 3   │   │
│  │ (Disc)    │  │ (Disc)    │  │ (RAM)     │   │
│  │           │  │           │  │           │   │
│  │ Queue-A   │  │ Queue-B   │  │ Queue-C   │   │
│  │ [메시지]  │  │ [메시지]  │  │ [메시지]  │   │
│  └─────┬─────┘  └─────┬─────┘  └─────┬─────┘   │
│        │              │              │          │
│        └──────────────┼──────────────┘          │
│            메타데이터 동기화 (자동)               │
│            메시지 복제 (별도 설정 필요)            │
└─────────────────────────────────────────────────┘

# RAM Node로 클러스터에 합류
rabbitmqctl join_cluster --ram rabbit@node1

# 나중에 Disc Node로 변경
rabbitmqctl change_cluster_node_type disc

┌──────────────┐    ┌──────────────┐    ┌──────────────┐
│    Node 1    │    │    Node 2    │    │    Node 3    │
│              │    │              │    │              │
│ ┌──────────┐ │    │ ┌──────────┐ │    │ ┌──────────┐ │
│ │ Master Q │─┼────┼▶│ Mirror Q │ │    │ │ Mirror Q │ │
│ │ (원본)   │─┼────┼─┼──────────┼─┼────┼▶│ (복제본) │ │
│ └──────────┘ │    │ └──────────┘ │    │ └──────────┘ │
└──────────────┘    └──────────────┘    └──────────────┘
         │                 ▲                    ▲
         │       비동기 복제 (async replication)  │
         └────────────────────────────────────────┘

# 모든 큐를 모든 노드에 미러링
rabbitmqctl set_policy ha-all ".*" '{"ha-mode":"all"}'

# 특정 큐를 2개 노드에 미러링
rabbitmqctl set_policy ha-two "^order\." '{"ha-mode":"exactly","ha-params":2}'

# 동기화 모드 설정
rabbitmqctl set_policy ha-sync ".*" \
  '{"ha-mode":"all","ha-sync-mode":"automatic"}'

                    메시지 발행
                       │
                       ▼
┌──────────────────────────────────────────────┐
│               Quorum Queue                    │
│                                              │
│  ┌──────────┐  ┌──────────┐  ┌──────────┐   │
│  │  Node 1  │  │  Node 2  │  │  Node 3  │   │
│  │ (Leader) │  │(Follower)│  │(Follower)│   │
│  └────┬─────┘  └────┬─────┘  └────┬─────┘   │
│       │              │              │        │
│       │   1. 메시지 복제 요청        │        │
│       ├─────────────▶│              │        │
│       ├──────────────┼─────────────▶│        │
│       │              │              │        │
│       │   2. ACK 응답 (과반수)       │        │
│       │◀─────────────┤              │        │
│       │              │     (2/3 OK) │        │
│       │                                      │
│       │   3. 커밋 확정 → Producer에 Confirm   │
│       │                                      │
└──────────────────────────────────────────────┘

// Spring AMQP에서 Quorum Queue 선언
@Bean
public Queue orderQueue() {
    return QueueBuilder.durable("order.queue")
        .quorum()            // Quorum Queue로 선언
        .deliveryLimit(5)    // 최대 재전송 횟수
        .build();
}

# CLI로 Quorum Queue 선언
rabbitmqadmin declare queue name=order.queue \
  durable=true arguments='{"x-queue-type":"quorum"}'

네트워크 파티션 발생!
Node1, Node2  ←──── X ────→  Node3

[ignore]
  Node1, Node2: 계속 동작 (자신이 정상이라고 판단)
  Node3: 계속 동작 (자신이 정상이라고 판단)
  → split-brain 발생! 양쪽에서 같은 큐를 독립적으로 운영

[pause-minority]
  Node1, Node2: 계속 동작 (과반수 = 2/3)
  Node3: 자동 일시 정지 (소수 = 1/3)
  → split-brain 방지, 파티션 복구 시 Node3 자동 재개

[autoheal]
  파티션 중: 양쪽 모두 동작
  파티션 복구 시: 소수 파티션(Node3)을 자동으로 재시작
  → 소수 파티션의 미동기화 데이터는 유실될 수 있음

# rabbitmq.conf
cluster_partition_handling = pause_minority

[정상 상태]
  Node1: Queue-A (메시지 100건)
  Node2: Queue-B (메시지 50건)
  Node3: (큐 없음)

[Node1 장애 발생]
  Queue-A: 접근 불가 ❌
  Queue-B: 정상 동작 ✅

  → Node1이 복구될 때까지 Queue-A의 메시지 100건에 접근할 수 없음
  → Node1이 복구되면 메시지 복원 (Durable + Persistent인 경우)
  → Durable하지 않았다면 메시지 영구 유실

[정상 상태]  (3노드, Quorum Queue)
  Node1: Queue-A Leader  + Queue-A 데이터
  Node2: Queue-A Follower + Queue-A 데이터
  Node3: Queue-A Follower + Queue-A 데이터

[Node1 장애 발생]
  Node2 또는 Node3이 새 Leader로 선출
  Queue-A: 정상 동작 ✅ (과반수 2/3 생존)

  → 서비스 중단 없이 계속 메시지 발행/소비 가능
  → Node1 복구 시 자동으로 Follower로 재합류, 누락 로그 동기화

# 클러스터 전체 상태 확인
rabbitmqctl cluster_status

# 특정 Quorum Queue의 상태 확인
rabbitmqctl list_queues name type leader members \
  --formatter=pretty_table

# 노드 간 연결 상태 확인
rabbitmq-diagnostics check_port_connectivity

# Management Plugin 활성화
rabbitmq-plugins enable rabbitmq_management

# 기본 접속 URL: http://localhost:15672
# 기본 계정: guest / guest (로컬만 접근 가능)