Laravel多租户架构下如何为队列动态配置自定义数据库？

我正在开发一个基于Laravel的多租户应用，数据库连接根据请求的子域名动态确定，例如：

• spain.example.com 使用 spain_db
• india.example.com 使用 india_db

已实现IdentifyTenant中间件，用于检测子域名、获取租户数据库信息并动态设置连接，代码如下：

config([
    'database.connections.custom' => [
        'driver'    => 'mysql',
        'host'      => $tenantDetails['db_host'],
        'database'  => $tenantDetails['db_name'],
        'username'  => $tenantDetails['db_user'],
        'password'  => $tenantDetails['db_password'],
        'charset'   => 'utf8mb4',
        'collation' => 'utf8mb4_unicode_ci',
        'prefix'    => '',
        'strict'    => false,
        'engine'    => null,
    ],
]);
DB::setDefaultConnection('custom');

该配置在HTTP请求中运行正常，可根据子域名动态切换数据库连接。

问题：队列Worker #

运行php artisan queue:work或php artisan queue:listen时，队列worker始终使用.env文件中的默认数据库，需要worker根据任务中存储的租户信息动态确定数据库连接。

已尝试方案 #

1. 在任务负载中传递租户信息 #

分发任务时附带租户专属信息：

$tenantDetails = [
    'db_host' => '127.0.0.1',
    'db_name' => 'spain_db',
    'db_user' => 'root',
    'db_password' => '',
];
YourJob::dispatch($tenantDetails);

在任务的handle方法中动态设置数据库：

config([
    'database.connections.custom' => [
        'driver'    => 'mysql',
        'host'      => $this->tenantDetails['db_host'],
        'database'  => $this->tenantDetails['db_name'],
        'username'  => $this->tenantDetails['db_user'],
        'password'  => $this->tenantDetails['db_password'],
        'charset'   => 'utf8mb4',
        'collation' => 'utf8mb4_unicode_ci',
        'prefix'    => '',
        'strict'    => false,
        'engine'    => null,
    ],
]);
DB::setDefaultConnection('custom');

2. 使用JobProcessing事件 #

创建SetTenantForQueue监听器处理JobProcessing事件，动态配置租户数据库：

namespace App\Listeners;

use Illuminate\Queue\Events\JobProcessing;
use Illuminate\Support\Facades\DB;

class SetTenantForQueue
{
    public function handle(JobProcessing $event)
    {
        $tenantDetails = $event->job->payload()['data']['tenantDetails'] ?? null;

        if ($tenantDetails) {
            config([
                'database.connections.custom' => [
                    'driver'    => 'mysql',
                    'host'      => $tenantDetails['db_host'],
                    'database'  => $tenantDetails['db_name'],
                    'username'  => $tenantDetails['db_user'],
                    'password'  => $tenantDetails['db_password'],
                    'charset'   => 'utf8mb4',
                    'collation' => 'utf8mb4_unicode_ci',
                    'prefix'    => '',
                    'strict'    => false,
                    'engine'    => null,
                ],
            ]);
            DB::setDefaultConnection('custom');
        }
    }
}

在EventServiceProvider中注册监听器：

use Illuminate\Queue\Events\JobProcessing;
use App\Listeners\SetTenantForQueue;

protected $listen = [
    JobProcessing::class => [
        SetTenantForQueue::class,
    ],
];

现存问题 #

尽管尝试了上述方案，队列worker执行任务时仍使用.env中的默认数据库，需要确保worker根据子域名或任务负载动态使用租户数据库。

求助内容 #

1. 如何配置Laravel队列worker为每个任务动态设置数据库连接？
2. 在Laravel中处理多租户数据库与队列是否有更优方案？
3. 如何让队列worker实现“租户感知”，无需手动干预（如为每个租户运行单独的worker）？

解决方案 #

1. 修复动态连接切换的核心问题

当前代码存在连接复用的隐患：Laravel数据库连接一旦建立会被复用，不会自动重新初始化。需要在切换连接前清理旧连接：

// 清理所有已建立的数据库连接
DB::purge();
// 或针对性清理默认/自定义连接
DB::purge(config('database.default'));
DB::purge('custom');

// 配置新的租户连接
config([
    'database.connections.custom' => [
        'driver'    => 'mysql',
        'host'      => $tenantDetails['db_host'],
        'database'  => $tenantDetails['db_name'],
        'username'  => $tenantDetails['db_user'],
        'password'  => $tenantDetails['db_password'],
        'charset'   => 'utf8mb4',
        'collation' => 'utf8mb4_unicode_ci',
        'prefix'    => '',
        'strict'    => false,
    ],
]);

