laravel horizon 中 high 队列被 default 延迟执行,需通过五种方式实现权重控制:一、supervisor 显式分配进程数;二、启用 auto 平衡策略并设阈值;三、用 redis sorted set 手动注入 score 调度;四、多 redis 连接隔离;五、基于 metrics api 动态调节权重。

如果您在 Laravel 应用中使用 Horizon 管理 Redis 队列,但发现 high 队列任务仍被 default 队列任务延迟执行,则可能是由于队列权重未正确分配或 Horizon 的负载均衡策略未适配分级需求。以下是实现队列权重控制的多种方法:
一、通过 Horizon Supervisor 配置显式进程权重
Horizon 不支持传统数值型优先级(如 priority=10),但可通过为不同队列分配差异化的 worker 进程数,实现事实上的“权重”效果:进程数越多,单位时间处理该队列任务的能力越强,等效于更高权重。
1、编辑 config/horizon.php,在 environments 配置块中为各环境定义带权重的 supervisor:
2、为 high 队列配置 6 个进程,default 队列配置 2 个进程,emails 队列配置 1 个进程:
3、确保 'balance' 设置为 false,禁用自动均衡,防止 Horizon 动态重分配进程覆盖手动权重设定:
4、运行 php artisan config:clear 清除配置缓存,使修改生效。
二、启用 auto 平衡策略并配合队列长度阈值
Horizon 的 auto 平衡模式会根据各队列 pending 任务数量动态调整 worker 分配比例,其本质是按实时负载反向赋予权重——任务积压越多的队列,获得的 worker 资源权重越高。
1、在 config/horizon.php 中将 balance 设为 'auto':
2、为每个 supervisor 明确设置 min_processes 和 max_processes,限定权重浮动范围:
3、通过 Horizon Web 控制台或 redis-cli 持续观察 llen queues:high 和 llen queues:default,确认 auto 策略是否响应积压变化:
4、若发现某队列长期积压但未获额外进程,检查该队列是否被其他 supervisor 配置意外排除,或是否存在失败任务阻塞队列头。
三、结合 Redis Sorted Set 手动注入 score 实现调度偏移
虽然 Laravel Redis 驱动默认不利用 zset 的 score 字段控制优先级,但可绕过框架底层,直接向 Redis 队列写入带高分值的任务,再通过自定义 worker 按 score 逆序拉取,从而实现细粒度权重干预。
1、在 dispatch 前,使用 Redis 命令将任务以高 score 写入 zset(例如 score=999):
PHP中文网提供Laravel 13.2.0版本下载,Laravel框架 是基于 PHP 8.3+ 的高性能框架,官方推荐通过 Composer 安装。它内置 AI SDK、JSON:API Resources 及原生向量搜索,支持属性驱动开发与队列路由,大幅提升开发效率。相比旧版,13.2.0 优化了缓存 TTL 管理与实时通信,无需 Redis 即可横向扩展。作为现代 Web 开发首选,它兼顾安全与极速体验,助您快速构建企业级应用。
2、编写专用命令类 App\Console\Commands\WeightedQueueWork,覆盖默认 queue:work 行为,使用 ZREVRANGEBYSCORE 读取高分任务:
3、在 Supervisor 中单独启动该命令监听 high 队列:
4、确保该 worker 不与标准 horizon 进程共用同一 Redis 连接池,避免连接竞争导致 score 读取错乱。
四、使用多连接隔离 + 自定义队列前缀模拟权重层级
通过为不同权重队列分配独立 Redis 数据库或键前缀,再配合不同连接配置,可彻底隔离调度逻辑,规避单一连接下队列混排带来的权重稀释问题。
1、在 config/database.php 中新增两个 Redis 连接:
2、在 .env 中定义 QUEUE_CONNECTION_HIGH=redis-high 和 QUEUE_CONNECTION_DEFAULT=redis-default:
3、修改任务分发逻辑,对 high 权重任务显式指定连接:
4、在 config/horizon.php 中分别为 redis-high 和 redis-default 连接定义独立 supervisor,并分配对应进程数,形成物理级权重隔离。
五、基于 Horizon Metrics API 动态调节权重
Horizon 提供 /horizon/api/metrics 接口返回各队列的 pending、completed、failed 等实时指标。可编写定时脚本采集数据,当 high 队列 pending 数超过阈值时,自动触发 Supervisor 重启指令,加载更高进程数的配置。
1、创建命令类 App\Console\Commands\AdjustQueueWeight,调用 HorizonMetricsRepository 获取队列状态:
2、当 $metrics['queues']['high']['pending'] > 50 时,生成临时 config/horizon.php 权重增强版并覆盖原配置:
3、执行 php artisan horizon:terminate 后立即运行 php artisan horizon 启动新权重配置:
4、将该命令加入 Laravel Task Scheduling,每 30 秒检查一次,确保权重响应实时业务压力:注意:此操作需确保 config/horizon.php 文件权限允许运行时写入,且不能与人工编辑冲突。










