库存扣减并发安全
库存扣减是高并发场景下最容易出错的地方。数据库行锁、Redis Decr、Lua 脚本、事务消息，四种方案孰优孰劣？
一、库存扣减的核心挑战
- 1.1 超卖——库存变成负数
- 1.2 少卖——库存有剩余但无法下单
- 1.3 热点商品——大量请求竞争同一行数据
- 1.4 扣减与支付的时序
二、方案 1：数据库行锁
- 2.1
UPDATE stock SET num = num - ? WHERE id = ? AND num >= ? - 2.2 行锁的排队效果——天然串行化
- 2.3 热点商品性能——TPS 受限于行锁
- 2.4 优化——拆行为多行
三、方案 2：Redis Decr
- 3.1
DECR stock_key——原子操作 - 3.2 判断返回值 >= 0——不会超卖
- 3.3 问题——Redis 宕机，库存数据丢失
- 3.4 持久化方案——AOF + RDB
四、方案 3：Redis + Lua 原子脚本
- 4.1 Lua 脚本保证”判断 + 扣减”的原子性
- 4.2 完整的 Lua 脚本示例
- 4.3 与单纯 DECR 的对比
- 4.4 支持批量扣减
五、方案 4：RocketMQ 事务消息
- 5.1 先扣 Redis 库存 + 发 half 消息
- 5.2 本地事务创建订单
- 5.3 异步扣减数据库库存
- 5.4 回查机制保证一致性
六、方案对比总结
- 并发能力——Redis Lua > Redis Decr > RocketMQ > 行锁
- 一致性——行锁 > RocketMQ > Redis Lua > Redis Decr
- 综合推荐——Redis Lua + 数据库异步扣减
本博客所有文章除特别声明外，均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来源 谜思录！
相关推荐
2013-09-15
AQS 并发包原理
ReentrantLock、Semaphore、CountDownLatch、ReentrantReadWriteLock……它们底层都依赖 AQS。理解 AQS，就理解了 Java 并发工具的设计灵魂。 一、AQS 是什么 1.1 AbstractQueuedSynchronizer——基于 FIFO 等待队列的同步框架 1.2 设计模式：模板方法模式 1.3 核心三要素：state 状态、CLH 队列、Condition 条件队列 二、state——同步状态的原子管理 2.1 volatile int state + CAS 的原子操作 2.2 getState() /...
2014-01-11
线程池参数配置指南
Executors.newFixedThreadPool() 阿里规范不让用，newCachedThreadPool() 可能导致 OOM。那么线程池到底该怎么配？本文从源码到生产实践，给出计算公式和配置模板。 一、线程池的 8 个参数 1.1 corePoolSize——核心线程数 1.2 maximumPoolSize——最大线程数 1.3 keepAliveTime——空闲线程存活时间 1.4 unit——时间单位 1.5 workQueue——工作队列 1.6 threadFactory——线程工厂 1.7 handler——拒绝策略 1.8 参数之间的协作关系——任务提交后...
2013-07-13
volatile 可见性与有序性原理
volatile 是 Java 并发编程的”轻量级”同步机制。它真的轻吗？从 CPU 缓存一致性到指令重排序，一篇文章说清楚。 一、为什么要理解 JMM 1.1 物理机缓存模型——CPU → L1/L2/L3 Cache → 主存 1.2 缓存一致性问题——MESI 协议简介 1.3 Java 内存模型（JMM）抽象——主内存 vs 工作内存 1.4 JMM 解决什么——原子性、可见性、有序性 二、volatile 的可见性 2.1 写 volatile 变量——立即刷回主内存 2.2 读 volatile 变量——强制从主内存读取 2.3 一个可见性问题的代码...
2020-03-15
跨库查询方案对比
没分库分表前一个 JOIN 搞定的事，分完后变得异常复杂。跨库查询的 6 种方案，各有千秋。 一、跨库查询的困境 1.1 分库分表前——SELECT * FROM order JOIN user ON ... 1.2 分库分表后——订单和用户在不同库 1.3 问题的本质——数据分散后的聚合查询 二、方案 1：字段冗余 2.1 把频繁查询的字段冗余到订单表——用户名、手机号 2.2 更新时的数据一致性——MQ 异步更新 2.3 优缺点——查询快但数据一致性问题 三、方案 2：ES 异构同步 3.1 Canal 监听 binlog → 同步到 ES 3.2 ES 的搜索和聚合能力替代...
2022-10-15
并发工具类对比与实践
一个接口需要调用 3 个微服务，串行 300ms。用 CompletableFuture 并行调用只需 120ms。 一、场景描述 1.1 商品详情页——需要商品信息、库存、评价、推荐 1.2 串行调用——逐个等待，时间累加 1.3 并行调用的收益——总时间 = max(每个调用的时间) 二、CountDownLatch 2.1 原理——计数器，主线程等待所有子任务完成 2.2 代码示例——3 个线程并行获取数据 2.3 缺点——无法获取返回值、只能使用一次 三、CyclicBarrier 3.1 原理——所有线程到达 barrier 后一起继续 3.2 与 Count...
2013-11-16
ThreadLocal 内存泄露与最佳实践
几乎所有 Java 项目都在用 ThreadLocal 存储上下文信息，但很多人不知道它可能造成内存泄漏——而且是在你”原本以为不会”的场景下。 一、ThreadLocal 的设计初衷 1.1 线程隔离的数据存储——每个线程一份独立副本 1.2 典型使用场景——数据库连接、Session、事务上下文、链路追踪 TraceId 二、ThreadLocal 的底层结构 2.1 Thread → ThreadLocalMap → Entry（弱引用包装的 ThreadLocal 作为 key） 2.2 ThreadLocalMap 的数据结构——线性探测法解决哈希冲突 2.3 Entry...