laravel通过配置数据库连接实现读写分离,自动将select查询发送到从库、写操作发送到主库。在config/database.php中为mysql配置read和write服务器,并设置sticky=true以确保同一请求周期内写后读的一致性。使用DB门面或Eloquent时,读写操作自动路由至对应连接。可通过DB::connection(‘mysql.write’)强制使用主库,或扩展模型添加onWriteConnection方法。通过SQL监听或pdo属性可验证连接来源,整个过程无需修改业务代码,透明高效。

Laravel 实现数据库的读写分离非常方便,主要通过配置数据库连接来自动将 SELECT 查询发送到从库(读),而 INSERT、UPDATE、delete 等操作发送到主库(写)。以下是具体实现方式。
配置数据库连接支持读写分离
Laravel 允许在 config/database.php 中为同一个数据库类型定义多个服务器,分别用于读和写。以 MySQL 为例:
修改 config/database.php 中的 mysql 连接配置:
‘connections’ => [
‘mysql’ => [
‘driver’ => ‘mysql’,
‘read’ => [
[
‘host’ => ‘192.168.1.1’,
‘port’ => ‘3306’,
‘username’ => ‘reader’,
‘password‘ => ‘password’,
]
],
‘write’ => [
[
‘host’ => ‘192.168.1.2’,
‘port’ => ‘3306’,
‘username’ => ‘writer’,
‘password’ => ‘password’,
]
],
‘sticky’ => true,
‘database’ => ‘your_database’,
‘charset’ => ‘utf8mb4’,
‘collation’ => ‘utf8mb4_unicode_ci’,
‘prefix’ => ”,
],
]
说明:
- read 配置用于执行 SELECT 操作的数据库服务器
- write 配置用于执行写操作的数据库服务器
- sticky 设置为 true 表示“粘性连接”:同一个请求周期内,一旦发生过写操作,后续读操作也会走主库,避免主从同步延迟导致数据不一致
- 其他通用配置(如 database、charset)只需写在主配置中,会被自动继承
使用查询构造器或 Eloquent 自动分离
配置完成后,Laravel 会根据 SQL 类型自动选择连接:
- 使用 DB::select() 或 Model::get() 时,自动使用 read 连接
- 使用 DB::insert()、update()、delete() 或 Model->save() 时,自动使用 write 连接
示例:
// 自动走从库
$users = DB::table(‘users’)->get();
// 自动走主库
DB::table(‘users’)->insert([‘name’ => ‘John’]);
// Eloquent 查询也适用
User::where(‘active’, 1)->get(); // 读
$user = new User([‘name’ => ‘Jane’]);
$user->save(); // 写
强制指定读写连接
某些场景下需要手动控制连接,比如想强制从主库读取最新数据:
- 强制使用写连接进行查询:
DB::connection(‘mysql.write’)->select(‘select * from users where id = ?’, [1]);
- 在 Eloquent 中使用:
User::onWriteConnection()->first();
注意:Laravel 并没有内置 onWriteConnection() 方法,如需此功能可自行在模型中扩展:
class User extends Model
{
public Static function onWriteConnection()
{
return static::query()->useWritePdo();
}
}
验证读写分离是否生效
可以通过监听 SQL 日志确认连接来源:
DB::listen(function ($query) {
Log::info(‘SQL:’, [
‘sql’ => $query->sql,
‘bindings’ => $query->bindings,
‘time’ => $query->time,
‘connection’ => $query->connection->getPdo() ? $query->connection->getPdo()->getAttribute(PDO::ATTR_CONNECTION_STATUS) : NULL
]);
});
也可以通过打印 PDO 连接信息判断当前使用的是哪个主机:
$pdo = DB::connection()->getPdo();
echo $pdo->getAttribute(PDO::MYSQL_ATTR_HOST_INFO);
基本上就这些。Laravel 的读写分离机制设计得很透明,只需正确配置,大部分情况下无需修改代码即可生效。
以上就是Laravel怎么实现数据库的读写分离的详细内容,更多请关注php中文网其它相关文章!