PHP实现数据库读写分离

在PHP中实现数据库读写分离，通常涉及以下几个步骤：配置主从数据库服务器、编写代码来分离读写操作、处理异常和错误等。以下是一个基本的实现示例：

1. 配置主从数据库服务器

首先，你需要配置主数据库（Master）和从数据库（Slave）。假设你已经有了这两个数据库服务器，并且它们已经正确配置并运行。

2. 编写代码来分离读写操作

你可以使用PHP的数据库扩展（如PDO或mysqli）来连接数据库，并根据SQL操作的类型（读或写）来选择连接到主库还是从库。

使用PDO示例：

<?php
$masterConfig = [
    'host' => 'master_host',
    'dbname' => 'database_name',
    'user' => 'username',
    'password' => 'password'
];

$slaveConfig = [
    'host' => 'slave_host',
    'dbname' => 'database_name',
    'user' => 'username',
    'password' => 'password'
];

function getConnection($isWrite) {
    if ($isWrite) {
        return new PDO($masterConfig['dsn'], $masterConfig['user'], $masterConfig['password']);
    } else {
        return new PDO($slaveConfig['dsn'], $slaveConfig['user'], $slaveConfig['password']);
    }
}

// 示例：读取操作
$query = "SELECT * FROM table_name";
$conn = getConnection(false); // false 表示读取操作
$stmt = $conn->prepare($query);
$stmt->execute();
$result = $stmt->fetchAll(PDO::FETCH_ASSOC);
print_r($result);

// 示例：写入操作
$query = "INSERT INTO table_name (column1, column2) VALUES (?, ?)";
$conn = getConnection(true); // true 表示写入操作
$stmt = $conn->prepare($query);
$stmt->execute(['value1', 'value2']);
?>

使用mysqli示例：

<?php
$masterConfig = [
    'host' => 'master_host',
    'dbname' => 'database_name',
    'user' => 'username',
    'password' => 'password'
];

$slaveConfig = [
    'host' => 'slave_host',
    'dbname' => 'database_name',
    'user' => 'username',
    'password' => 'password'
];

function getConnection($isWrite) {
    if ($isWrite) {
        $mysqli = new mysqli($masterConfig['host'], $masterConfig['user'], $masterConfig['password'], $masterConfig['dbname']);
        if ($mysqli->connect_error) {
            die('Connect Error (' . $mysqli->connect_errno . ') ' . $mysqli->connect_error);
        }
        return $mysqli;
    } else {
        $mysqli = new mysqli($slaveConfig['host'], $slaveConfig['user'], $slaveConfig['password'], $slaveConfig['dbname']);
        if ($mysqli->connect_error) {
            die('Connect Error (' . $mysqli->connect_errno . ') ' . $mysqli->connect_error);
        }
        return $mysqli;
    }
}

// 示例：读取操作
$query = "SELECT * FROM table_name";
$conn = getConnection(false); // false 表示读取操作
$result = $conn->query($query);
while ($row = $result->fetch_assoc()) {
    print_r($row);
}

// 示例：写入操作
$query = "INSERT INTO table_name (column1, column2) VALUES ('value1', 'value2')";
$conn = getConnection(true); // true 表示写入操作
if ($conn->query($query) === TRUE) {
    echo "New record created successfully";
} else {
    echo "Error: " . $query . "<br>" . $conn->error;
}
$conn->close();
?>

3. 处理异常和错误

在实际应用中，你需要处理可能出现的异常和错误，确保程序的健壮性。

4. 考虑连接池和性能优化

对于高并发应用，可以考虑使用连接池来管理数据库连接，以提高性能。

5. 监控和维护

定期监控主从数据库的状态，确保数据同步正常，及时处理可能出现的故障。

通过以上步骤，你可以在PHP中实现基本的数据库读写分离。根据具体需求，你可能需要进一步优化和扩展这个实现。