Redis高并发高可用集群：百万级秒杀实战全攻略

slot = CRC16(key) & 16383  // 固定公式，客户端本地计算

javaString stock = jedis.get("stock");
if (stock > 0) {
    jedis.decr("stock");  // 10个请求同时读到stock=1，全部通过，库存变-9！
}

javajedis.multi();
jedis.decr("stock");
jedis.sadd("users", uid);
jedis.exec();  // 乐观锁导致大量请求失败，库存仍有剩余（少卖）

lua-- 防重复抢购 + 库存扣减 + 原子执行，一次网络往返搞定
local userid = KEYS[1]
local prodid = KEYS[2]
local qtkey = "sk:"..prodid..":qt"
local usrkey = "sk:"..prodid..":usr"

-- ① 防重复抢购
local exists = redis.call("sismember", usrkey, userid)
if tonumber(exists) == 1 then return 2 end

-- ② 库存不足
local num = redis.call("get", qtkey)
if tonumber(num) <= 0 then return 0 end

-- ③ 原子扣减 + 记录用户
redis.call("decr", qtkey)
redis.call("sadd", usrkey, userid)
return 1  -- 成功

用户请求
  │
  ▼
┌─────────────────┐
│ ① 网关层限流     │ ← Nginx/Sentinel：IP限流、频率拦截、黑白名单
├─────────────────┤
│ ② 应用层防重     │ ← JVM本地缓存 + Redis全局防重，拦截重复抢购
├─────────────────┤
│ ③ Redis核心层    │ ← 库存预热、分布式锁、Lua原子扣减、队列削峰
├─────────────────┤
│ ④ 异步消息层     │ ← Redis Stream/MQ：解耦秒杀与数据库落地
├─────────────────┤
│ ⑤ 数据库落地层   │ ← 低速平稳执行订单创建、库存落地、数据持久化
└─────────────────┘

用户请求
  → 限流模块过滤（令牌桶：每秒1000请求）
  → Lua脚本原子执行（防重 + 查库存 + 扣减）
  → 成功 → 写入Redis Stream：XADD orders * user_id 123 product_id 1001
  → 消费者组异步批量写入MySQL
  → 定时任务清理超时未支付订单并恢复库存

lualocal restored = redis.call('INCR', 'product:1001:stock')
redis.call('SREM', 'product:1001:users', user_id)