Laravel 8 运行时全局切换数据库连接实现读写分离（读写.全局.数据库连接.切换.分离...）
在构建高性能、高可用的web应用时，数据库读写分离是一种常见的优化策略。它通过将读取操作路由到数据库副本（只读数据库），将写入操作路由到主数据库，从而分散数据库负载，提高并发处理能力。laravel框架提供了强大的数据库抽象层，但要在运行时根据请求类型（例如，get请求使用只读数据库，post/put/delete请求使用主数据库）全局切换数据库连接，并非简单修改配置即可实现。
许多开发者在尝试运行时切换数据库连接时，通常会尝试以下方法：
// 尝试一：断开当前连接，修改默认连接名，然后重连指定连接
DB::disconnect();
Config::set('database.default', 'mysql_readonly');
DB::reconnect('mysql_readonly');
// 尝试二：修改默认连接名，并清除指定连接
Config::set('database.default', 'mysql_readonly');
DB::purge('mysql_readonly');
// 尝试三：断开当前连接，修改默认连接名，然后获取指定连接实例
DB::disconnect();
Config::set('database.default', 'mysql_readonly');
DB::connection('mysql_readonly'); 然而，上述方法往往无法达到全局切换的效果。其核心原因在于，Laravel的数据库连接管理器可能会缓存已建立的连接实例，或者在框架内部的某些服务（如Eloquent ORM）中，对默认连接的引用并未随着 database.default 配置项的改变而自动更新。简单地更改默认连接的“名称”，并不能强制所有后续的数据库操作都使用新的连接配置。
高效的全局数据库连接切换方案实现运行时全局、可靠地切换数据库连接，关键在于不仅要指定新的连接参数，更要确保Laravel框架内部对“默认”连接的认知被有效覆盖，并清除所有已建立的连接实例，迫使框架在下一次数据库操作时根据最新的配置重新建立连接。
以下是经过验证的有效解决方案，通常在自定义中间件中实现：
<?php
namespace App\Http\Middleware;
use Closure;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Config;
use Illuminate\Support\Facades\DB;
class DatabaseConnectionSwitcher
{
/**
* 处理传入请求。
*
* @param \Illuminate\Http\Request $request
* @param \Closure(\Illuminate\Http\Request): (\Symfony\Component\HttpFoundation\Response) $next
* @return \Symfony\Component\HttpFoundation\Response
*/
public function handle(Request $request, Closure $next)
{
// 检查请求方法，如果是 GET 请求，则切换到只读数据库
if ($request->isMethod('GET')) {
// 1. 获取只读数据库的连接配置
$readOnlyConfig = config('database.connections.mysql_readonly');
// 2. 关键步骤：将主数据库（默认连接）的配置替换为只读数据库的配置
// 这会影响所有后续通过 DB::connection('mysql') 或隐式使用默认连接的操作
Config::set('database.connections.mysql', $readOnlyConfig);
// 3. 清除所有已建立的数据库连接实例
// 这会强制 Laravel 在下一次数据库操作时，根据最新的配置重新建立连接
DB::purge();
}
// 对于非 GET 请求（如 POST, PUT, DELETE 等），
// 保持使用默认的主数据库连接，无需额外操作，
// 因为我们只在 GET 请求时修改了 'mysql' 连接的配置。
// 如果需要，也可以在此处显式地将 'mysql' 配置重置回主库的原始配置。
return $next($request);
}
} 方案解析：
该解决方案的核心在于以下三行代码的协同作用：
$readOnlyConfig = config('database.connections.mysql_readonly'); 此行代码从 config/database.php 文件中获取名为 mysql_readonly 的数据库连接配置数组。这是进行连接切换的基础，它包含了只读数据库的所有连接参数（如主机、端口、数据库名、用户名、密码等）。
Config::set('database.connections.mysql', $readOnlyConfig); 这是最关键的一步。它并没有修改 database.default 这个指示默认连接名称的配置，而是直接覆盖了名为 mysql 的默认连接（通常是主数据库）的底层配置参数。这意味着，当Laravel尝试使用 mysql 连接时（无论是通过 DB::connection('mysql') 显式调用，还是通过 DB Facade 或 Eloquent ORM 隐式使用默认连接），它现在将使用 mysql_readonly 的连接参数进行连接。
DB::purge(); 此方法用于清除所有当前已建立的数据库连接实例。Laravel为了性能优化，会缓存已建立的连接。如果连接不被清除，即使配置被修改，后续的数据库操作可能仍然会使用旧的、已缓存的连接。DB::purge() 强制Laravel在下一次需要数据库连接时，根据最新的配置重新建立连接。这样，所有后续的数据库操作（无论是直接使用 DB Facade 还是 Eloquent ORM）都会自动指向新的只读数据库。
将上述逻辑封装在中间件中是实现读写分离的最佳实践。你需要将此中间件注册到 app/Http/Kernel.php 中的 web 或 api 中间件组，或应用于特定路由上，以确保在请求进入控制器之前完成数据库连接的切换。
配置示例 (config/database.php):
'connections' => [
'mysql' => [ // 这是你的主数据库配置
'driver' => 'mysql',
'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_readonly' => [ // 这是你的只读数据库副本配置
'driver' => 'mysql',
'host' => env('DB_READONLY_HOST', '127.0.0.1'), // 使用不同的环境变量或直接配置
'port' => env('DB_READONLY_PORT', '3306'),
'database' => env('DB_READONLY_DATABASE', 'forge_readonly'),
'username' => env('DB_READONLY_USERNAME', 'forge_readonly'),
'password' => env('DB_READONLY_PASSWORD', ''),
'unix_socket' => env('DB_READONLY_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'),
]) : [],
],
// ... 其他连接
], 重要注意事项：
- 配置管理： 确保你的 config/database.php 文件中正确配置了 mysql（主数据库）和 mysql_readonly（只读副本）两个连接，并且它们指向不同的数据库实例。
- 切换时机： 数据库连接切换应尽可能早地发生在请求生命周期中，通常在全局中间件中进行，以确保所有后续的数据库操作都能应用到正确的连接。
- 事务处理： 在读写分离场景下，如果涉及到跨数据库的事务操作，需要特别小心。通常，事务应在主数据库上进行。如果只读库用于读取，而写操作在主库，那么事务通常只在主库上发起。避免在只读连接上启动事务。
- 缓存影响： 如果你的应用使用了查询缓存（例如，通过 remember 方法），数据库切换可能会影响缓存的有效性。确保缓存策略与读写分离策略兼容，例如，读操作的缓存应独立于写操作。
- 写入操作： 对于非GET请求（如 POST、PUT、DELETE），上述中间件默认会保持使用主数据库连接。这是因为我们只在GET请求时修改了 mysql 连接的配置。如果你的应用逻辑复杂，可能需要更精细的控制，确保写入操作始终指向主数据库。
- 长连接/队列： 对于Laravel的队列工作器或Artisan命令等长生命周期进程，它们在启动时可能已经建立了数据库连接。在运行时修改配置并 purge 可能不会立即对这些已存在的连接生效，或者需要额外处理以确保连接的正确性。通常，这些进程会在每次任务执行时重新获取连接，或在任务开始时应用相应的连接逻辑。
通过动态修改默认连接的底层配置并强制清除现有连接，Laravel开发者可以在运行时灵活且全局地实现数据库读写分离。这种方法避免了仅仅修改默认连接名所带来的局限性，提供了一种健壮且全局生效的解决方案。在实际应用中，结合中间件的恰当使用，并充分考虑事务、缓存、以及不同请求类型的处理，可以构建出高性能、高可用的Laravel应用。
以上就是Laravel 8 运行时全局切换数据库连接实现读写分离的详细内容，更多请关注知识资源分享宝库其它相关文章！
