Message Queue메시지 큐

생산자(주문 서비스) → [메시지 큐] → 소비자(알림 서비스)
                     "주문 완료"     (비동기 처리)

생산자는 소비자의 처리 완료를 기다리지 않음
→ 빠른 응답, 느슨한 결합, 재시도 지원

import pika

# 생산자
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='orders')
channel.basic_publish(exchange='', routing_key='orders',
                       body='{"order_id": 123, "product": "apple"}')

# 소비자
def callback(ch, method, properties, body):
    print(f"주문 처리: {body}")
    ch.basic_ack(delivery_tag=method.delivery_tag)

channel.basic_consume(queue='orders', on_message_callback=callback)
channel.start_consuming()