🎤 Laravel 多数据库连接的读写分离与数据库负载均衡实现：一场技术讲座
大家好！欢迎来到今天的 Laravel 技术讲座！今天我们将一起探讨如何在 Laravel 中实现多数据库连接的 读写分离 和 数据库负载均衡。如果你觉得数据库配置复杂得像一团乱麻，别担心，我会用轻松幽默的语言和代码示例带你一步步搞定它！🎉
📋 讲座大纲
- 什么是读写分离？
- Laravel 的多数据库连接基础
- 实现读写分离的步骤
- 数据库负载均衡的实现
- 实战代码演示
- 常见问题与优化
1. 什么是读写分离？🌟
在数据库的世界里，"读" 和 "写" 是两个常见的操作。
- 写操作（INSERT、UPDATE、DELETE）会改变数据的状态。
- 读操作（SELECT）只是查询数据。
如果我们把写操作集中在主数据库（Master），而把读操作分散到从数据库（Slave），这样可以有效减轻主数据库的压力，提高系统的性能。这就是所谓的 读写分离！
💡 国外文档引用：In the context of database scaling, read-write splitting is a common strategy to offload read-heavy workloads from the primary database to replicas.
2. Laravel 的多数据库连接基础 🔧
在 Laravel 中，我们可以通过 config/database.php 文件来定义多个数据库连接。比如：
// config/database.php
'connections' => [
'mysql_master' => [
'driver' => 'mysql',
'host' => env('DB_HOST_MASTER', '127.0.0.1'),
'port' => env('DB_PORT_MASTER', '3306'),
'database' => env('DB_DATABASE_MASTER', 'forge'),
'username' => env('DB_USERNAME_MASTER', 'forge'),
'password' => env('DB_PASSWORD_MASTER', ''),
'charset' => 'utf8mb4',
'collation' => 'utf8mb4_unicode_ci',
'prefix' => '',
],
'mysql_slave' => [
'driver' => 'mysql',
'host' => env('DB_HOST_SLAVE', '127.0.0.1'),
'port' => env('DB_PORT_SLAVE', '3306'),
'database' => env('DB_DATABASE_SLAVE', 'forge'),
'username' => env('DB_USERNAME_SLAVE', 'forge'),
'password' => env('DB_PASSWORD_SLAVE', ''),
'charset' => 'utf8mb4',
'collation' => 'utf8mb4_unicode_ci',
'prefix' => '',
],
],在这里，我们定义了两个连接：mysql_master 和 mysql_slave。接下来就是如何让它们各司其职啦！
3. 实现读写分离的步骤 🛠️
Step 1: 创建一个自定义的数据库连接类
Laravel 提供了一个非常灵活的机制，允许我们通过扩展 ConnectionResolverInterface 来实现自定义的数据库连接逻辑。我们可以创建一个名为 DatabaseReadWriteSplitting.php 的类：
// app/Services/DatabaseReadWriteSplitting.php
namespace AppServices;
use IlluminateSupportFacadesDB;
use IlluminateDatabaseConnectionResolverInterface;
class DatabaseReadWriteSplitting implements ConnectionResolverInterface
{
protected $resolver;
public function __construct(ConnectionResolverInterface $resolver)
{
$this->resolver = $resolver;
}
public function connection($name = null)
{
if ($name === 'mysql') {
// 根据当前操作类型选择 Master 或 Slave
$query = DB::getQueryLog();
if (!empty($query) && in_array(strtoupper($query[0]['query']), ['INSERT', 'UPDATE', 'DELETE'])) {
return $this->resolver->connection('mysql_master');
} else {
return $this->resolver->connection('mysql_slave');
}
}
return $this->resolver->connection($name);
}
// 其他方法需要实现，但通常不需要修改
public function getDefaultConnection() { return $this->resolver->getDefaultConnection(); }
public function setDefaultConnection($name) { $this->resolver->setDefaultConnection($name); }
public function getConnection($name) { return $this->resolver->getConnection($name); }
public function getConnections() { return $this->resolver->getConnections(); }
}Step 2: 注册自定义连接类
接下来，我们需要在 AppServiceProvider 中注册这个自定义类：
// app/Providers/AppServiceProvider.php
namespace AppProviders;
use IlluminateSupportServiceProvider;
use AppServicesDatabaseReadWriteSplitting;
use IlluminateSupportFacadesDB;
class AppServiceProvider extends ServiceProvider
{
public function boot()
{
$readWriteSplitting = new DatabaseReadWriteSplitting(DB::getFacadeRoot());
DB::setConnectionResolver($readWriteSplitting);
}
public function register()
{
//
}
}4. 数据库负载均衡的实现 🏋️♂️
读写分离解决了主从数据库的分工问题，但如果我们的从数据库有多个副本怎么办？这时候就需要引入 负载均衡！
在 Laravel 中，我们可以通过随机选择从数据库来实现简单的负载均衡。修改 config/database.php 文件中的从数据库配置：
'mysql_slave' => [
'read' => [
['host' => env('DB_HOST_SLAVE_1', '127.0.0.1'), 'port' => env('DB_PORT_SLAVE_1', '3306')],
['host' => env('DB_HOST_SLAVE_2', '127.0.0.1'), 'port' => env('DB_PORT_SLAVE_2', '3306')],
],
'write' => [
'host' => env('DB_HOST_MASTER', '127.0.0.1'),
'port' => env('DB_PORT_MASTER', '3306'),
],
'driver' => 'mysql',
'database' => env('DB_DATABASE', 'forge'),
'username' => env('DB_USERNAME', 'forge'),
'password' => env('DB_PASSWORD', ''),
'charset' => 'utf8mb4',
'collation' => 'utf8mb4_unicode_ci',
'prefix' => '',
],💡 国外文档引用：Laravel’s database configuration supports defining multiple read/write connections for load balancing purposes.
5. 实战代码演示 💻
假设我们有一个 User 模型，下面是它的基本用法：
// 写操作
$user = new AppModelsUser();
$user->name = 'John Doe';
$user->email = 'john@example.com';
$user->save(); // 使用 mysql_master
// 读操作
$users = AppModelsUser::all(); // 使用 mysql_slave如果需要手动指定连接，可以这样做：
// 手动指定连接
$user = AppModelsUser::on('mysql_master')->find(1);6. 常见问题与优化 ❓
Q1: 如何确保主从数据库的数据一致性？
A1: 可以通过设置 MySQL 的主从同步延迟时间（MASTER_DELAY）来尽量减少数据不一致的情况。
Q2: 如果从数据库挂了怎么办？
A2: 可以通过监控工具（如 Prometheus）实时检测从数据库的状态，并在程序中动态切换到其他可用的从数据库。
总结 🎉
今天的讲座到这里就结束啦！我们学习了如何在 Laravel 中实现 读写分离 和 数据库负载均衡。虽然看起来有点复杂，但只要掌握了核心原理，一切都会变得简单明了！
最后送给大家一句话：“数据库就像你的伙伴，善待它，它就会回报你！” 😊
如果有任何问题，欢迎在评论区留言！下次见咯！👋
