多种网络互通秒杀

from flask import Flask, request, jsonify
import redis
import time

app = Flask(__name__)
redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)

@app.route('/seckill', methods=['POST'])
def seckill():
    user_id = request.json.get('user_id')
    product_id = request.json.get('product_id')
    
    # 使用Redis实现分布式锁
    lock_key = f"lock:product:{product_id}"
    with redis_client.lock(lock_key, timeout=10):
        stock = redis_client.decr(f"stock:product:{product_id}")
        if stock >= 0:
            # 记录订单并异步处理
            record_order(user_id, product_id)
            return jsonify({"status": "success", "message": "秒杀成功"})
        else:
            redis_client.incr(f"stock:product:{product_id}")  # 库存回滚
            return jsonify({"status": "fail", "message": "库存不足"})

def record_order(user_id, product_id):
    # 模拟异步记录订单
    time.sleep(1)
    print(f"User {user_id} ordered product {product_id}")

if __name__ == '__main__':
    app.run(debug=True, host='0.0.0.0', port=5000)