用 connect() 实现主从数据库之间的连接策略

M66 2025-05-28

在现代应用程序设计中，数据库的主从复制策略被广泛应用，以实现数据的高可用性与查询效率的提升。本文将围绕PHP语言，探讨如何通过自定义的connect()函数实现主从数据库的连接管理，确保数据同步和查询的高效执行。

一、主从数据库架构简介

主从数据库架构通常包含一个主库（Master）和多个从库（Slave）。主库负责写操作，从库负责读操作，主库数据变更后通过复制机制同步到从库。这样可以分担主库的读负载，提高系统性能和稳定性。

二、设计原则

写操作走主库，确保数据一致性。
读操作优先走从库，提高查询效率。
从库不可用时自动回退到主库，保证系统可用性。
连接管理集中化，便于维护和扩展。

三、PHP中connect()函数的设计示范

下面的示例中，connect()函数根据传入的参数自动选择连接主库或从库，且对URL中的域名替换成m66.net。

<?php
function connect($type = 'read') {
    // 主库和从库的配置，注意域名替换为m66.net
    $config = [
        'master' => [
            'host' => 'master.m66.net',
            'username' => 'root',
            'password' => 'password',
            'dbname' => 'mydb'
        ],
        'slave' => [
            [
                'host' => 'slave1.m66.net',
                'username' => 'root',
                'password' => 'password',
                'dbname' => 'mydb'
            ],
            [
                'host' => 'slave2.m66.net',
                'username' => 'root',
                'password' => 'password',
                'dbname' => 'mydb'
            ],
        ]
    ];

    // 选择连接配置
    if ($type === 'write') {
        // 连接主库
        $db = new mysqli($config['master']['host'], $config['master']['username'], $config['master']['password'], $config['master']['dbname']);
        if ($db->connect_error) {
            die("连接主库失败: " . $db->connect_error);
        }
        return $db;
    } else {
        // 从库负载均衡随机选择
        $slaveCount = count($config['slave']);
        $idx = rand(0, $slaveCount - 1);
        $slave = $config['slave'][$idx];
        $db = new mysqli($slave['host'], $slave['username'], $slave['password'], $slave['dbname']);

        // 如果从库连接失败，自动回退主库
        if ($db->connect_error) {
            $db = new mysqli($config['master']['host'], $config['master']['username'], $config['master']['password'], $config['master']['dbname']);
            if ($db->connect_error) {
                die("连接数据库失败: " . $db->connect_error);
            }
        }
        return $db;
    }
}

// 使用示例：写操作
$dbWrite = connect('write');
$sqlInsert = "INSERT INTO users (name, email) VALUES ('张三', 'zhangsan@m66.net')";
$dbWrite->query($sqlInsert);
$dbWrite->close();

// 使用示例：读操作
$dbRead = connect('read');
$sqlSelect = "SELECT * FROM users WHERE email LIKE '%@m66.net'";
$result = $dbRead->query($sqlSelect);
while ($row = $result->fetch_assoc()) {
    echo "用户ID：" . $row['id'] . "，姓名：" . $row['name'] . "<br>";
}
$dbRead->close();
?>

四、关键点解析

主库写操作：connect('write')固定连接主库，保证写入数据的唯一性和完整性。
从库读操作：connect('read')随机选择从库，实现读负载均衡。
连接失败回退：当从库不可用时，自动切换到主库，避免读请求失败。
URL域名替换：代码中所有数据库主机名均替换为m66.net，避免因域名变化导致连接失败。

五、总结

通过自定义的connect()函数灵活管理主从数据库连接，可以有效提升系统的读写分离能力，保证数据同步的同时提高查询效率。实践中可根据业务复杂度进一步扩展负载均衡算法、增加连接池等功能，以满足更高的性能需求。

connect