// 같은 큐에 여러 컨슈머 연결 예시
String queueName = "task_queue";
channel.queueDeclare(queueName, true, false, false, null);
 
// 컨슈머 1
channel.basicConsume(queueName, false, deliverCallback1, consumerTag -> {});
// 컨슈머 2  
channel.basicConsume(queueName, false, deliverCallback2, consumerTag -> {});
 
// 메시지 전달 순서:
// 메시지1 → 컨슈머1
// 메시지2 → 컨슈머2
// 메시지3 → 컨슈머1

// 같은 routing key, 다른 큐에 바인딩
channel.queueBind("queue1", "direct_exchange", "orders");
channel.queueBind("queue2", "direct_exchange", "orders");
// 결과: 메시지가 queue1과 queue2 모두에 복사됨

// 같은 큐 사용 (여러 컨슈머가 Round-Robin 분배)
channel.queueDeclare("order_queue", true, false, false, null);
 
// 다른 큐 사용 (각각 독립적)
channel.queueDeclare("email_queue", true, false, false, null);
channel.queueDeclare("sms_queue", true, false, false, null);
 
// 서버 자동 생성 큐 (고유 이름 자동 생성)
String randomQueueName = channel.queueDeclare().getQueue();
// 예: amq.gen-JzTY20BRgKO-HjmUJj0wLg

// 첫 번째 선언
channel.queueDeclare("test_queue", true, false, false, null);
 
// 두 번째 선언 (다른 durable 값) - 에러 발생!
channel.queueDeclare("test_queue", false, false, false, null);
// IOException: PRECONDITION_FAILED

// 서버 생성 큐 활용 예시
String tempQueue = channel.queueDeclare().getQueue();
channel.queueBind(tempQueue, "logs", "");
 
// RPC 패턴에서 응답 큐로 활용
String replyQueue = channel.queueDeclare().getQueue();
AMQP.BasicProperties props = new AMQP.BasicProperties.Builder()
    .replyTo(replyQueue)
    .build();

// 로그 필터링 패턴
channel.exchangeDeclare("log_exchange", "direct");
String logQueue = "application_logs";
channel.queueDeclare(logQueue, true, false, false, null);
 
// 같은 큐를 여러 routing key로 바인딩
channel.queueBind(logQueue, "log_exchange", "error");
channel.queueBind(logQueue, "log_exchange", "warning");
channel.queueBind(logQueue, "log_exchange", "info");
 
// 하나의 컨슈머가 모든 로그 레벨 처리
DeliverCallback deliverCallback = (consumerTag, delivery) -> {
    String message = new String(delivery.getBody(), "UTF-8");
    String severity = delivery.getEnvelope().getRoutingKey();
    System.out.println("로그 [" + severity + "]: " + message);
};

// 주문 처리 큐가 웹/모바일/API 주문을 모두 받기
channel.exchangeDeclare("web_orders", "direct");
channel.exchangeDeclare("mobile_orders", "direct");
channel.exchangeDeclare("api_orders", "direct");
 
String orderQueue = "order_processing";
channel.queueDeclare(orderQueue, true, false, false, null);
 
// 같은 큐를 여러 Exchange에 바인딩
channel.queueBind(orderQueue, "web_orders", "new_order");
channel.queueBind(orderQueue, "mobile_orders", "new_order");
channel.queueBind(orderQueue, "api_orders", "new_order");

// 사용자 이벤트를 여러 서비스가 각각 처리
channel.exchangeDeclare("user_events", "direct");
 
// 여러 서비스별 큐 선언
channel.queueDeclare("email_service_queue", true, false, false, null);
channel.queueDeclare("analytics_queue", true, false, false, null);
channel.queueDeclare("notification_queue", true, false, false, null);
 
// 같은 Exchange에 여러 큐 바인딩
String routingKey = "user_signup";
channel.queueBind("email_service_queue", "user_events", routingKey);
channel.queueBind("analytics_queue", "user_events", routingKey);
channel.queueBind("notification_queue", "user_events", routingKey);
 
// 메시지 발행 시 모든 큐로 전달
channel.basicPublish("user_events", routingKey, null, 
    "새 사용자 가입: user123".getBytes());

@Configuration
public class RabbitConfig {
    @Bean
    public Declarables orderBindings(DirectExchange exchange, Queue queue) {
        return new Declarables(
            BindingBuilder.bind(queue).to(exchange).with("web.order"),
            BindingBuilder.bind(queue).to(exchange).with("mobile.order"),
            BindingBuilder.bind(queue).to(exchange).with("api.order")
        );
    }
}

// Round-Robin 동작 예시
// 3개 메시지, 3개 컨슈머
// 메시지1 → 컨슈머A ✅
// 메시지2 → 컨슈머B ✅  
// 메시지3 → 컨슈머C ✅
// 하지만 처리 중 장애 시 중복 처리 가능!

// 컨슈머 장애 시나리오
channel.basicConsume("order_queue", false, (consumerTag, delivery) -> {
    String order = new String(delivery.getBody(), "UTF-8");
    
    processOrder(order);  // ✅ 주문 처리 완료
    
    // 💥 여기서 컨슈머 크래시 → ACK 못 보냄
    channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
}, consumerTag -> {});
 
// 결과:
// 1. 주문은 이미 처리됨
// 2. ACK를 못 받은 RabbitMQ가 메시지를 다른 컨슈머에게 재전송
// 3. 같은 주문이 중복 처리됨 ❌

// 방법 1: 멱등성 구현
if (!orderRepository.exists(orderId)) {
    processOrder(order);
    channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
} else {
    // 이미 처리된 주문 - 그냥 ACK
    channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
}
 
// 방법 2: 트랜잭션 활용
@Transactional
public void handleMessage(Delivery delivery) {
    orderService.save(order);  // DB 작업과
    channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);  // ACK를 함께
}
 
// 방법 3: 중복 제거 테이블
String messageId = delivery.getProperties().getMessageId();
if (!processedMessageRepository.exists(messageId)) {
    processOrder(order);
    processedMessageRepository.save(messageId);
    channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
}