PHPmysql读写分离实现

<?php
// 主服务器配置
$master_host = 'master_host';
$master_user = 'master_user';
$master_pass = 'master_pass';
$master_db = 'master_db';

// 从服务器配置
$slave_hosts = [
    'slave_host1',
    'slave_host2',
    // 可以添加更多的从服务器
];

$slave_user = 'slave_user';
$slave_pass = 'slave_pass';
$slave_db = 'slave_db';

// 创建数据库连接
function connect($host, $user, $pass, $db) {
    $conn = new mysqli($host, $user, $pass, $db);
    if ($conn->connect_error) {
        die("连接失败: " . $conn->connect_error);
    }
    return $conn;
}

$master_conn = connect($master_host, $master_user, $master_pass, $master_db);

// 随机选择一个从服务器连接
$slave_conn = connect($slave_hosts[array_rand($slave_hosts)], $slave_user, $slave_pass, $slave_db);
?>

<?php
function execute_query($conn, $query) {
    return $conn->query($query);
}

// 写操作（例如插入数据）
function write_query($query) {
    global $master_conn;
    return execute_query($master_conn, $query);
}

// 读操作（例如查询数据）
function read_query($query) {
    global $slave_conn;
    return execute_query($slave_conn, $query);
}

// 示例：插入数据
write_query("INSERT INTO users (name, email) VALUES ('John Doe', 'john@example.com')");

// 示例：查询数据
$result = read_query("SELECT * FROM users");
while ($row = $result->fetch_assoc()) {
    echo $row['name'] . ' - ' . $row['email'] . '<br>';
}
?>