Laravel行锁与事务使用教程

在Laravel高并发场景下（如库存扣减、计数器更新），若多个请求同时读取相同数据并提交导致不一致，根本原因往往是未正确将行级锁`lockForUpdate`与数据库事务深度结合；本文系统揭示五大关键实践：必须在事务内使用`lockForUpdate`才能生效、需手动控制事务边界以支持条件判断、依赖唯一索引+事务锁定防止幻读、分页场景须重构查询再加锁、多表操作必须严格按固定顺序加锁规避死锁——每一步都直击生产环境数据竞争痛点，助你构建真正可靠、可落地的并发安全方案。

如果您在Laravel中处理高并发场景下的数据竞争问题，例如库存扣减或计数器更新，但发现多个请求同时读取相同初始值并提交导致数据不一致，则很可能是未正确结合lockForUpdate与事务进行行级锁定。以下是实现该机制的具体方法：

一、基础用法：在事务中调用lockForUpdate获取排他锁

lockForUpdate必须在数据库事务上下文中生效，它会锁定查询到的行，阻止其他事务对该行执行SELECT FOR UPDATE或LOCK IN SHARE MODE，直至当前事务提交或回滚。该锁仅作用于索引列匹配的行，若查询未命中索引则可能升级为表锁。

1、使用DB::transaction开启自动管理的事务闭包。

2、在闭包内通过Eloquent模型调用lockForUpdate()方法并执行first()或get()。

3、对返回的模型实例进行业务逻辑修改，如$goods->stock -= 1。

4、调用模型save()或直接使用DB::table()->where()->update()持久化变更。

5、闭包正常结束时事务自动提交，锁随之释放；若抛出异常则自动回滚并解锁。

二、手动控制事务生命周期配合lockForUpdate

当需要根据中间状态决定是否提交（例如先校验再更新），或需嵌入非Eloquent操作时，应显式控制事务边界。此时lockForUpdate仍依赖事务存在才能生效，且必须在beginTransaction之后、commit/rollback之前执行锁定查询。

1、调用DB::beginTransaction()显式开启事务。

2、执行带lockForUpdate的查询，例如$record = DB::table('orders')->where('id', $id)->lockForUpdate()->first()。

3、检查$record是否符合业务前提（如status为'pending'）。

4、若条件满足，执行UPDATE语句变更状态；否则调用DB::rollback()终止。

5、所有验证和写入成功后，调用DB::commit()提交；任一环节失败则立即DB::rollback()。

三、结合唯一索引与条件查询防止幻读

单纯使用lockForUpdate无法阻止新插入满足WHERE条件的记录（即幻读）。为确保“不存在才创建”类逻辑的原子性，需配合唯一索引与INSERT ... ON DUPLICATE KEY UPDATE，或在事务中先SELECT FOR UPDATE锁定范围，再执行INSERT。

1、确保目标字段（如order_no、sku）已建立唯一索引或主键约束。

2、在事务闭包中执行DB::table('products')->where('sku', $sku)->lockForUpdate()->first()。

3、若结果为空，执行DB::insert()插入新记录；若存在，则执行update操作。

4、整个过程包裹在DB::transaction()中，确保查、插/更操作不可分割。

关键提示：lockForUpdate不会阻塞普通SELECT，仅阻塞其他事务中的锁读操作；因此务必避免在事务外做前置非锁定查询后再进事务加锁，否则存在竞态窗口

四、分页场景下安全使用lockForUpdate

当需对分页结果中的某条记录加锁更新时，不能直接对paginate()结果调用lockForUpdate，因其底层SQL不含锁定子句。必须重构查询，使用toBase()->orderBy()->limit()->offset()生成原始Builder，再链式追加lockForUpdate。

1、构造原始查询：$builder = Product::query()->where('status', 1)->orderBy('id')。

2、获取当前页数据ID列表：$ids = $builder->clone()->take(10)->skip(20)->pluck('id')。

3、在新查询中使用whereIn('id', $ids)->lockForUpdate()->get()锁定这批记录。

4、遍历结果集执行业务更新，并统一在事务中完成。

注意：若分页参数来自用户输入，需严格校验offset和limit数值，防止恶意构造超大偏移量引发性能问题

五、多表关联更新时的锁顺序一致性

涉及多个表的事务中，若不同请求以不同顺序加锁（如A先锁users再锁orders，B先锁orders再锁users），极易引发死锁。必须全局约定固定加锁顺序，例如始终按表名字母序或业务主次序执行lockForUpdate。

1、确定本次事务涉及的所有表，按字母升序排列：比如orders、products、users。

2、依次执行DB::table('orders')->where(...)->lockForUpdate()->first()。

3、接着执行DB::table('products')->where(...)->lockForUpdate()->first()。

4、最后执行DB::table('users')->where(...)->lockForUpdate()->first()。

5、全部锁定成功后再进行跨表更新操作，确保所有事务遵循同一路径。

重要提醒：MySQL默认事务隔离级别为REPEATABLE READ，在此级别下lockForUpdate会对满足WHERE条件的间隙（gap）加锁，有效防止幻读；切换为READ COMMITTED时将失去间隙锁能力

本篇关于《Laravel行锁与事务使用教程》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于文章的相关知识，请关注golang学习网公众号！