Hyperf集群定时任务需用Redis分布式锁防重复执行,锁键按任务粒度命名并带动态标识,加锁须原子操作SET key value NX PX,解锁用Lua脚本校验owner,任务中非阻塞抢锁并try-finally确保释放。

Hyperf定时任务在集群部署时,多个实例会同时触发相同任务,导致重复执行(比如重复关单、重复发券)。用Redis分布式锁是最直接有效的管控手段——核心不是“加个锁就行”,而是锁的获取、续期、释放必须闭环且防误删。
锁键命名要带业务标识和唯一上下文
避免所有定时任务共用一个锁名(如task:lock),否则会相互阻塞。应按任务粒度区分:
- 订单关单任务 → lock:close_order:job
- 库存同步任务 → lock:sync_stock:job
- 若任务需参数隔离(如按商户ID执行),加上动态标识:lock:sync_stock:tenant_1001
命名统一用冒号分隔,层级清晰,便于排查和清理。
加锁必须原子设置 + 过期时间 + 唯一持有者标识
不能分两步:先SETNX再EXPIRE,中间宕机就死锁。正确方式是单命令完成:
- 使用SET key value NX PX 30000(30秒过期)
- value必须是当前进程/协程唯一标识,推荐uniqid('hyperf_', true)或UUID
- Hyperf中优先通过DI注入LockInterface,而非手动new RedisLock,确保连接复用和生命周期受控
解锁必须用Lua脚本校验后再删
直接DEL会误删别人持有的锁。务必用以下原子脚本:
if redis.call("GET", KEYS[1]) == ARGV[1] then return redis.call("DEL", KEYS[1]) else return 0 endHyperf自带的RedisLock::unlock()已内置该逻辑,只要传入当初加锁时返回的owner值即可。
定时任务里要捕获锁超时并优雅降级
定时任务不等锁,抢不到就跳过本次执行:
- 用tryLock($key, $ttl = 30, $waitMs = 0)(等待0毫秒,即非阻塞)
- 判断返回值:null表示未抢到,直接return;字符串表示抢到,记录owner用于后续解锁
- 务必包在try...finally里,确保无论成功失败都尝试释放锁
- 捕获LockTimeoutException,避免协程卡死


















