Kaedah pembangunan untuk mencapai pemprosesan tugas tak segerak berprestasi tinggi melalui baris gilir mesej PHP

Kaedah pembangunan untuk mencapai pemprosesan tugas tak segerak berprestasi tinggi melalui baris gilir mesej PHP

Dengan perkembangan pesat Internet, keperluan prestasi pelbagai laman web dan aplikasi juga semakin tinggi dan lebih tinggi. Dalam pembangunan sebenar, terdapat banyak situasi di mana tugas yang memakan masa perlu diproses, seperti menghantar sejumlah besar e-mel, menjana laporan, dsb. Tugasan ini boleh mengurangkan prestasi laman web dengan banyak atau menyebabkan sumber pelayan kehabisan.

Untuk menyelesaikan masalah ini, kami boleh menggunakan baris gilir mesej untuk melaksanakan pemprosesan tugasan tak segerak. Baris gilir mesej ialah kaedah komunikasi berdasarkan model pengeluar-pengguna Pengeluar bertanggungjawab untuk menolak mesej ke baris gilir, dan pengguna bertanggungjawab untuk mengalih keluar mesej daripada baris gilir dan memprosesnya.

Dalam pembangunan PHP, kami boleh menggunakan beberapa perisian baris gilir mesej matang, seperti RabbitMQ, Kafka, dll. Mari kita ambil RabbitMQ sebagai contoh untuk memperkenalkan kaedah pembangunan bagaimana untuk mencapai pemprosesan tugas tak segerak berprestasi tinggi melalui baris gilir mesej PHP.

Pertama, kita perlu memasang RabbitMQ dan memulakan perkhidmatan. Anda boleh memuat turun pakej pemasangan RabbitMQ dari laman web rasmi dan memasang serta mengkonfigurasinya mengikut dokumentasi.

Seterusnya, kita perlu memperkenalkan perpustakaan klien RabbitMQ ke dalam projek PHP. Anda boleh menggunakan Komposer untuk menguruskan kebergantungan projek Jalankan arahan berikut untuk memasang perpustakaan klien PHP RabbitMQ:

composer require php-amqplib/php-amqplib

Selepas pemasangan selesai, kami boleh menulis kod PHP untuk menggunakan RabbitMQ untuk menghantar dan menerima mesej. Yang pertama ialah kod untuk menghantar mesej Contohnya adalah seperti berikut:

require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;

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

$channel->queue_declare('task_queue', false, true, false, false);

$message = new AMQPMessage('Hello World!', ['delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT]);
$channel->basic_publish($message, '', 'task_queue');

$channel->close();
$connection->close();

Kod di atas mula-mula membuat sambungan dengan RabbitMQ dan mencipta saluran melalui sambungan. Kemudian baris gilir bernama "task_queue" diisytiharkan, yang akan mengekalkan mesej.

Seterusnya, mesej (AMQPMessage) dibuat dan sifat kegigihan mesej ditetapkan. Akhir sekali, gunakan kaedah basic_publish untuk menghantar mesej ke baris gilir.

Berikut ialah contoh kod untuk menerima mesej:

require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLibConnectionAMQPStreamConnection;

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

$channel->queue_declare('task_queue', false, true, false, false);

$channel->basic_qos(null, 1, null);
$channel->basic_consume('task_queue', '', false, false, false, false, function ($msg) {
    // 处理任务
    echo $msg->body . "
";
    sleep(5);
    echo "Finish task
";

    //确认消息已经被消费
    $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
});

while (count($channel->callbacks)) {
    $channel->wait();
}

Kod di atas juga membuat sambungan dan saluran dengan RabbitMQ terlebih dahulu Selepas mengisytiharkan baris gilir "task_queue", kaedah basic_qos dipanggil untuk menetapkan pengimbangan beban pengguna. Kemudian fungsi panggil balik pengguna didaftarkan melalui kaedah basic_consume, yang digunakan untuk memproses mesej yang diterima.

Dalam fungsi panggil balik, kami mula-mula mengeluarkan kandungan mesej ($msg->body), dan kemudian mensimulasikan pemprosesan tugas untuk mengambil masa tertentu Di sini kami menggunakan fungsi tidur untuk menjeda selama 5 saat. Akhir sekali, panggil kaedah $msg->delivery_info['channel']->basic_ack untuk mengesahkan bahawa mesej telah digunakan.

Akhir sekali, kami menggunakan gelung sementara untuk mendengar mesej dalam baris gilir sehingga tiada mesej dalam baris gilir.

Dengan kod di atas, kami boleh menggunakan baris gilir mesej PHP dengan mudah untuk melaksanakan pemprosesan tugas tak segerak berprestasi tinggi.

Ringkasnya, baris gilir mesej PHP ialah cara yang cekap untuk mengendalikan tugas yang memakan masa, yang boleh meningkatkan prestasi tapak web atau aplikasi dengan sangat baik. Melalui perisian baris gilir mesej seperti RabbitMQ, kita boleh menggunakan kod PHP dengan mudah untuk menghantar dan menerima mesej. Saya harap artikel ini akan membantu anda memahami cara untuk mencapai pemprosesan tugas tak segerak berprestasi tinggi melalui baris gilir mesej PHP.

Atas ialah kandungan terperinci Kaedah pembangunan untuk mencapai pemprosesan tugas tak segerak berprestasi tinggi melalui baris gilir mesej PHP. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!