需通过多连接队列、自定义地理标记驱动、Redis有序集合、Supervisor进程组绑定及HTTP代理层五种方式实现优先级与地域路由。

如果您在Laravel应用中需要根据任务紧急程度分配不同优先级,并将队列任务分发至地理上更近的处理节点,则需突破默认单一队列驱动的限制。以下是实现队列优先级与地域节点匹配的具体方法:
一、使用多连接+多队列名称模拟优先级
通过配置多个Redis或Database连接,结合队列名称前缀区分优先级,使高优先级任务被专用消费者更快拾取。每个连接可绑定特定地域节点的Worker进程。
1、在config/queue.php中新增三个连接配置:redis_high、redis_normal、redis_low,分别指向同一Redis实例的不同数据库(如db=0、db=1、db=2)或不同地域Redis集群地址。
2、为每个连接设置对应队列名称:将high、normal、low作为队列名后缀,例如us-east-high、ap-southeast-normal。
3、在任务分发时显式指定连接与队列:dispatch((new SendNotification)->onConnection('redis_high')->onQueue('us-east-high'));
4、在对应地域服务器启动专用Worker:php artisan queue:work redis_high --queue=us-east-high --max-jobs=100。
二、自定义队列驱动支持地域标签路由
扩展Laravel原生Redis驱动,在推送任务时嵌入地域标识字段,并在Worker拉取前过滤匹配标签的任务,实现节点级精准路由。
1、创建app/Queue/GeotaggedRedisQueue.php,继承Illuminate\Queue\RedisQueue,重写push方法,在$payload中注入"region": "cn-shenzhen"字段。
2、重写pop方法:调用eval Lua脚本从Redis List中查找首个region值匹配当前Worker地域标签的任务,若无匹配则返回null。
3、在config/queue.php中注册新驱动:'georedis' => ['driver' => 'georedis', 'connection' => 'default'],并绑定服务容器。
4、在地域节点部署时,通过环境变量APP_REGION=cn-beijing注入Worker上下文,使pop逻辑自动识别本地标签。
三、基于Redis Sorted Set实现动态优先级调度
利用Redis有序集合按分数排序特性,将任务优先级(如1-100)与地域权重(如延迟毫秒值)组合为ZSET分数,使高优+低延迟任务始终排在队首。
1、修改任务序列化逻辑,在Jobs\Job类的resolve方法中计算综合得分:$score = $priority * 1000 - $latencyMs,其中$latencyMs通过预置地域延迟表查得。
2、使用ZADD geotagged_queue {$score} {$jobId}代替LPUSH,并将完整任务数据以jobId为key存入Hash结构。
Laravel Cloud(cloud.laravel.com)。此技能用于处理所有 Laravel Cloud 请求,包括搜索和读取数据。只要任务涉及 Laravel Cloud,即使用此技能。
3、Worker轮询执行ZRANGE geotagged_queue 0 0 WITHSCORES,校验分数是否仍符合当前节点服务能力阈值(如分数≥当前节点基准值),否则跳过。
4、消费成功后执行ZREM geotagged_queue {$jobId},失败则更新分数为降权值并重新插入。
四、利用Supervisor进程组绑定地域与优先级
通过Supervisor配置文件控制不同地域服务器上运行的Worker进程组,使其仅监听指定地域前缀+优先级组合的队列名,避免跨地域争抢。
1、在/etc/supervisor/conf.d/queue-us.conf中定义[program:queue-us-high]段,命令为php artisan queue:work --queue=us-high,us-medium。
2、为ap-southeast节点单独配置[program:queue-ap-high],命令中仅包含ap-southeast-high和ap-southeast-medium队列名。
3、在任务分发端,根据用户IP解析地域(如使用geoip2/geoip2包),再映射为队列前缀:$queue = $regionMap[$userRegion] . '-high';。
4、确保各节点Supervisor仅加载本地对应的conf文件,且autostart=true与autorestart=true启用。
五、消息中间件代理层实现透明路由
在Laravel与底层队列服务之间引入轻量代理服务(如Go编写的HTTP-to-Redis桥接器),由其统一接收任务请求,依据Header中的X-Priority与X-Region头完成路由决策。
1、修改Laravel中QUEUE_CONNECTION为http,并配置queue.connections.http.base_url=http://localhost:8080。
2、代理服务监听/push端点,解析JSON Body与Headers,生成带地域标记的Redis Key:queue:us-east:high:20240521。
3、代理根据X-Region选择目标Redis集群节点(如us-east-redis.example.com),并按X-Priority决定ZSET分数或List插入位置。
4、各地域Worker直连本地Redis集群,仅订阅形如queue:us-east:*:的模式匹配键,使用PSUBSCRIBE实时响应。










