需协同配置失败重试策略与队列优先级机制：一、用多队列分流，如 urgent_failed；二、任务类中动态设重试参数并写入 priority_failed_jobs 表；三、Horizon 中为不同失败队列配置权重 supervisor；四、Redis ZSET 实时排序；五、中间件按异常类型决策优先级。
如果您在 Laravel 应用中运行队列任务时遇到部分失败任务需优先重试，而其他低优先级失败任务可延后处理，则需将失败重试策略与队列优先级机制协同配置。以下是实现该目标的具体方法：
一、通过多队列名称实现失败任务的优先级分流
利用 Laravel 队列驱动支持多队列名称的特性，可将高优先级失败任务推送到专用队列（如 urgent_failed），再单独启动高优先级 worker 消费该队列，从而实现失败任务按优先级调度。
1、在 config/queue.php 中确保 redis 或 database 驱动已启用 retry_after 配置，并确认 failed_jobs 表已创建（执行 php artisan queue:failed-table && php artisan migrate）。
2、定义一个专门用于重试高优先级失败任务的 Artisan 命令类，例如 app/Console/Commands/RetryUrgentFailedJobs.php，其 handle 方法中调用 Queue::connection()->getJob() 手动拉取 failed_jobs 表中 priority 字段为 'high' 的记录。
3、修改 failed_jobs 表结构，新增 priority 字段（TINYINT，默认值 0，1=high，0=normal），并在任务分发前通过 DB::table('failed_jobs')->where('id', $id)->update(['priority' => 1]) 标记关键失败任务。
4、启动独立 worker 处理高优失败队列：php artisan queue:work --queue=urgent_failed --tries=3 --timeout=120。
二、在任务类中动态设置重试参数与优先级标记
每个任务实例可通过 $tries、$backoff 和自定义属性控制自身失败行为，并在 failed() 方法中主动写入带优先级标识的失败记录，绕过默认 failed_jobs 存储逻辑，转存至带索引的 priority_failed_jobs 表。
1、运行迁移命令创建 priority_failed_jobs 表：php artisan make:migration create_priority_failed_jobs_table。
2、在迁移文件中定义字段：id、job_id、connection、queue、payload、exception、failed_at、priority（ENUM('high','medium','low')）。
3、在任务类中重写 failed() 方法：当捕获到数据库连接异常或 HTTP 超时等临时性错误时，显式插入 priority='high' 记录，并跳过父类默认日志写入。
4、编写专用命令 php artisan queue:retry-priority --priority=high，该命令仅查询 priority_failed_jobs 表中 priority='high' 的任务并调用 Queue::pushRaw() 重新入队到 urgent 队列。
三、使用 Horizon 配置失败队列的优先级消费顺序
Horizon 提供可视化界面与高级队列管理能力，支持为不同失败队列绑定不同权重的 supervisor，使 high-priority-failed 队列获得更高 CPU 时间片和更快轮询频率。
1、安装 Horizon 并发布配置：composer require laravel/horizon && php artisan horizon:install。
2、编辑 config/horizon.php，在 supervisors 配置块中定义两个 supervisor：
Laravel Cloud（cloud.laravel.com）。此技能用于处理所有 Laravel Cloud 请求，包括搜索和读取数据。只要任务涉及 Laravel Cloud，即使用此技能。
3、第一个 supervisor 名为 high-priority-worker，配置 queues=['urgent_failed']，minProcesses=3，maxProcesses=5，balance='simple'；
4、第二个 supervisor 名为 normal-failed-worker，配置 queues=['default_failed']，minProcesses=1，balance='auto'；
5、Horizon 启动后将自动按 supervisor 定义顺序拉取任务，urgent_failed 中的任务始终先于 default_failed 被处理。
四、基于 Redis Sorted Set 实现失败任务的实时优先级排序
放弃默认 failed_jobs 表，改用 Redis 的 ZSET 结构存储失败任务，以 score 字段表示优先级权重（如 HTTP 超时任务 score=1000，验证失败任务 score=10），worker 按 score 降序 zrevrange 获取待重试任务。
1、在 App\Jobs\FailedJobManager 类中封装 pushToZset($job, $priorityScore) 方法，使用 Redis::zAdd('failed_jobs_zset', $priorityScore, json_encode($job)) 写入。
2、编写自定义 worker 命令 php artisan queue:work-zset，其核心逻辑为：$jobData = Redis::zRevRange('failed_jobs_zset', 0, 0, ['WITHSCORES' => true])，取出 score 最高的一条。
3、执行重试后调用 Redis::zRem('failed_jobs_zset', $jobData[0]) 移除已处理项；若重试失败则调用 Redis::zIncrBy('failed_jobs_zset', 50, $jobData[0]) 提升下次重试权重。
4、此方案完全规避数据库 I/O 瓶颈，适用于每秒失败任务超百条的高并发场景。
五、通过中间件注入失败任务优先级决策逻辑
在队列中间件中拦截任务执行结果，根据异常类型动态决定是否立即重试、延迟重试或标记为高优失败，避免所有失败任务统一走默认重试路径。
1、创建中间件 app/Queue/Middleware/RetryByExceptionType.php，实现 handle() 方法。
2、在 handle() 中判断 $exception 实例：若为 Illuminate\Database\QueryException 或 GuzzleHttp\Exception\ConnectException，则调用 $job->release(10) 并 向 Redis 发送 high_priority_retry:{job_id} key，过期时间设为 60 秒。
3、另起一个轻量级监听命令 php artisan listen:high-priority-retry，持续执行 Redis::keys('high_priority_retry:*') 并对匹配 key 调用 dispatchSync() 强制同步重试。
4、在 config/queue.php 的 worker 配置中为对应连接添加 'middleware' => [App\Queue\Middleware\RetryByExceptionType::class]。
