在队列中动态切换MySQL数据源，会导致数据串库

问答 / 2 / 6 / 创建于 11个月前

1. 运行环境

LNMP

1). 当前使用的 Laravel 版本？

8.12

2). 当前使用的 php/php-fpm 版本？

PHP 版本：7.4

3). 当前系统

CentOS

4). 业务环境

开发环境，单节点未使用负载均衡

5). 相关软件版本

MySQL8.0

2. 问题描述？

系统是一个多租户的Saas系统，存在多数据库，需要根据用户切换数据源，同步请求时是正常的，当采用redis异步队列的时候，切换数据源后，执行异步操作，会发生串库现象。config()->set没有生效。

//对列中修改数据库的配置
            config()->set('database.connections.mysql_master.host', $dbConfig['host']);
            config()->set('database.connections.mysql_master.port', $dbConfig['port']);
            config()->set('database.connections.mysql_master.database', $dbConfig['database']);
            config()->set('database.connections.mysql_master.username', $dbConfig['username']);
            config()->set('database.connections.mysql_master.password', $dbConfig['password']);
            $this->connection = 'mysql_master';

在队列中动态切换MySQL数据源，会导致数据串库

3. 您期望得到的结果？

异步队列内切换数据库成功，写入对应的数据库

4. 您实际得到的结果？

队列内业务部分写到目标库，部分写到其它数据库，发生串库问题。

DonFisher

1 声望

暂无个人描述~

0 人点赞

从零开发一个电商项目，功能包括电商后台、商品 & SKU 管理、购物车、订单管理、支付宝支付、微信支付、订单退款流程、优惠券等

我们将带你从零开发一个项目并部署到线上，本课程教授 Web 开发中专业、实用的技能，如 Git 工作流、Laravel Mix 前端工作流等。

推荐文章：

更多推荐...

博客

冯老师的困惑 —— 一个跑了两年的 BUG 19 / 16 |

博客

在laravel下实现全双工的websocket开发 21 / 8 |

博客

手摸手带你使用 docker-compose 编排一个开发环境 18 / 15 |

博客

Tiny RDM - 您的极简Redis数据管理利器！高效、易用、快速部署。立即体验！🚀! 欢迎各位来尝鲜. 13 / 23 |

博客

乐融沃多商户商城现已完全开源 10 / 16 |

博客

PHP 中一次反射需要多长时间 28 / 9 |

讨论数量: 6

cccdz

课程读者 490 声望

我目前这个项目也像是saas 我是同一个数据库然后这个下面分不同的库名用户名密码是一样只需要切换一下库然后封装了一个switch_database去切换库
每次在队列中间件里面做一次切换

if (!function_exists('switch_database')) {
    /**
     * 切換庫
     *
     * @param string $idCode
     * @return void
     */
    function switch_database(string $idCode): void
    {
        context_store()->setIdCode($idCode);

        // 獲取數據庫所有連接
        $connections = DB::getConnections();

        // 如果不存在這個數據庫連接 則不切換庫 會在第一次建立這個連接的時候會觸發事件 切換到對應的庫
        if (!isset($connections[DB::getDefaultConnection()])) {
            return;
        }

        $databaseName = get_database_name($idCode);

        DB::statement("use $databaseName");
        DB::setDatabaseName($databaseName);
    }
}

<?php

namespace App\Jobs\Middleware;

use App\Jobs\BaseJob;
use Closure;

class ContextTrace
{
    public function handle(object $job, Closure $next): void
    {
        /** @var BaseJob $job */
        log_share_context_uuid($job->contextTraceId);
        switch_database($job->idCode);

        $next($job);
    }
}

Laravel

所有job都继承者baseJob

11个月前评论

陈先生

课程读者 650 声望 / PHP_EOL @ NaN

断开当前链接再链接新的库

11个月前评论

cccdz

课程读者 490 声望

你这样改肯定不行 DB是单例你第一次的运行的时候就已经实例化对应的驱动了你第二次去用的时候直接拿这个实例了不会初始化了你配置完这个后需要DB::reconnect() 重置连接一下

11个月前评论

cccdz

课程读者 490 声望

我目前这个项目也像是saas 我是同一个数据库然后这个下面分不同的库名用户名密码是一样只需要切换一下库然后封装了一个switch_database去切换库
每次在队列中间件里面做一次切换

if (!function_exists('switch_database')) {
    /**
     * 切換庫
     *
     * @param string $idCode
     * @return void
     */
    function switch_database(string $idCode): void
    {
        context_store()->setIdCode($idCode);

        // 獲取數據庫所有連接
        $connections = DB::getConnections();

        // 如果不存在這個數據庫連接 則不切換庫 會在第一次建立這個連接的時候會觸發事件 切換到對應的庫
        if (!isset($connections[DB::getDefaultConnection()])) {
            return;
        }

        $databaseName = get_database_name($idCode);

        DB::statement("use $databaseName");
        DB::setDatabaseName($databaseName);
    }
}

<?php

namespace App\Jobs\Middleware;

use App\Jobs\BaseJob;
use Closure;

class ContextTrace
{
    public function handle(object $job, Closure $next): void
    {
        /** @var BaseJob $job */
        log_share_context_uuid($job->contextTraceId);
        switch_database($job->idCode);

        $next($job);
    }
}

Laravel

所有job都继承者baseJob

11个月前评论

晏南风

见习助教 149 声望

把业务写在service 就不会了，让job 减负

11个月前评论

huchao399

62 声望

动态修改配置前先断开连接，一定要用purge方法，disconnect方法并不会清楚缓存的实例

DB::purge('mysql_master');

11个月前评论

kis龍

Laravel 9.x 译者 498 声望

可不可以将 database 甚至 config 放到 consul 中去？

11个月前评论

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容，与人为善，比聪明更重要！

帮助

在队列中动态切换MySQL数据源，会导致数据串库

1. 运行环境

1). 当前使用的 Laravel 版本？

2). 当前使用的 php/php-fpm 版本？

3). 当前系统

4). 业务环境

5). 相关软件版本

2. 问题描述？

3. 您期望得到的结果？

4. 您实际得到的结果？

推荐文章：

高认可度评论：

社区赞助商

关于 LearnKu

资源推荐

服务提供商

其他信息

在队列中动态切换MySQL数据源，会导致数据串库

1. 运行环境

1). 当前使用的 Laravel 版本？

2). 当前使用的 php/php-fpm 版本？

3). 当前系统

4). 业务环境

5). 相关软件版本

2. 问题描述？

3. 您期望得到的结果？

4. 您实际得到的结果？

推荐文章：

高认可度评论：

社区赞助商

关于 LearnKu

资源推荐

服务提供商

其他信息

请登录