如何在Laravel Queue中切换数据库队列连接

步骤1：完善数据库连接配置 #

你需要先在config/database.php的connections数组中添加mysql_local的完整配置，对应.env里的本地数据库变量：

'connections' => [
    // 保留原有生产环境mysql配置
    'mysql' => [
        'driver' => 'mysql',
        'url' => env('DATABASE_URL'),
        'host' => env('DB_HOST', '127.0.0.1'),
        'port' => env('DB_PORT', '3306'),
        'database' => env('DB_DATABASE', 'forge'),
        'username' => env('DB_USERNAME', 'forge'),
        'password' => env('DB_PASSWORD', ''),
        'unix_socket' => env('DB_SOCKET', ''),
        'charset' => 'utf8mb4',
        'collation' => 'utf8mb4_unicode_ci',
        'prefix' => '',
        'prefix_indexes' => true,
        'strict' => true,
        'engine' => null,
        'options' => extension_loaded('pdo_mysql') ? array_filter([
            PDO::MYSQL_ATTR_SSL_CA => env('MYSQL_ATTR_SSL_CA'),
        ]) : [],
    ],

    // 添加本地数据库连接配置
    'mysql_local' => [
        'driver' => 'mysql',
        'host' => env('DB_HOST_LOCAL', '127.0.0.1'),
        'port' => env('DB_PORT_LOCAL', '3306'),
        'database' => env('DB_DATABASE_LOCAL', 'core3'),
        'username' => env('DB_USERNAME_LOCAL', 'root'),
        'password' => env('DB_PASSWORD_LOCAL', ''),
        'unix_socket' => env('DB_SOCKET', ''),
        'charset' => 'utf8mb4',
        'collation' => 'utf8mb4_unicode_ci',
        'prefix' => '',
        'prefix_indexes' => true,
        'strict' => true,
        'engine' => null,
        'options' => extension_loaded('pdo_mysql') ? array_filter([
            PDO::MYSQL_ATTR_SSL_CA => env('MYSQL_ATTR_SSL_CA'),
        ]) : [],
    ],
],

步骤2：确认队列配置指向本地连接 #

你的queue.php配置已添加connection键，需额外确认默认队列驱动是否为database，确保全局生效：

// queue.php
'default' => env('QUEUE_CONNECTION', 'database'), // 确保默认驱动是database

'connections' => [
    'database' => [
        'driver' => 'database',
        'connection' => 'mysql_local', // 明确指定本地数据库连接
        'table' => 'jobs',
        'queue' => 'default',
        'retry_after' => 90,
        'after_commit' => false,
    ],
    // 其他队列驱动配置可保留
],

若无需全局修改，也可在分发任务时单独指定队列连接：

// 分发任务时指定使用目标队列连接
YourJob::dispatch()->onConnection('database');

步骤3：清除配置缓存并重启队列进程 #

Laravel会缓存配置文件，修改后需清除缓存才能生效：

php artisan config:clear

如果正在运行队列工作进程，必须重启进程加载新配置：

php artisan queue:restart

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