Pembangunan PHP: Gunakan baris gilir mesej untuk menyelesaikan masalah konkurensi yang tinggi

Dengan perkembangan Internet, semakin banyak laman web dan aplikasi perlu mengendalikan sejumlah besar permintaan serentak. Sebagai bahasa skrip sebelah pelayan berprestasi tinggi, PHP secara semula jadi memainkan peranan yang semakin penting. Walau bagaimanapun, PHP mempunyai keupayaan pemprosesan serentak yang terhad Jika teknik pengoptimuman khas tidak digunakan, anda akan menghadapi masalah berikut:

1. Permintaan serentak yang tinggi akan menjadikan pelayan PHP sibuk, menyebabkan kelewatan permintaan dan pembaziran sumber.
2. Apabila memproses sejumlah besar permintaan, PHP akan menduduki banyak memori dan sumber CPU, menyebabkan prestasi pelayan merosot.

Untuk menyelesaikan masalah ini, kami boleh menggunakan teknologi baris gilir mesej. Baris gilir mesej ialah mekanisme komunikasi tak segerak yang boleh memproses permintaan secara tak segerak, dengan itu mengelakkan pelayan PHP daripada menyekat semasa memproses permintaan. Di bawah ini kita akan menyelidiki cara menggunakan baris gilir mesej untuk meningkatkan keupayaan pemprosesan serentak aplikasi PHP.

Pengenalan kepada baris gilir mesej

Baris gilir mesej ialah mekanisme komunikasi tak segerak, biasanya terdiri daripada komponen seperti pengeluar, pengguna dan baris gilir. Pengeluar boleh menghantar mesej ke baris gilir, dan pengguna boleh mendapatkan mesej daripada baris gilir dan memprosesnya. Baris gilir mesej menyelesaikan masalah pemprosesan tugas tak segerak, dengan itu mengelakkan kemerosotan prestasi yang disebabkan oleh terlalu banyak permintaan.

Dalam PHP, kami boleh menggunakan banyak perisian baris gilir mesej pihak ketiga, seperti RabbitMQ, Kafka, ActiveMQ, dll. Perisian ini menyediakan API yang kaya dan perpustakaan pelanggan untuk memudahkan kami melaksanakan fungsi baris gilir mesej dalam aplikasi PHP.

Langkah untuk menggunakan baris gilir mesej untuk menyelesaikan masalah serentak yang tinggi

1. Pasang perisian baris gilir mesej

Sebelum mula menggunakan baris gilir mesej, kita perlu memasang perisian baris gilir Mesej yang sepadan. Mengambil RabbitMQ sebagai contoh, kita boleh menggunakan arahan berikut untuk memasang RabbitMQ:

sudo apt-get install rabbitmq-server

2. Tulis kod pengeluar

Pengeluar ialah program yang menghantar mesej kepada mesej daripada PHP kod Hantar mesej dalam baris gilir. Dalam RabbitMQ, kita boleh menggunakan perpustakaan klien PHP php-amqplib untuk melaksanakan fungsi pengeluar. Mula-mula, kita perlu memperkenalkan perpustakaan php-amqplib ke dalam program PHP:

require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;

Kemudian, kita perlu membuat sambungan AMQP dan mencipta baris gilir bernama test_queue:

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->queue_declare('test_queue', false, true, false, false);

Akhir sekali, kita boleh Hantar mesej ke baris gilir:

$msg = new AMQPMessage('Hello World!');
$channel->basic_publish($msg, '', 'test_queue');

Kod ini akan menghantar mesej kepada baris gilir bernama test_queue.

3. Menulis kod pengguna

Pengguna ialah program yang menerima mesej, mendapatkannya daripada baris gilir dan memprosesnya. Dalam RabbitMQ, kita boleh menggunakan perpustakaan klien PHP php-amqplib untuk melaksanakan fungsi pengguna. Mula-mula, kita perlu memperkenalkan perpustakaan php-amqplib ke dalam program PHP:

require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;

Kemudian, kita perlu mencipta sambungan AMQP dan mentakrifkan fungsi panggil balik untuk memproses mesej yang diperoleh daripada baris gilir:

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->queue_declare('test_queue', false, true, false, false);
$callback = function($msg) {
  echo "Received ", $msg->body, "
";
};

Kemudian, kita boleh mendengar mesej dalam baris gilir dalam program pengguna:

$channel->basic_consume('test_queue', '', false, true, false, false, $callback);
while(count($channel->callbacks)) {
  $channel->wait();
}

Kod ini akan memulakan gelung tak terhingga dan memantau sama ada terdapat mesej yang tiba dalam baris gilir bernama test_queue. Jika terdapat mesej dalam baris gilir, fungsi panggil balik yang ditentukan dipanggil untuk memproses mesej.

4. Melaksanakan pemprosesan teragih

Dalam aplikasi PHP, kami biasanya perlu menggunakan berbilang pelayan PHP untuk mengendalikan trafik. Untuk mencapai pemprosesan teragih bagi baris gilir mesej, kami boleh menggunakan teknologi berikut:

a.

b. Gunakan alat caching seperti Redis untuk berkongsi hasil pemprosesan dan mengelakkan pemprosesan mesej berulang.

c. Gunakan alat pengimbangan beban untuk mengedarkan permintaan bagi memastikan setiap pelayan PHP boleh menerima peluang untuk memproses permintaan.

Ringkasan

Menggunakan baris gilir mesej boleh menyelesaikan masalah prestasi aplikasi PHP apabila mengendalikan permintaan serentak yang tinggi. Dengan melaksanakan pengeluar dan pengguna, permintaan diproses secara tidak segerak dalam baris gilir, dengan itu mengelakkan masalah seperti sumber pelayan yang sibuk dan menyekat permintaan. Pada masa yang sama, kami juga boleh menggunakan teknologi pemprosesan teragih untuk meningkatkan keupayaan pemprosesan serentak aplikasi PHP. Baris gilir mesej ialah salah satu teknologi penting dalam aplikasi Internet moden pengaturcara PHP juga harus mahir dalam teknologi ini untuk menyumbang dengan lebih baik kepada pembangunan aplikasi Internet.

Atas ialah kandungan terperinci Pembangunan PHP: Gunakan baris gilir mesej untuk menyelesaikan masalah konkurensi yang tinggi. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!