Kaedah PHP untuk melaksanakan pemulihan kegagalan sharding pangkalan data

Dengan perkembangan pesat Internet, semakin banyak syarikat memindahkan sistem perniagaan ke awan dan menggunakan seni bina teragih untuk mengendalikan sejumlah besar data dan trafik serentak yang tinggi. Walau bagaimanapun, dalam seni bina yang diedarkan, pemulihan kerosakan menjadi lebih kompleks Terutamanya apabila kegagalan pangkalan data berpecah berlaku, data pada nod yang gagal perlu dipulihkan dalam masa, jika tidak, operasi perniagaan yang stabil mungkin terjejas dengan serius. Artikel ini akan memperkenalkan cara menggunakan PHP untuk mencapai pemulihan kegagalan sharding pangkalan data.

1. Kesan kegagalan pangkalan data berpecah

Sharding adalah untuk membahagikan sekeping data kepada berbilang subset dan menyimpannya dalam pelayan pangkalan data yang berbeza untuk mencapai tujuan storan dan pengimbangan beban teragih. Walau bagaimanapun, apabila pecahan tertentu gagal, ia akan menjejaskan operasi keseluruhan perniagaan.

Andaikan platform e-dagang mempunyai jadual pesanan pengguna yang diletakkan pada pangkalan data A yang dipecahkan, dan pangkalan data A yang dipecahkan tiba-tiba pada masa ini, keseluruhan pertanyaan pesanan pedagang dan proses pembayaran akan dihalang, dan pengguna tidak akan boleh berfungsi seperti biasa. Selesai tempahan dan pembayaran untuk produk. Oleh itu, dalam seni bina pangkalan data berpecah, pemulihan kegagalan menjadi sangat penting.

2. Proses PHP untuk merealisasikan pemulihan kegagalan sharding pangkalan data

Untuk menyelesaikan masalah kegagalan pangkalan data sharded, kami boleh menggunakan replikasi master-slave dan penyelesaian HA untuk mencapai failover dan pemulihan data. Berikut ialah proses untuk PHP melaksanakan pemulihan kegagalan sharding pangkalan data:

1 replikasi pangkalan data Master-slave

Replikasi master-slave mereplikasi data melalui log binari MySQL dan Tuliskannya ke dalam fail log binari, dan pangkalan data hamba menyalin fail log binari ke pelayannya sendiri untuk memastikan bahawa data dalam pangkalan data hamba adalah konsisten dengan pangkalan data induk. Dengan cara ini, selepas pangkalan data utama gagal, pangkalan data hamba boleh dengan cepat ditukar kepada pangkalan data utama untuk memastikan operasi sistem perniagaan yang stabil.

Penyelesaian 2.HA

Penyelesaian HA (Ketersediaan Tinggi) boleh menukar nod yang gagal secara automatik untuk memastikan kestabilan sistem perniagaan. Penyelesaian HA menggunakan VRRP (Virtual Router Redundancy Protocol) atau protokol lain untuk melaksanakan penukaran alamat IP maya.

Apabila nod didapati rosak, sistem HA secara automatik akan menghalakan alamat IP ke nod sandarannya. Pada masa ini, nod siap sedia secara automatik akan menjadi nod induk dan memulakan perkhidmatan replikasi untuk memastikan ketekalan data dan kebolehpercayaan yang tinggi.

3. Program pensuisan automatik

Program pensuisan automatik digunakan untuk memantau pangkalan data induk dan pangkalan data hamba Apabila pangkalan data induk gagal, ia akan bertukar secara automatik daripada pangkalan data hamba pangkalan data. Program pensuisan automatik boleh bertukar secara automatik tanpa campur tangan manual, supaya sistem perniagaan boleh terus beroperasi dengan stabil.

4. Prosedur pemulihan data

Sebaik sahaja kegagalan pangkalan data pecah berlaku, pemulihan kegagalan perlu dilakukan dengan cepat untuk memulihkan data dari nod siap sedia. Program pemulihan data boleh mengeksport data dari nod siap sedia ke nod yang gagal melalui arahan mysqldump MySQL untuk mencapai pemulihan data yang cepat.

3. Pelaksanaan kod PHP untuk pemulihan kegagalan sharding pangkalan data

Artikel ini menggunakan bahasa PHP sebagai contoh untuk menunjukkan pelaksanaan kod untuk pemulihan kegagalan sharding pangkalan data.

1. Konfigurasikan alamat IP maya pelayan induk-hamba dan penyelesaian HA:

