核心思路是将补偿逻辑前置为可调度、可中断、可确认的独立业务服务,失败时登记待办而非重试,通过状态机驱动分阶段执行,并与前端协同实现无感降级。

核心思路不是“等失败再补”,而是把补偿逻辑前置为可调度、可中断、可确认的业务动作,让扣减失败不卡主线程,也不阻塞用户。
把补偿器变成独立可执行的业务服务
不要把补偿逻辑写在订单创建方法里,而是封装成带业务ID、幂等键、超时控制的补偿服务。例如:
– 创建 InventoryCompensator 类,提供 cancelReservation(orderId) 方法;
– 内部自动查当前订单真实状态(是否已支付、库存是否已扣、是否已发货);
– 仅当“已冻结未支付”时才释放库存,避免误操作;
– 所有调用走异步消息或延迟任务队列(如 Kafka + 延迟topic 或 Redis ZSET 定时扫描)。
扣减失败时不重试,直接登记补偿待办
当库存扣减因乐观锁冲突、Redis Lua 脚本返回 false、或分布式事务分支失败时,立刻终止当前流程,转而:
– 记录一条补偿任务(含 order_id、product_id、失败时间、原始请求快照);
– 状态设为 pending,并写入专用补偿任务表或事件表;
– 向用户返回“订单已受理,正在处理中”,前端展示「处理中」状态而非报错;
– 不占用主线程资源,不触发数据库重连或连接池争抢。
用状态机驱动补偿执行节奏
补偿不是“马上重做”,而是按业务语义分阶段推进:
– 初始失败 → 进入 waiting 状态,10秒后自动触发首次校验;
– 若发现订单已支付成功,则跳过补偿,升为 completed;
– 若仍为预占未支付,则调用反向接口释放库存,并标记为 compensated;
– 全程记录状态变更日志,支持人工介入与审计追溯;
– 状态迁移全部通过数据库 update where version 实现,天然具备并发安全。
前端+补偿协同实现“无感降级”
大促峰值下主动限流或降级时,可临时将扣减操作转为“预占+异步确认”模式:
– 用户下单只写入轻量预占记录(Redis Hash + 过期时间),不碰主库;
– 补偿器定时扫描过期未确认的预占单,自动释放;
– 前端轮询订单状态接口,返回 status=reserved 或 status=confirmed,体验平滑;
– 即使补偿器短时积压,也不会导致接口超时或线程阻塞,系统保持响应能力。

















