分布式消息队列双十一优惠活动

import pika

# 生产者
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='order_queue')

def send_order(order_data):
    channel.basic_publish(exchange='',
                          routing_key='order_queue',
                          body=order_data)
    print(f" [x] Sent {order_data}")

send_order('{"order_id": 12345, "product": "Laptop", "quantity": 1}')
connection.close()

# 消费者
def callback(ch, method, properties, body):
    print(f" [x] Received {body}")
    # 处理订单逻辑
    ch.basic_ack(delivery_tag=method.delivery_tag)

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

channel.queue_declare(queue='order_queue')
channel.basic_consume(queue='order_queue', on_message_callback=callback)

print(' [*] Waiting for orders. To exit press CTRL+C')
channel.start_consuming()