// 设置默认连接并强制重新连接
DB::setDefaultConnection('custom');
DB::reconnect();

将这段逻辑替换任务handle方法或JobProcessing监听器中的配置代码，确保每次任务处理都重新初始化租户连接。

2. 更优的多租户队列处理方案

（1）抽象租户任务基类

创建TenantAwareJob抽象基类，统一处理数据库切换逻辑，所有租户任务继承此类：

abstract class TenantAwareJob implements ShouldQueue
{
    protected $tenantDetails;

    public function __construct(array $tenantDetails)
    {
        $this->tenantDetails = $tenantDetails;
    }

    public function handle()
    {
        // 清理旧连接
        DB::purge();
        // 配置租户连接
        config([
            'database.connections.tenant' => [
                'driver'    => 'mysql',
                'host'      => $this->tenantDetails['db_host'],
                'database'  => $this->tenantDetails['db_name'],
                'username'  => $this->tenantDetails['db_user'],
                'password'  => $this->tenantDetails['db_password'],
                'charset'   => 'utf8mb4',
                'collation' => 'utf8mb4_unicode_ci',
                'prefix'    => '',
                'strict'    => false,
            ],
        ]);
        DB::setDefaultConnection('tenant');
        DB::reconnect();

        // 执行子类业务逻辑
        $this->handleTenantJob();
    }

    // 子类实现具体业务
    abstract protected function handleTenantJob();
}

后续租户任务只需实现handleTenantJob方法，无需重复编写连接切换代码。

（2）队列任务中间件

创建SetTenantConnection中间件，在任务执行前后处理连接切换：

class SetTenantConnection
{
    public function handle($job, $next)
    {
        $tenantDetails = $job->tenantDetails ?? null;
        if ($tenantDetails) {
            DB::purge();
            config([
                'database.connections.tenant' => [
                    // 租户数据库配置
                    'driver'    => 'mysql',
                    'host'      => $tenantDetails['db_host'],
                    'database'  => $tenantDetails['db_name'],
                    'username'  => $tenantDetails['db_user'],
                    'password'  => $tenantDetails['db_password'],
                    'charset'   => 'utf8mb4',
                    'collation' => 'utf8mb4_unicode_ci',
                ],
            ]);
            DB::setDefaultConnection('tenant');
            DB::reconnect();
        }

        // 执行任务
        $next($job);

        // 任务完成后恢复默认连接（防止后续任务串用）
        DB::purge('tenant');
        DB::setDefaultConnection(config('database.default'));
        DB::reconnect();
    }
}

在任务类中绑定中间件：

class YourJob implements ShouldQueue
{
    public $tenantDetails;

    public function __construct(array $tenantDetails)
    {
        $this->tenantDetails = $tenantDetails;
    }

    public function middleware()
    {
        return [new SetTenantConnection];
    }

    public function handle()
    {
        // 业务逻辑，已自动切换到租户数据库
    }
}

3. 无干预的租户感知Worker

核心思路是传递租户ID而非完整数据库配置，从中央数据库（存储所有租户信息的库）动态获取配置：

• 分发任务时仅传递租户ID：

// 从当前请求的中间件中获取租户ID
$tenantId = request()->tenant->id;
YourJob::dispatch($tenantId);

• 在JobProcessing监听器中获取租户配置并切换连接：

namespace App\Listeners;

use Illuminate\Queue\Events\JobProcessing;
use Illuminate\Support\Facades\DB;
use App\Models\Tenant;

class SetTenantForQueue
{
    public function handle(JobProcessing $event)
    {
        $tenantId = $event->job->payload()['data']['tenantId'] ?? null;
        if (!$tenantId) return;

        // 切换到中央数据库查询租户信息
        DB::setDefaultConnection('central');
        $tenant = Tenant::find($tenantId);
        if (!$tenant) return;

        // 清理旧连接并切换到租户数据库
        DB::purge();
        config([
            'database.connections.tenant' => [
                'driver'    => 'mysql',
                'host'      => $tenant->db_host,
                'database'  => $tenant->db_name,
                'username'  => $tenant->db_user,
                'password'  => $tenant->db_password,
                'charset'   => 'utf8mb4',
                'collation' => 'utf8mb4_unicode_ci',
            ],
        ]);
        DB::setDefaultConnection('tenant');
        DB::reconnect();
    }
}

这种方式避免了在任务负载中暴露敏感信息，Worker只需从中央库获取配置即可自动切换，无需为每个租户单独启动实例。

内容的提问来源于stack exchange，提问作者shaikh saliem