PHP中MySQL的讀寫分離實現

在PHP中實現MySQL的讀寫分離，通常涉及到主從復制（Master-Slave Replication）的概念。以下是一個基本的實現步驟和示例代碼：

1. 配置MySQL主從復制

首先，你需要配置MySQL的主從復制。假設你有一個主數據庫（Master）和一個從數據庫（Slave）。

主數據庫（Master）配置

編輯my.cnf或my.ini文件：

[mysqld]
server-id=1
log-bin=mysql-bin
binlog-do-db=your_database_name

重啟MySQL服務使配置生效。

從數據庫（Slave）配置

編輯my.cnf或my.ini文件：

[mysqld]
server-id=2
relay-log=mysql-relay-bin
log-slave-updates=1
read-only=1

重啟MySQL服務使配置生效。

2. 獲取主數據庫的復制狀態

連接到主數據庫并獲取當前的復制狀態：

<?php
$master_host = 'master_host_ip';
$master_user = 'master_username';
$master_password = 'master_password';
$master_db = 'your_database_name';

$conn = new mysqli($master_host, $master_user, $master_password, $master_db);

if ($conn->connect_error) {
    die('Connection failed: ' . $conn->connect_error);
}

$sql = "SHOW SLAVE STATUS\G";
$result = $conn->query($sql);

if ($result->num_rows > 0) {
    while($row = $result->fetch_assoc()) {
        echo "Slave_IO_Running: " . $row['Slave_IO_Running'] . "\n";
        echo "Slave_SQL_Running: " . $row['Slave_SQL_Running'] . "\n";
        if ($row['Slave_IO_Running'] == 'Yes' && $row['Slave_SQL_Running'] == 'Yes') {
            echo "Replication is running.\n";
        } else {
            echo "Replication is not running.\n";
        }
    }
} else {
    echo "Error: " . $sql . "<br>" . $conn->error;
}

$conn->close();
?>

3. 實現讀寫分離

根據讀取和寫入操作選擇不同的數據庫連接。

寫入操作（寫主庫）

<?php
$write_host = 'master_host_ip';
$write_user = 'master_username';
$write_password = 'master_password';
$write_db = 'your_database_name';

$write_conn = new mysqli($write_host, $write_user, $write_password, $write_db);

if ($write_conn->connect_error) {
    die('Connection failed: ' . $write_conn->connect_error);
}

// 插入數據示例
$sql = "INSERT INTO your_table (column1, column2) VALUES ('value1', 'value2')";
if ($write_conn->query($sql) === TRUE) {
    echo "New record created successfully";
} else {
    echo "Error: " . $sql . "<br>" . $write_conn->error;
}

$write_conn->close();
?>

讀取操作（讀從庫）

<?php
$read_host = 'slave_host_ip';
$read_user = 'slave_username';
$read_password = 'slave_password';
$read_db = 'your_database_name';

$read_conn = new mysqli($read_host, $read_user, $read_password, $read_db);

if ($read_conn->connect_error) {
    die('Connection failed: ' . $read_conn->connect_error);
}

// 查詢數據示例
$sql = "SELECT * FROM your_table";
$result = $read_conn->query($sql);

if ($result->num_rows > 0) {
    while($row = $result->fetch_assoc()) {
        echo "id: " . $row["id"]. " - Name: " . $row["name"]. "<br>";
    }
} else {
    echo "0 results";
}

$read_conn->close();
?>

4. 使用連接池（可選）

為了提高性能和穩定性，可以考慮使用連接池來管理數據庫連接。PHP中有許多連接池庫，如PDO或HikariCP。

總結

以上是一個基本的MySQL讀寫分離實現示例。實際應用中可能需要更多的錯誤處理和優化，例如使用連接池、監控復制狀態、自動故障轉移等。