Laravel怎么实现数据库的读写分离-Laravel-PHP中文网

Laravel怎么实现数据库的读写分离

穿越時空

发布： 2025-11-12 08:02:03

原创

860人浏览过

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

laravel怎么实现数据库的读写分离

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中文网其它相关文章！