降级核心是任务自主让路:基于重试次数切换队列、Redis ZSET按等待时长降级、中间件结合运行时状态决策、Horizon多通道隔离与自动迁移。

并发任务在失败或积压时若不降级,高优任务会被卡死,系统吞吐直接崩。必须让任务“自己知道什么时候该让路”,而不是靠人工干预或全局限流。
基于重试次数自动切换队列
这是最直接、Laravel 原生支持度最高的降级方式。核心是利用 $this->attempts() 和显式分发到不同队列名,避免所有任务挤在同一个 queue 里排队。
- 在任务类中定义
protected $priorityLevel = 3,初始值对应最高优先级队列(如urgent_3) - 重写
failed()方法:当$this->attempts() >= 2 && $this->priorityLevel > 1时,执行$this->priorityLevel-- - 重新分发时用
dispatch($this)->onQueue("urgent_{$this->priorityLevel}"),确保目标队列已配置在config/queue.php中 - 不要在
failed()里做耗时操作(如 HTTP 请求、DB 查询),否则会拖慢失败处理流程,甚至导致失败队列本身堆积
用 Redis ZSET 实现等待时长驱动的降级
适用于对“时效性”敏感但又不能无限重试的任务,比如定时抓取、通知补发。它不依赖失败次数,而是看任务“躺平了多久”。
- 入队前,用
Redis::zadd('pending_tasks', now()->timestamp, json_encode([...]))记录任务元数据和初始优先级 - 写一个自定义 Artisan 命令(如
php artisan queue:degrade-by-age),定期扫描 ZSET 中 score 超过阈值(如 300 秒)的任务 - 扫描到后,从 ZSET 中
ZREM,再调用dispatch(new $jobClass(...))->onQueue('low_priority')重新入队 - 注意:ZSET 的 score 必须是整数时间戳,不能用
microtime(true),否则排序错乱;同时要加锁防止多个进程重复迁移同一任务
通过队列中间件拦截并条件性降级
适合需要结合运行时状态决策的场景,比如当前 CPU 使用率 > 80% 或数据库连接池接近耗尽时,主动把低优任务推后。
- 创建中间件
PriorityDowngradeMiddleware,在handle()中读取$job->attempts()和自定义字段(如$job->priority_level) - 检查是否满足降级条件:
if ($job->attempts() > 3 && $job->priority_level > 1),满足则构造新任务并dispatch()到低一级队列 - 关键点:必须调用
$job->delete()或$job->fail()显式终止当前任务,否则它会继续执行原逻辑 - 这个中间件只对声明了
middleware()方法的任务生效,别忘了在任务类里返回[new PriorityDowngradeMiddleware]
Horizon 多通道 + 自动迁移的组合策略
当业务线多、优先级维度复杂(比如 urgent / batch / seo / audit)时,单靠代码逻辑容易失控。Horizon 提供了可视化+通道隔离能力,是规模化降级的基础。
- 在
config/horizon.php中为每类任务定义独立supervisor,例如seo_worker只监听seo_low队列,并设置memory和sleep严格限制资源 - 配合 Horizon 的
tags功能,在任务中打标:$this->tags = ['seo', 'url:'.$url],便于失败后按标签重试或归档 - 降级不是“丢弃”,而是迁移:Horizon 支持用
redis-cli --raw lrange horizon:failed 0 -1 | grep ... | xargs -I{} redis-cli lrem horizon:failed 0 {}批量捞出特定 tag 的失败任务,再用脚本重分发到低优队列 - 最容易被忽略的是:Horizon 的
trim配置默认只保留最近 60 分钟失败记录,如果降级逻辑依赖历史失败数据做统计分析,得提前调大horizon.trim.failed


















