在Laravel项目中，灰度发布可以让新功能先面向小部分用户开放，降低上线风险，而优先级队列能确保核心任务优先被处理，两者结合可以大幅提升系统稳定性和任务处理效率。下面介绍具体的实现方法。
核心实现思路
要实现Laravel的优先级队列灰度发布，主要分为三个部分：一是配置多优先级队列，二是设置灰度发布规则，三是将两者结合实现任务按优先级和灰度规则分发。整体逻辑是优先处理高优先级队列的任务，同时只有符合灰度规则的用户触发的任务才会进入新功能对应的队列。
步骤一：配置优先级队列
Laravel默认支持多种队列驱动，我们可以通过配置多个队列来实现优先级区分，优先级高的队列会被worker优先消费。
修改队列配置文件
打开config/queue.php，在connections的redis配置下添加多个队列名称，默认队列作为低优先级队列，新增高优先级队列：
<?php
return [
// 其他配置省略
'connections' => [
'redis' => [
'driver' => 'redis',
'connection' => 'default',
'queue' => env('REDIS_QUEUE', 'default'), // 默认低优先级队列
'retry_after' => 90,
'block_for' => null,
// 新增高优先级队列配置
'high_priority_queue' => 'high_priority',
'middle_priority_queue' => 'middle_priority',
],
],
];
启动多队列worker
启动队列worker时指定多个队列，按优先级顺序排列，这样worker会先处理排在前面的队列任务：
php artisan queue:work redis --queue=high_priority,middle_priority,default
步骤二：实现灰度发布规则
灰度发布需要判断用户是否符合灰度条件，常见的规则有用户ID取模、白名单、比例灰度等，这里以实现用户ID取模的灰度判断为例。
创建灰度判断服务类
创建app/Services/GrayReleaseService.php，实现灰度判断逻辑：
<?php
namespace AppServices;
class GrayReleaseService
{
/**
* 判断用户是否符合灰度规则
* @param int $userId 用户ID
* @param int $grayRatio 灰度比例，比如10表示10%的用户进入灰度
* @return bool
*/
public static function isGrayUser(int $userId, int $grayRatio = 10): bool
{
// 用户ID取模，余数小于灰度比例则进入灰度
return $userId % 100 < $grayRatio;
}
/**
* 判断是否为灰度白名单用户
* @param int $userId 用户ID
* @return bool
*/
public static function isInWhiteList(int $userId): bool
{
$whiteList = config('gray.white_list', []);
return in_array($userId, $whiteList);
}
}
添加灰度配置
在config目录下新建gray.php配置文件，添加灰度相关配置：
<?php
return [
// 灰度比例，10表示10%用户
'ratio' => 10,
// 灰度白名单用户ID
'white_list' => [1, 2, 3],
];
步骤三：结合优先级队列与灰度发布
接下来需要将任务分发和灰度规则结合，符合灰度的用户触发的任务进入新功能对应的优先级队列，不符合的进入旧逻辑队列。
创建队列任务类
创建两个任务类，分别对应新功能和旧功能的处理逻辑：
<?php
namespace AppJobs;
use IlluminateBusQueueable;
use IlluminateContractsQueueShouldQueue;
use IlluminateFoundationBusDispatchable;
use IlluminateQueueInteractsWithQueue;
use IlluminateQueueSerializesModels;
class NewFeatureJob implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
public $userId;
public function __construct(int $userId)
{
$this->userId = $userId;
// 新功能任务设置为高优先级，进入高优先级队列
$this->onQueue('high_priority');
}
public function handle()
{
// 新功能处理逻辑
echo "处理用户{$this->userId}的新功能任务" . PHP_EOL;
}
}
class OldFeatureJob implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
public $userId;
public function __construct(int $userId)
{
$this->userId = $userId;
// 旧功能任务设置为默认优先级
$this->onQueue('default');
}
public function handle()
{
// 旧功能处理逻辑
echo "处理用户{$this->userId}的旧功能任务" . PHP_EOL;
}
}
任务分发逻辑
在业务代码中根据用户灰度状态分发不同的任务：
<?php
namespace AppHttpControllers;
use AppJobsNewFeatureJob;
use AppJobsOldFeatureJob;
use AppServicesGrayReleaseService;
use IlluminateHttpRequest;
class TestController extends Controller
{
public function handleTask(Request $request)
{
$userId = $request->input('user_id');
// 判断是否为灰度用户
$isGray = GrayReleaseService::isGrayUser($userId, config('gray.ratio'))
|| GrayReleaseService::isInWhiteList($userId);
if ($isGray) {
// 灰度用户分发新功能高优先级任务
NewFeatureJob::dispatch($userId);
} else {
// 非灰度用户分发旧功能默认优先级任务
OldFeatureJob::dispatch($userId);
}
return response()->json(['code' => 0, 'msg' => '任务分发成功']);
}
}
验证与扩展
完成上述配置后，可以编写测试用例验证功能：模拟不同用户ID请求接口，查看队列中的任务是否符合预期，高优先级队列的任务是否优先被处理。如果需要调整灰度比例，只需要修改config/gray.php中的ratio配置即可，不需要修改业务代码。如果要新增更多优先级队列，只需要在worker启动时添加对应的队列名称，并在任务类中指定对应的队列即可。