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

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 连接

示例:

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

阿里云-虚拟数字人

阿里云-虚拟数字人是什么? …

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

查看详情 Laravel怎么实现数据库的读写分离

// 自动走从库
$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中文网其它相关文章!

上一篇
下一篇
text=ZqhQzanResources