应采用轮询式多队列监听并配置权重、动态队列权重调度中间件、数据库时间戳补偿查询及最大等待时长告警四类方法防止低优先级任务饥饿。
如果您在 Laravel 中为报表、邮件等任务设置了低优先级队列，但发现这些任务长期无法被执行，甚至被高优先级任务完全压制，则可能是由于队列消费策略缺乏公平性保障。以下是防止低优先级任务永久饥饿的具体方法：
一、采用轮询式多队列监听并配置权重
通过强制 worker 按固定比例轮询多个队列，确保低优先级队列始终获得执行机会，避免因单一高优队列持续有任务而造成低优队列无限等待。
1、启动 queue:work 时显式指定多个队列名，并用英文逗号分隔：php artisan queue:work --queue=high,medium,low
2、为每个队列设置独立的 --sleep 值：使用自定义命令包装器或 Supervisor 配置，在 high 队列空闲时缩短 sleep（如 --sleep=1），在 low 队列轮到时适当延长（如 --sleep=3），但不设为 0 或过长
3、在 config/queue.php 的 redis 连接中启用 block_for 选项（Laravel 10+ 支持）：'block_for' => 1，使 pop 操作在无任务时最多阻塞 1 秒，提升轮询响应性
4、验证轮询行为：在各队列任务 handle() 方法中记录日志，检查 low 队列是否在每 N 次 high 队列消费后至少触发一次
二、引入动态队列权重调度中间件
通过中间件在任务入队前计算其“饥饿度”，对长时间未被执行的低优先级任务自动提升其队列权重，使其更易被 worker 拉取。
1、创建中间件类：php artisan make:queue:middleware AdjustQueueWeight
2、在 handle() 方法中读取任务的 attempts() 和入队时间（$job->payload['pushedAt']），若 low 队列任务等待超 300 秒且重试次数 ≥ 2，则调用 $job->onQueue('low_urgent')
3、在 config/queue.php 中新增连接 low_urgent，指向同一 Redis 数据库但使用不同 queue 名称（如 queues:low_urgent）
4、为 low_urgent 队列单独启动一个高响应 worker：php artisan queue:work --queue=low_urgent --sleep=0.5 --max-jobs=5
三、基于数据库 jobs 表的时间戳补偿查询
当使用 database 驱动时，可修改队列拉取逻辑，优先选择 queue 字段匹配且 reserved_at 为空、且 created_at 超过阈值的任务，从而打破 FIFO 绝对顺序，缓解饥饿。
1、运行迁移添加字段：php artisan make:migration add_hunger_score_to_jobs_table
2、在 migration 中为 jobs 表添加 hunger_score 列：$table->unsignedTinyInteger('hunger_score')->default(0)->index()
3、创建自定义 DatabaseQueue 类，继承 Illuminate\Queue\DatabaseQueue，重写 getJobForQueue() 方法，在 SQL 查询中加入 ORDER BY hunger_score DESC, created_at ASC
4、在任务分发前更新 hunger_score：使用 DB::table('jobs')->where('queue', 'low')->whereNull('reserved_at')->increment('hunger_score', 1)
四、设置低优先级任务最大等待时长并触发降级告警
为防止低优先级任务在队列中滞留过久，通过定时扫描机制识别超时任务，并主动干预其调度路径或通知运维人员。
1、新建 Artisan 命令：php artisan make:command CheckLowPriorityHunger
2、在 handle() 方法中执行查询：DB::table('jobs')->where('queue', 'low')->where('created_at', 'subMinutes(10))->count()
3、若数量 > 0，则触发告警：Log::warning('发现 low 队列中存在 ' . $count . ' 个超时 10 分钟的任务')
4、同时执行补偿操作：DB::table('jobs')->where('queue', 'low')->where('created_at', 'subMinutes(5))->update(['queue' => 'low_emergency'])
五、使用 Horizon 的平衡策略与队列分组隔离
Horizon 提供了可视化队列监控和高级调度策略，可通过配置 balance 策略与 process 分配，确保低优先级队列不被高优进程吞没。
1、在 config/horizon.php 的 environments 数组中，为 local/production 定义 supervisor：'supervisor-1' => ['connection' => 'redis', 'queue' => ['high'], 'balance' => 'simple', 'processes' => 10]
2、为低优先级单独定义 supervisor：'supervisor-low' => ['connection' => 'redis', 'queue' => ['low'], 'balance' => 'auto', 'processes' => 2, 'minProcesses' => 1, 'maxProcesses' => 4]
3、启用 memory-limit 和 timeout 限制：'timeout' => 60, 'memory' => 128，防止单个 high 任务长期占用 worker 进程
4、在 Horizon UI 中确认 low 队列的 Recent Jobs 列表中存在非空记录，且 Last Job 时间距当前不超过配置的 --sleep 值
