Laravel队列故障源于缺失重试策略与可观测性:需创建failed_jobs表并配置database失败驱动;启用Horizon实现可视化监控;高优任务通过$tries、failed()中addMilliseconds(100)及--sleep=0实现毫秒级重试。

线上Laravel应用的队列任务突然卡住、静默消失或反复失败,导致订单未发货、邮件未发送、数据未同步,业务链路中断却无告警——这不是偶发故障,而是队列系统缺乏重试策略与可观测性配置的必然结果。
确认失败任务是否被持久化记录
第一步不是重试,是确认系统是否具备记录能力。若failed_jobs表不存在,所有失败任务将直接丢弃,连排查依据都没有。
运行php artisan queue:failed-table生成迁移文件。
执行php artisan migrate创建failed_jobs表。该表必须存在,否则queue:failed命令始终返回空列表,【你看到的“没失败”很可能只是没记录】。
检查config/queue.php中'failed'配置项:驱动必须设为database-uuids或database,且database指向已配置的数据库连接名。
启用Horizon实现可视化监控
Horizon是Laravel官方提供的Redis队列监控方案,能实时显示队列吞吐、延迟、失败率和单个任务堆栈,比日志grep高效百倍。
方法一:安装并初始化
执行composer require laravel/horizon。
运行php artisan horizon:install生成配置与资源。
执行php artisan vendor:publish --provider="Laravel\Horizon\HorizonServiceProvider"发布配置文件。
方法二:关键配置校验
确保.env中QUEUE_CONNECTION=redis且REDIS_QUEUE值与Horizon配置中prefix一致。
在config/horizon.php中启用'waits' => true,否则长耗时任务超时不会触发告警。
启动服务:php artisan horizon,访问/horizon查看仪表盘。
配置高优任务毫秒级重试
支付回调、库存扣减等高优先级任务失败后,不能等默认5秒退避,必须100毫秒内重试——这需要组合三处配置。
Laravel Cloud(cloud.laravel.com)。此技能用于处理所有 Laravel Cloud 请求,包括搜索和读取数据。只要任务涉及 Laravel Cloud,即使用此技能。
第一步:任务类中声明重试参数
在Job类顶部引入use Illuminate\Queue\InteractsWithQueue;和use Illuminate\Queue\SerializesModels;。
设置public $tries = 3;,并删除$backoff数组——避免固定间隔干扰毫秒重试逻辑。
第二步:在failed()方法中主动重发
判断异常类型:if ($exception instanceof \Illuminate\Database\QueryException || $exception->getCode() === '08S01')(数据库连接中断)。
满足条件时调用self::dispatch($this)->delay(now()->addMilliseconds(100));,注意必须用self::dispatch()而非dispatch(),否则无法序列化当前实例。
第三步:监听器禁用休眠
启动高优队列专用进程:php artisan queue:work redis --queue=high --sleep=0 --max-jobs=1。【--sleep=0是关键,否则每轮处理后强制休眠1秒,毫秒重试失效】。
快速定位与重试失败任务
当Horizon或日志报警提示失败激增,需立即介入,而非等待自动重试。
① 查看全部失败任务:php artisan queue:failed。
② 按失败原因筛选:在输出中搜索"Serialization of closure"或"Connection refused",快速归类是代码问题还是基础设施问题。
③ 批量重试所有失败任务:php artisan queue:retry all。
④ 若某任务重试后仍失败,先php artisan queue:forget {id}移出失败队列,再检查对应Job类中failed()方法是否抛出新异常——这会导致重试循环卡死。
⑤ 清空失败记录仅用于测试环境:php artisan queue:flush,生产环境禁用。

















