Laravel中可通过五种方式实现队列任务优先级动态降级：一、基于重试次数降级；二、自定义中间件策略；三、Redis ZSET按等待时长降级；四、数据库状态表驱动衰减；五、结合Horizon多通道分流与自动迁移。
在 Laravel 应用中，当高优先级队列任务因持续失败或资源争抢而长期积压时，可能阻塞中低优先级任务的执行。为保障系统整体响应性与任务吞吐均衡，需构建一种依据失败次数、重试延迟或等待时长动态降低任务优先级的机制。以下是实现该机制的具体方法：
一、基于任务重试次数的优先级降级
利用 Laravel 队列任务的 $tries 和 $maxExceptions 属性，结合自定义异常捕获逻辑，在每次失败后将任务重新分发至更低优先级的连接或队列名中。
1、在任务类中定义初始优先级标识及降级阈值，例如 protected $priorityLevel = 3;（3 为最高）。
2、重写 failed() 方法，在其中判断当前失败次数是否达到降级条件：if ($this->attempts() >= 2 && $this->priorityLevel > 1) { $this->priorityLevel--; }。
3、调用 dispatch($this->payload)->onConnection('redis')->onQueue("low_priority_{$this->priorityLevel}"); 将任务重新投递至对应优先级队列。
4、确保 config/queue.php 中为不同优先级配置独立的 queue 名称，如 high_priority_3、medium_priority_2、low_priority_1，并按顺序启动监听进程。
二、通过自定义中间件注入动态优先级策略
创建队列中间件，在任务执行前检查其元数据，若满足降级规则则修改其目标队列，并跳过本次执行，转而以新优先级重新入队。
1、运行 php artisan make:queue:middleware PriorityDowngradeMiddleware 生成中间件文件。
2、在 handle() 方法中读取任务的 attempts() 和自定义字段 priority_level，使用 if ($job->attempts() > 3 && $job->priority_level > 1) 判断是否触发降级。
3、构造新任务实例，设置 priority_level = $job->priority_level - 1，并调用 dispatch(new $job->job)(...)->onQueue("queue_p{$job->priority_level - 1}");。
4、对需启用该机制的任务类，在 middleware() 方法中返回 [new PriorityDowngradeMiddleware]。
三、借助 Redis Sorted Set 实现基于等待时长的自动降级
将待执行任务元数据存入 Redis 的有序集合（ZSET），以入队时间戳为 score，定时扫描超时未被消费的任务，并将其迁移至低优先级队列。
1、在任务推入队列前，使用 Redis::zadd('pending_tasks', now()->timestamp, json_encode([...])) 记录任务原始信息与初始优先级。
2、编写 Artisan 命令 php artisan queue:downgrade-stale，在其中执行 Redis::zrangebyscore('pending_tasks', '-inf', now()->subMinutes(5)->timestamp) 获取等待超 5 分钟的任务。
3、对每个匹配任务，解析 JSON 数据，将其 priority_level 减 1，然后调用 Bus::dispatch(...)->onQueue("p".($level-1)) 重新投递。
4、在 app/Console/Kernel.php 的 schedulable 中添加 $schedule->command('queue:downgrade-stale')->everyFiveMinutes();。
四、使用数据库状态表驱动的优先级衰减模型
在数据库中建立 job_priorities 表，记录任务 ID、当前优先级、最后失败时间、降级次数等字段，通过 Eloquent 模型控制优先级变化节奏。
1、执行迁移命令创建表：包含 job_id（唯一索引）、current_level、last_failed_at、downgrade_count 字段。
2、在任务的 failed() 方法中，先查询或新建对应记录：$record = JobPriority::firstOrCreate(['job_id' => $this->jobId()], [...]);。
3、更新记录：$record->decrement('current_level'); $record->increment('downgrade_count'); $record->last_failed_at = now(); $record->save();。
4、根据 $record->current_level 值决定重投队列名称，例如 dispatch($this)->onQueue("p{$record->current_level}");，注意确保 current_level 不低于 1。
五、结合 Horizon 配置实现多通道优先级分流与自动迁移
利用 Laravel Horizon 提供的标签、监控与队列配置能力，在仪表盘中可视化各优先级队列负载，并通过 Horizon 的事件监听器实现失败任务的跨队列迁移。
1、在 config/horizon.php 中定义多个环境配置，如 'production' => ['supervisor-1' => ['queue' => ['high_priority'], 'balance' => 'simple']]，并为每组分配独立 queue 名称。
2、注册 Horizon 事件监听器，在 Horizon::looping() 中定期检查 HighPriorityJob::failed() 数量，当单队列失败率超过 15% 时触发迁移逻辑。
3、使用 Redis::lpop("queues:high_priority") 获取原始任务 payload，反序列化后修改 queue 字段为 medium_priority，再 Redis::rpush("queues:medium_priority", $payload)。
4、确保所有 supervisor 进程均启用 --delay=1 参数，使中低优先级队列获得更频繁的轮询机会，提升降级后任务的实际执行速度。
