PHP Laravel 队列怎样避免任务重复执行

Laravel 队列出现“同一订单被处理两次”时，先不要急着给 Job 加一个模糊的全局锁：重复可能发生在任务还没执行就被重复派发，也可能发生在两个 worker 同时修改同一个业务对象。前一种适合用 ShouldBeUnique 约束入队，后一种适合用 WithoutOverlapping 保护执行中的资源。

官方文档：https://laravel.com/docs/queues

最稳妥的组合是：先用稳定的业务键做入队去重，再按共享资源的并发边界加执行锁；如果锁竞争会释放任务，还要同步设置尝试次数、等待时间和锁过期时间。

先分清排队重复和执行重叠

例如订单 1001 被支付回调重复触发两次。两个 Job 都进入队列，属于“重复入队”；如果两个 worker 已经同时拿到任务并修改库存，属于“执行重叠”。它们不是同一个问题：唯一 Job 主要阻止同一业务键再次 dispatch，执行中间件则控制已经进入 worker 的任务如何竞争资源。

因此，先问两个问题：相同业务键的任务是否根本不应该同时出现在队列里？还是允许排队，但不允许同时修改同一个资源？答案决定了锁放在 dispatch 边界还是 worker 边界。

同一业务对象只保留一个待处理任务

当“同一订单只需要一份待处理同步任务”时，让 Job 实现 ShouldBeUnique，并把订单号写进 uniqueId。Laravel 会尝试用唯一键取得缓存锁；已有相同锁时，新的任务不会再次入队。

orderId;
    }

    public function handle(): void
    {
        // 这里执行订单同步；真实项目应继续使用业务幂等保护。
    }
}

这段策略解决的是“同一订单的任务不要重复排队”，不是所有重复写入的万能替代品。唯一锁需要使用支持原子锁的缓存驱动；多台 Web 主机或 worker 运行时，应让它们连接同一个中心缓存。若只希望锁在任务真正开始处理前释放，可改用 ShouldBeUniqueUntilProcessing，但这会允许后续任务在前一个任务处理期间进入队列。

已入队任务再用 WithoutOverlapping 串行化

另一种场景是两条任务都合理进入队列，但它们不能同时更新同一份余额或同一个供应商状态。这时用 WithoutOverlapping，锁键应对应被保护的资源，而不是随手写成 Job 类名。

accountId))
                // 锁竞争时延迟 30 秒再取，避免忙等。
                ->releaseAfter(30)
                // 异常退出后最多保留 180 秒，避免永久占锁。
                ->expireAfter(180),
        ];
    }

    public function handle(): void
    {
        // 读取并更新账户余额；锁覆盖完整的临界区。
    }
}

如果重叠任务没有任何业务价值，可以把 releaseAfter(30) 换成 dontRelease()，让拿不到锁的任务直接删除。不过要确认丢弃任务不会造成账务缺口。默认情况下，不同 Job 类即便使用同一个键也可能各自竞争不同的锁；需要跨类互斥时，再调用 shared()，并统一键的命名规则。

重叠后重试和锁过期要配套

WithoutOverlapping 释放任务回队列时，会消耗一次尝试次数。默认尝试次数太小，会出现“只是锁竞争，却很快被标记失败”的现象。因此，tries、releaseAfter 和 expireAfter 要按最长正常处理时间一起估算。

可以用下面的规则做初始配置：

• releaseAfter 略大于一次临界区的常见耗时，减少无意义的反复取锁。
• tries 覆盖可能的锁竞争次数，并为真正的异常留出重试空间。
• expireAfter 应大于正常处理时长，但不能大到让异常锁长期阻塞同一资源。

锁只能减少并发冲突，不能代替业务幂等。支付、扣库存、写账单等关键操作仍应使用唯一约束、状态条件更新或幂等记录，防止 worker 在超时、网络重试和人工补偿下重复落库。

发布前按场景选择策略

最后检查三件事：唯一键是否真的代表业务对象，所有 worker 是否共享支持原子锁的缓存，失败与超时时是否仍有数据库层面的幂等兜底。这样才能把“任务重复执行”拆成可控的入队、执行和落库三层问题。

常见问题

ShouldBeUnique 能保证数据库绝对不会重复写入吗？

不能。它主要约束任务派发和唯一锁生命周期；数据库写入仍可能受到重试、超时和人工补偿影响，应继续使用唯一约束或条件更新。

ShouldBeUnique 和 WithoutOverlapping 可以一起用吗？

可以，但要先说明两把锁各自保护什么：前者控制相同业务键是否重复入队，后者控制 worker 执行时的资源并发。键名和过期时间不要含糊。

为什么加了 WithoutOverlapping 后任务反而失败更多？

常见原因是锁竞争释放任务消耗了尝试次数，而 tries 没有按等待次数上调。先结合临界区耗时调整 releaseAfter 和 tries，再检查 expireAfter 是否覆盖异常退出场景。