select_for_update() 并非万能,它仅在数据库事务内有效,且依赖支持行级锁的数据库(如 PostgreSQL、MySQL InnoDB),SQLite 不支持;必须配合 transaction.atomic() 使用,否则不加锁;需主键查询以避免锁升级,禁用非索引字段条件;无锁乐观更新(filter+update)更轻量高效。

为什么 select_for_update() 在库存扣减里不是万能的
它只能在数据库事务内起作用,且必须搭配支持行级锁的数据库(如 PostgreSQL、MySQL InnoDB),SQLite 直接报错。Django 默认的 ATOMIC_REQUESTS=True 或手动 transaction.atomic() 是前提,否则 select_for_update() 会被忽略——锁根本不会加。
- 没开事务时调用
select_for_update(),Django 不报错但也不加锁,多个请求同时读到相同库存值,超卖照常发生 - MySQL 下若查询条件未命中索引(比如用
name__icontains),会升级为表锁,吞吐量断崖下跌 - PostgreSQL 中若 WHERE 条件含非主键字段且无索引,同样可能锁住大量无关行
正确写法:事务 + 主键查询 + 显式锁
库存扣减必须锁定具体商品记录,最稳的方式是用主键查,再加锁。别用 filter(name=...),哪怕 name 加了唯一索引,Django ORM 生成的 SQL 仍可能不走索引优化路径。
from django.db import transaction <p>def deduct_stock(product_id: int, quantity: int) -> bool: try: with transaction.atomic(): product = Product.objects.select_for_update().get(id=product_id) if product.stock >= quantity: product.stock -= quantity product.save() return True return False except Product.DoesNotExist: return False
-
select_for_update()必须紧跟在get()或filter().first()前,不能写成Product.objects.get(...).select_for_update()—— 那样锁的是已查出的对象,不是数据库行 - MySQL 默认使用
SELECT ... FOR UPDATE,PostgreSQL 同样支持;若需跳过被锁行,加select_for_update(nowait=True),捕获DatabaseError - 不要在锁内做 HTTP 请求、发邮件等耗时操作,否则锁持有时间拉长,拖垮并发能力
并发测试时容易漏掉的关键点
本地用 threading 模拟并发,很可能测不出问题——因为单进程下 GIL 会让线程串行执行。真正要验证,得用多进程或压测工具(如 locust)打真实接口,且数据库连接池配置要匹配(比如 Django 的 CONN_MAX_AGE=0 避免连接复用干扰锁行为)。
快速生成专业的 Python 脚本和应用代码。一键创建完整项目结构,支持CLI、API、爬虫、Bot、Django等多种项目类型,包含完整的项目结构、配置文件、依赖管理、测试、README和文档。
- Django 测试用例里跑
TestCase默认每个 test 在独立事务中回滚,select_for_update()锁不会跨 test 生效,无法模拟真实竞争 - PostgreSQL 的
FOR UPDATE锁默认阻塞,MySQL 也是;但若两个请求锁同一行,后到者会等待,而非失败——得靠超时控制(select_for_update(timeout=5)),否则可能卡死 - 如果库存字段是
IntegerField,注意负数校验必须在应用层做,数据库不会阻止stock = -100的更新
比 select_for_update() 更轻量的替代方案
高并发场景下,纯数据库锁易成瓶颈。更常见的解法是把扣减逻辑下沉到 Redis + Lua 原子脚本,或用数据库的 UPDATE ... SET stock = stock - N WHERE stock >= N 返回影响行数判断是否成功——后者不需要锁,也不依赖事务,适合简单扣减。
立即学习“Python免费学习笔记(深入)”;
# 无锁乐观更新(MySQL/PostgreSQL)
updated = Product.objects.filter(
id=product_id,
stock__gte=quantity
).update(stock=F('stock') - quantity)
if updated == 0:
# 扣减失败:库存不足或已被他人扣完
raise ValueError("Insufficient stock")- 这种写法不加锁,性能更高,但业务逻辑复杂时(比如要记录流水、触发通知)就得额外查一次确认状态
-
F()表达式更新是原子的,但无法获取更新前的 stock 值,所以没法直接返回剩余库存,需额外refresh_from_db() - 如果扣减后要写日志或发消息,建议用信号(
post_save)或事务回调(transaction.on_commit()),避免在 update 语句里混入副作用
实际项目里,select_for_update() 不是默认首选,而是兜底手段。真正压测下来,往往发现无锁更新 + 重试机制更稳,也更容易横向扩展。

