$master_db_host = '192.168.1.1';
$master_db_user = 'root';
$master_db_pwd = '123456';
$master_db_name = 'orders';

$slave_db_host = '192.168.1.2';
$slave_db_user = 'root';
$slave_db_pwd = '123456';
$slave_db_name = 'orders';

$vip = '192.168.1.3';

2. Laksanakan fungsi replikasi induk-hamba, tetapkan pelayan induk dan pelayan hamba dalam pangkalan data, dan merealisasikan replikasi pangkalan data :

$dsn = "mysql:host=$master_db_host;dbname=$master_db_name";
$user = $master_db_user;
$pwd = $master_db_pwd;

try {
    $pdo = new PDO($dsn, $user, $pwd);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    $pdo->exec('SET NAMES utf8');
    $stmt = $pdo->query("SHOW MASTER STATUS");
    $master_status = $stmt->fetch(PDO::FETCH_ASSOC);
    $pdo = null;
} catch (PDOException $e) {
    echo 'Connection failed: ' . $e->getMessage();
}

$dsn = "mysql:host=$slave_db_host;dbname=$slave_db_name";

try {
    $pdo = new PDO($dsn, $slave_db_user, $slave_db_pwd);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    $pdo->exec('SET NAMES utf8');
    $stmt = $pdo->prepare("STOP SLAVE;");
    $stmt->execute();

    $stmt = $pdo->prepare("CHANGE MASTER TO MASTER_HOST=:host, "
            . "MASTER_USER=:user, MASTER_PASSWORD=:pwd, "
            . "MASTER_LOG_FILE=:log_file, MASTER_LOG_POS=:log_pos;");
    $stmt->bindParam(":host", $master_db_host, PDO::PARAM_STR);
    $stmt->bindParam(":user", $master_db_user, PDO::PARAM_STR);
    $stmt->bindParam(":pwd", $master_db_pwd, PDO::PARAM_STR);
    $stmt->bindParam(":log_file", $master_status['File'], PDO::PARAM_STR);
    $stmt->bindParam(":log_pos", $master_status['Position'], PDO::PARAM_INT);
    $stmt->execute();

    $stmt = $pdo->prepare("START SLAVE;");
    $stmt->execute();
} catch (PDOException $e) {
    echo 'Connection failed: ' . $e->getMessage();
}

3 Laksanakan penyelesaian HA dan tukar nod induk-hamba secara automatik:

exec("ifconfig eth1:$vip $vip netmask 255.255.255.255"); 
exec("route add -host $vip dev eth1:$vip");

4. pangkalan data hamba:

$dsn = "mysql:host=$master_db_host;dbname=$master_db_name";
$user = $master_db_user;
$pwd = $master_db_pwd;

try {
    $pdo = new PDO($dsn, $user, $pwd);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    $pdo->exec("SELECT 1 FROM DUAL;");
    $pdo = null;
} catch (PDOException $e) {
    echo 'Connection failed: ' . $e->getMessage();
    $dsn = "mysql:host=$slave_db_host;dbname=$slave_db_name";

    try {
        $pdo = new PDO($dsn, $slave_db_user, $slave_db_pwd);
        $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
        exec("ifconfig eth1:$vip down");
        exec("ifconfig eth1:$vip up");
    } catch (PDOException $e) {
        echo 'Connection failed: ' . $e->getMessage();
    }
}

5 Laksanakan program pemulihan data dan gunakan arahan mysqldump untuk mengeksport data dari nod siap sedia ke nod yang gagal:

$cmd = "/usr/bin/mysqldump -h $slave_db_host -u $slave_db_user -p$slave_db_pwd $slave_db_name orders | mysql -h $master_db_host -u $master_db_user -p$master_db_pwd $master_db_name";

exec($cmd);

4. Ringkasan

Pemulihan kerosakan seni bina teragih adalah lebih rumit daripada sistem yang berdiri sendiri Untuk kegagalan pangkalan data shard, kami boleh menggunakan penyelesaian master-slave dan HA untuk mencapai penukaran automatik dan pemulihan data yang cepat. Di atas adalah kaedah dan pelaksanaan kod pemulihan kesalahan pecahan pangkalan data menggunakan PHP Saya harap ia akan membantu pembaca dalam pemulihan kesalahan di bawah seni bina teragih.

Atas ialah kandungan terperinci Kaedah PHP untuk melaksanakan pemulihan kegagalan sharding pangkalan data. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!