Laravel高并发写入需防数据覆盖,推荐四种缓存锁方案:一、Cache::lock()内置锁,自动过期与释放;二、Redis SETNX手动加锁,需try-finally确保释放;三、LockableJob封装队列任务锁;四、数据库行锁+缓存标记混合防护。

如果您在 Laravel 应用中处理高并发场景下的数据写入操作,多个请求可能同时修改同一资源,导致数据不一致或覆盖。缓存锁是一种轻量、快速的分布式互斥机制,可借助 Redis 等缓存驱动实现原子性加锁与释放。以下是实现缓存锁防止并发写入的多种方法:
一、使用 Cache::lock() 方法(Laravel 7.0+ 内置锁)
该方法基于底层缓存驱动(如 Redis)提供原子性加锁能力,支持自动过期与阻塞等待,适用于大多数同步写入场景。
1、调用 Cache::lock() 创建一个具有唯一键名和过期时间的锁实例,例如 Cache::lock('order_processing_123', 10) 表示为订单 ID 123 创建一个 10 秒有效期的锁。
2、调用 ->get() 尝试获取锁,若成功则执行闭包内逻辑;若失败则返回 false,不执行后续操作。
3、在闭包中完成数据库更新、文件写入等关键操作,闭包结束后锁自动释放。
4、如需阻塞等待锁可用,可使用 ->block(5) 指定最多等待 5 秒,例如 Cache::lock('stock_update_456', 10)->block(5)->get(...)。
二、手动使用 Redis SETNX 命令实现锁
通过直接调用 Redis 的 SETNX(SET if Not eXists)命令设置带过期时间的键,确保仅首个请求能成功设值,从而获得锁控制权。
1、使用 Redis::setex() 或 Redis::set() 配合 NX 和 PX 选项设置锁键,例如 Redis::set('lock:payment_789', 'active', 'EX', 15, 'NX')。
2、检查返回值:若返回 1 表示加锁成功,可继续执行业务逻辑;若返回 null 或 0 则表示锁已被占用。
3、业务逻辑执行完毕后,必须调用 Redis::del('lock:payment_789') 主动删除锁键。
4、为防止程序异常中断导致死锁,应配合 try-finally 结构确保 del 操作必然执行。
三、使用 LockableJob 实现队列任务级锁
当并发写入由队列任务触发时,可将锁逻辑封装进任务类,利用 Laravel 的队列监听机制避免重复执行相同任务。
1、在任务类中实现 Illuminate\Bus\Queueable 和 Illuminate\Queue\SerializesModels trait,并添加 use Illuminate\Bus\Batchable; 若需批量控制。
2、在 handle() 方法开头调用 Cache::lock() 获取任务专属锁,键名建议包含任务参数哈希,例如 'job_lock_' . md5("process_user_{$this->userId}")。
3、加锁成功后执行数据库更新、状态变更等核心操作;失败则记录日志并退出任务。
4、无需手动释放锁,因 lock()->get() 的闭包执行完即自动释放,且队列任务天然具备单次执行语义。
四、基于数据库行锁结合缓存标记的混合方案
在无法依赖 Redis 或需更强一致性保障时,可先用数据库 SELECT FOR UPDATE 锁定记录,再用缓存标记标识“正在处理中”,双重防护降低竞争概率。
1、开启数据库事务并执行带 FOR UPDATE 的查询,例如 DB::transaction(function () { User::where('id', 101)->lockForUpdate()->first(); });。
2、查询成功后立即向缓存写入临时标记,键名为 'processing:user_101',值为当前时间戳,过期设为 30 秒。
3、后续请求先检查缓存标记是否存在,若存在则跳过处理或返回排队提示;否则继续走行锁流程。
4、事务提交后立即删除缓存标记,确保其他请求可及时感知处理结束。










