多数据库环境下如何运行Laravel队列任务？

问题1：任务存入公共数据库而非对应公司数据库的原因及解决 #

Laravel默认使用配置文件中database.default指定的连接存储队列任务，若你的默认连接是commonDatabase，任务自然会存入这里。要让任务进入对应公司的数据库，需在分发时明确指定目标连接：

解决方法1：分发时直接指定连接 #

// 根据请求头的公司名称获取对应数据库连接名
$companyConnection = $this->getCompanyDbConnection(request()->header('company-name'));
// 分发任务时绑定目标连接
dispatch(new YourJob())->onConnection($companyConnection);

解决方法2：在Job类中动态指定连接 #

将公司连接信息存入Job属性，重写getConnection方法实现动态切换：

class YourJob implements ShouldQueue
{
    public $companyConnection;

    public function __construct(string $companyConnection)
    {
        $this->companyConnection = $companyConnection;
    }

    public function getConnection()
    {
        return $this->companyConnection;
    }

    public function handle()
    {
        // 执行业务逻辑
    }
}

注意：使用该方案时，每个公司的数据库必须提前创建jobs和failed_jobs表，可通过指定连接执行迁移：

php artisan migrate --database=company_connection_name

问题2：最佳实现方案对比 #

两种方案各有优劣，需结合业务规模和需求选择：

方案1：公共数据库统一维护jobs表 #

优点：维护成本低，无需为每个公司创建队列表；worker只需监听一个队列，部署简单。
缺点：所有公司任务存放在一起，数据量大时可能影响查询效率；隔离性稍弱。

落地方式：

1. 所有任务存入commonDatabase的jobs表，任务中携带公司标识（如名称、数据库连接名）。
2. 分发任务时按公司设置专属队列名：

$companyName = request()->header('company-name');
dispatch(new YourJob($companyName))->onQueue("company-{$companyName}");

3. worker按需监听指定队列，或监听所有队列：

# 监听单个公司队列
php artisan queue:work --queue=company-companyA
# 监听多个公司队列
php artisan queue:work --queue=company-companyA,company-companyB
# 监听所有队列（按优先级排序）
php artisan queue:work --queue=high,default,company-*

4. 在Job的handle方法中切换到对应公司数据库执行业务：

public function handle()
{
    // 从公共数据库获取公司的数据库配置
    $dbConfig = DB::connection('common')->table('company_databases')
        ->where('name', $this->companyName)
        ->first();
    
    // 临时注册公司数据库连接
    Config::set('database.connections.company_temp', [
        'driver' => 'mysql',
        'host' => $dbConfig->host,
        'database' => $dbConfig->database,
        'username' => $dbConfig->username,
        'password' => $dbConfig->password,
        'charset' => 'utf8mb4',
        'collation' => 'utf8mb4_unicode_ci',
    ]);
    
    // 使用该连接执行具体业务操作
    DB::connection('company_temp')->table('your_table')->insert([...]);
}

方案2：每个公司数据库单独创建jobs表 #

优点：数据完全隔离，符合多租户独立数据库的设计原则；单个公司任务数据量小时效率更高。
缺点：维护成本高，新增公司时需手动/自动创建队列表；worker需要针对不同连接配置监听，部署复杂。

适用场景：公司数量较少，或对数据隔离有严格合规要求的场景。

推荐方案 #

若公司数量较多，优先选择公共数据库统一维护jobs表的方案，兼顾维护简便性和业务隔离需求；若公司数量少且隔离要求极高，再考虑每个公司单独建队列表。

问题3：用户登出后队列任务是否继续运行 #

会继续运行。队列任务由后台的Laravel queue worker进程独立处理，和用户的HTTP会话完全无关。用户登录只是触发任务分发的动作，一旦任务被成功存入队列，不管用户是否登出、浏览器是否关闭，worker都会按照队列顺序执行任务。

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