redis mysql实时库存

### 使用 Redis 和 MySQL 实现实时库存管理系统

#### 设计思路

为了实现实时库存管理，系统设计需考虑高并发场景下的性能优化以及数据一致性保障。MySQL 负责长期存储和事务处理，而 Redis 则用于缓存热数据并提供快速读写能力。

#### 数据库角色分配

- **MySQL**: 承担最终的数据持久化职责，确保交易记录不会丢失；支持复杂的查询操作。
- **Redis**: 提供高效的内存级访问速度，适合频繁变动的小型数据集如商品库存数量等临时状态保存[^1]。

#### 关键技术点

##### 库存更新机制

当有新的订单到来时：

1. 验证当前用户的购物车项是否存在足够的库存；
2. 如果验证通过，则尝试减少相应产品的可用库存数（先扣减 Redis 中的数量）；
3. 成功后立即向 MySQL 发起正式下单请求，并再次确认是否有足够库存完成此次购买行为；
4. 若因网络延迟等原因导致两次检查结果不一致，则回滚之前所做的更改以保持系统的准确性[^2]。

##### 同步策略

为了避免长时间断网或其他异常情况造成两套系统间的信息差异过大，建议定期执行批量同步任务来校正可能存在的偏差。具体做法是在低峰期由后台程序发起一次全面扫描对比动作，对于发现的不同之处做出适当调整直至完全匹配为止。

-- 更新 MySQL 表格中的库存信息
UPDATE products SET stock_quantity = ? WHERE id = ?

import redis
r = redis.Redis()

def update_stock(product_id, quantity_change):
    current_stock = int(r.get(f'stock:{product_id}') or 0)
    
    new_stock = max(0, current_stock + quantity_change)

    r.set(f'stock:{product_id}', str(new_stock))