分布式事务双11促销活动

import pika

def create_order(order_id, product_id, quantity):
    # 创建订单逻辑
    print(f"Order created: {order_id}")
    
    # 发送消息到库存服务
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue='inventory_update')
    channel.basic_publish(exchange='',
                          routing_key='inventory_update',
                          body=f"{product_id},{quantity}")
    connection.close()

create_order(12345, 'P001', 2)

import pika

def update_inventory(ch, method, properties, body):
    product_id, quantity = body.decode().split(',')
    # 更新库存逻辑
    print(f"Inventory updated for product {product_id}: -{quantity}")

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='inventory_update')
channel.basic_consume(queue='inventory_update', on_message_callback=update_inventory, auto_ack=True)
print('Inventory service waiting for messages...')
channel.start_consuming()