Laravel 中可通过四种方式实现队列优先级:一、Redis 驱动的 tagged 队列,支持标签筛选与监控;二、自定义队列名模拟标签,兼容 database/sqs 等驱动;三、使用中间件动态拦截并调整任务执行逻辑;四、结合 Horizon 实现标签可视化管理与运维操作。

如果您在 Laravel 应用中需要对不同任务按紧急程度或业务重要性进行区分处理,则可通过队列标签(Queue Tags)机制实现优先级分类。以下是实现此目标的多种方法:
一、使用 Redis 驱动的 tagged 队列
Laravel 原生支持 Redis 驱动下的队列标签功能,允许为任务打上一个或多个标签,便于后续筛选与监控。该方式依赖 Redis 的集合操作,适用于高并发且需实时区分优先级的场景。
1、确保配置文件 config/queue.php 中默认连接已设为 redis,且 default 项指向 redis 连接。
2、在分发任务时调用 onQueue() 并结合 withTags() 方法,例如:dispatch(new SendNotification)->onQueue('notifications')->withTags(['high', 'urgent'])。
3、启动监听时指定标签过滤,运行命令:php artisan queue:work --tag=high,此时仅消费带 high 标签的任务。
二、自定义队列名称模拟标签逻辑
当使用不支持原生标签的驱动(如 database 或 sqs)时,可通过命名规范将优先级嵌入队列名称,再配合多 worker 实例实现隔离消费。该方式无需额外扩展包,兼容性强。
1、定义多个队列名称,例如:critical、normal、low,分别对应不同优先级。
2、分发任务时显式指定队列名:dispatch(new ProcessOrder)->onQueue('critical')。
3、为每个优先级启动独立 worker 进程,例如:php artisan queue:work --queue=critical --sleep=1 和 php artisan queue:work --queue=normal --sleep=3,通过 --sleep 控制轮询间隔以体现调度权重。
三、基于中间件的运行时优先级拦截
利用 Laravel 队列中间件机制,在任务执行前动态判断其标签并决定是否跳过、延迟或重投。该方式灵活,适合需结合业务规则动态调整优先级的场景。
1、创建中间件:php artisan make:middleware CheckQueuePriority。
2、在中间件 handle() 方法中读取任务的 $job->tags(),若包含 maintenance 且当前系统处于维护模式,则调用 $job->release(300) 延迟 5 分钟后重试。
3、在任务类的 middleware() 方法中注册该中间件:return [new CheckQueuePriority];。
四、结合 Horizon 实现可视化标签管理
Laravel Horizon 是专为 Redis 队列设计的仪表板,内置对 tags 的完整支持,可实时查看各标签的任务数、失败率与运行时长,便于运维人员快速识别瓶颈。
1、安装 Horizon:composer require laravel/horizon,并执行 php artisan horizon:install。
2、在 config/horizon.php 中启用标签统计,确认 'tags' => true 已设置。
3、启动 Horizon 后访问 /horizon,进入 Tags 标签页,即可按 high、medium、low 等标签筛选并手动重试失败任务。











