企业级数据库云数据库秒杀

import redis
import time

# 连接Redis
r = redis.Redis(host='localhost', port=6379, db=0)

def seckill(product_id, user_id):
    # 使用Redis分布式锁防止超卖
    lock_key = f"lock:product:{product_id}"
    with r.lock(lock_key, blocking_timeout=10):
        # 检查库存
        stock_key = f"stock:product:{product_id}"
        stock = r.decr(stock_key)
        if stock >= 0:
            # 记录订单
            order_key = f"order:product:{product_id}:{user_id}"
            r.set(order_key, time.time())
            return True
        else:
            r.incr(stock_key)  # 库存不足，回滚
            return False

# 模拟秒杀请求
if __name__ == "__main__":
    product_id = "12345"
    user_id = "user123"
    if seckill(product_id, user_id):
        print("秒杀成功！")
    else:
        print("秒杀失败，库存不足。")