Bagaimana untuk melaksanakan pertanyaan yang diedarkan dan pengindeksan dalam perkhidmatan mikro PHP

Cara melaksanakan pertanyaan teragih dan pengindeksan dalam perkhidmatan mikro PHP

Dengan pembangunan aplikasi Internet, jumlah data semakin meningkat, dan pangkalan data bersendirian tidak lagi dapat memenuhi keperluan pertanyaan dan pengindeksan. Pertanyaan yang diedarkan dan pengindeksan menjadi salah satu penyelesaian. Artikel ini akan memperkenalkan cara melaksanakan pertanyaan dan pengindeksan teragih dalam perkhidmatan mikro PHP dan menyediakan contoh kod khusus.

1. Perisian data dan pertanyaan yang diedarkan

Dalam pertanyaan yang diedarkan, pemecahan data adalah sangat penting. Perkongsian data menyimpan data secara berselerak pada berbilang nod, dan setiap nod hanya menyimpan sebahagian daripada data, yang boleh mengurangkan tekanan beban pada satu nod. Dalam perkhidmatan mikro PHP, algoritma cincang sharding boleh digunakan untuk menyebarkan data ke nod pangkalan data yang berbeza.

Andaikan terdapat jadual pengguna yang mengandungi medan seperti ID pengguna, nama dan umur. Pertama, anda perlu menentukan bilangan serpihan, yang boleh dikira berdasarkan nilai cincang ID pengguna. Dengan mengandaikan bahawa bilangan serpihan ialah 3, anda boleh menggunakan kaedah berikut untuk mengira nombor serpihan:

function shard($id, $shardCount) {
    return crc32($id) % $shardCount;
}

Dengan mengandaikan bahawa ID pengguna ialah 1001, anda boleh menggunakan kod berikut untuk mendapatkan nombor serpihan di mana pengguna berada:

$shardCount = 3;
$userId = 1001;
$shardId = shard($userId, $shardCount);

Kemudian, anda boleh menggunakan nombor serpihan yang diperoleh , sambungkan nod pangkalan data yang sepadan untuk pertanyaan:

$databaseConfig = [
    ['host' => 'node1', 'user' => 'root', 'password' => 'password', 'database' => 'shard1'],
    ['host' => 'node2', 'user' => 'root', 'password' => 'password', 'database' => 'shard2'],
    ['host' => 'node3', 'user' => 'root', 'password' => 'password', 'database' => 'shard3'],
];

$connection = new PDO("mysql:host={$databaseConfig[$shardId]['host']};dbname={$databaseConfig[$shardId]['database']}", $databaseConfig[$shardId]['user'], $databaseConfig[$shardId]['password']);

// 查询用户信息
$userId = 1001;
$query = $connection->prepare("SELECT * FROM user WHERE id = :id");
$query->bindParam(':id', $userId);
$query->execute();

$user = $query->fetch(PDO::FETCH_ASSOC);

2. Indeks Teragih

Dalam pertanyaan teragih, menggunakan sharding untuk pertanyaan data boleh mengurangkan tekanan beban satu nod, tetapi dalam beberapa kes masih terdapat kesesakan prestasi . Sebagai contoh, apabila melakukan pertanyaan kabur pada medan tertentu, semua nod perlu dilalui untuk pemadanan, yang tidak cekap.

Untuk menyelesaikan masalah ini, indeks teragih boleh digunakan. Indeks teragih menyimpan data indeks secara berselerak pada berbilang nod, dan setiap nod hanya menyimpan sebahagian daripada data indeks. Dalam perkhidmatan mikro PHP, Redis boleh digunakan sebagai storan indeks teragih.

Andaikan anda ingin mencipta indeks teragih pada medan nama jadual pengguna, anda boleh menggunakan kaedah berikut:

$redisConfig = [
    ['host' => 'node1', 'port' => 6379],
    ['host' => 'node2', 'port' => 6379],
    ['host' => 'node3', 'port' => 6379],
];

$redis = new Redis();
$redis->connect($redisConfig[$shardId]['host'], $redisConfig[$shardId]['port']);

// 建立索引
$userId = 1001;
$userName = 'John';

$redis->sAdd("index:user:name:$userName", $userId);

Kemudian, anda boleh menggunakan indeks untuk melengkapkan pertanyaan yang diedarkan:

$userName = 'John';

// 获取索引中保存的用户ID
$userIdSet = $redis->sMembers("index:user:name:$userName");

// 查询用户信息
$query = $connection->prepare("SELECT * FROM user WHERE id IN (" . implode(',', $userIdSet) . ")");
$query->execute();

$users = $query->fetchAll(PDO::FETCH_ASSOC);

Dengan contoh kod di atas , pengedaran boleh dicapai dalam pertanyaan dan pengindeksan perkhidmatan mikro PHP. Menggunakan perkongsian data dan indeks teragih boleh meningkatkan prestasi pertanyaan dan indeks, dan boleh dikembangkan secara mendatar dengan menambahkan nod untuk memenuhi keperluan storan data yang semakin meningkat. Pada masa yang sama, perhatian perlu diberikan kepada isu seperti ketekalan data dan pemulihan kerosakan untuk memastikan kestabilan dan kebolehpercayaan sistem yang diedarkan.

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan pertanyaan yang diedarkan dan pengindeksan dalam perkhidmatan mikro PHP. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!