Laravel多数据库环境下队列Job执行异常问题求助

问题核心 #

默认队列Worker启动时会初始化数据库连接配置，后续处理任务时不会动态重新加载或切换连接。而你的场景中每个任务对应不同公司的数据库，全局启动队列时无法自动匹配任务所属的公司数据库，导致执行异常；但指定单个公司时，Worker提前绑定了对应数据库，所以能正常运行。

解决方法 #

1. 在Job内部动态切换数据库连接 #

确保每个队列任务携带公司代码参数，在Job执行时根据代码加载对应数据库配置并切换连接：

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Config;
use Illuminate\Support\Facades\DB;

class ProcessCompanyTask implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $companyCode;

    public function __construct(string $companyCode)
    {
        $this->companyCode = $companyCode;
        // 将队列名称与公司绑定，方便后续精准处理
        $this->queue = $companyCode;
    }

    public function handle()
    {
        // 从配置文件读取当前公司的数据库配置
        $dbConfig = config("companyDb.{$this->companyCode}");
        if (!$dbConfig) {
            throw new \Exception("公司 {$this->companyCode} 的数据库配置不存在");
        }

        // 注册动态数据库连接
        Config::set("database.connections.{$this->companyCode}", $dbConfig);
        // 切换到当前公司的数据库连接
        DB::setDefaultConnection($this->companyCode);

        // 执行具体任务逻辑，示例：
        // DB::table('orders')->where('status', 0)->update(['status' => 1]);

        // 可选：任务完成后恢复默认连接，避免影响后续任务
        DB::setDefaultConnection(config('database.default'));
    }
}

2. 自定义Artisan命令批量处理所有公司队列 #

如果需要一次性启动所有公司的队列处理，可自定义命令遍历所有公司，逐个启动对应队列的Worker：

步骤1：生成自定义命令

php artisan make:command QueueAllCompanies

步骤2：编写命令逻辑

<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;
use Illuminate\Support\Facades\Config;

class QueueAllCompanies extends Command
{
    protected $signature = 'queue:all-companies {--daemon : 后台守护进程模式运行}';
    protected $description = '批量处理所有公司的队列任务';

    public function handle()
    {
        $companies = Config::get('companyDb', []);
        if (empty($companies)) {
            $this->error('未配置任何公司数据库信息');
            return 1;
        }

        $this->info("开始处理 " . count($companies) . " 个公司的队列任务");

        foreach ($companies as $code => $_) {
            $this->info("启动公司 {$code} 的队列处理...");
            
            $args = [
                '--queue' => $code,
                '--tries' => 3,
                '--timeout' => 60,
            ];

            if ($this->option('daemon')) {
                // 后台启动并记录日志
                exec("nohup php artisan queue:work " . http_build_query($args, '', ' ') . " > storage/logs/queue-{$code}.log 2>&1 &");
                $this->info("公司 {$code} 的队列已后台启动");
            } else {
                // 前台逐个处理（适合测试）
                $this->call('queue:work', $args);
            }
        }

        return 0;
    }
}

步骤3：后台运行自定义命令

php artisan queue:all-companies --daemon &

关键注意事项 #

• 队列任务必须携带公司代码参数，确保Job能识别目标数据库
• 动态切换数据库后，建议在Job执行完毕恢复默认连接，避免Worker后续任务出错
• 后台运行时，可配合Supervisor等进程管理工具监控队列，防止进程意外退出

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