Bagaimanakah PHP melaksanakan baris gilir mesej dan pemprosesan tugas tak segerak?

Dengan perkembangan Internet, bilangan lawatan serentak ke tapak web dan aplikasi semakin banyak kali kita perlu menyelesaikan beberapa tugas yang memakan masa, seperti menghantar e-mel, memproses sejumlah besar data, dsb. Jika tugasan ini diproses semasa meminta dan membalas, ia akan menyebabkan pengguna menunggu terlalu lama dan menjejaskan pengalaman pengguna. Barisan beratur mesej dan pemprosesan tugas tak segerak boleh menyelesaikan masalah ini dengan berkesan.

Baris gilir mesej ialah kaedah penyampaian mesej Idea terasnya ialah meletakkan tugas atau mesej ke dalam baris gilir dan kemudian memproses tugas atau mesej ini secara tidak segerak. Terdapat banyak sistem baris gilir mesej matang dalam PHP, seperti RabbitMQ, Beanstalkd, dll. Sistem ini mempunyai ciri-ciri kebolehpercayaan yang tinggi dan skalabiliti yang kuat.

Mari perkenalkan cara menggunakan PHP untuk melaksanakan baris gilir mesej dan pemprosesan tugas tak segerak.

Pertama, kita perlu memasang sistem baris gilir mesej. Mengambil RabbitMQ sebagai contoh, anda boleh menggunakan komposer untuk memasang klien yang sepadan.

composer require php-amqplib/php-amqplib

Seterusnya, anda perlu mencipta penerbit mesej dalam PHP, yang bertanggungjawab untuk menolak tugasan ke baris gilir mesej.

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

// 创建连接
$connection = new PhpAmqpLibConnectionAMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

// 定义队列
$channel->queue_declare('task_queue', false, true, false, false);

// 创建一个回调函数来处理任务
$callback = function ($msg) {
  echo "接收到任务：" . $msg->body . "
";
  // 模拟耗时任务
  sleep(3);
  echo "处理完任务：" . $msg->body . "
";
  // 手动确认任务完成
  $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
};

// 设置预取计数（每次只处理一个任务）
$channel->basic_qos(null, 1, null);

// 监听队列并消费任务
$channel->basic_consume('task_queue', '', false, false, false, false, $callback);

// 不断监听队列直到没有任务为止
while ($channel->is_consuming()) {
  $channel->wait();
}

// 关闭连接
$channel->close();
$connection->close();
?>

Dalam kod di atas, kami mula-mula membuat sambungan dan mengisytiharkan baris gilir bernama "task_queue". Kemudian fungsi panggil balik ditakrifkan untuk memproses tugasan Selepas pemprosesan selesai, penyiapan tugasan disahkan secara manual. Akhir sekali, gunakan gelung sementara untuk memantau baris gilir secara berterusan sehingga tiada tugas yang tinggal.

Seterusnya, mari buat pengguna mesej untuk melaksanakan tugas yang memakan masa.

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

// 创建连接
$connection = new PhpAmqpLibConnectionAMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();

// 定义队列
$channel->queue_declare('task_queue', false, true, false, false);

// 设置预取计数（每次只处理一个任务）
$channel->basic_qos(null, 1, null);

// 创建一个回调函数来处理任务
$callback = function ($msg) {
  echo "接收到任务：" . $msg->body . "
";
  // 模拟耗时任务
  sleep(3);
  echo "处理完任务：" . $msg->body . "
";
  // 手动确认任务完成
  $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
};

// 监听队列并消费任务
$channel->basic_consume('task_queue', '', false, false, false, false, $callback);

// 不断监听队列直到没有任务为止
while ($channel->is_consuming()) {
  $channel->wait();
}

// 关闭连接
$channel->close();
$connection->close();
?>

Kod di atas pada asasnya adalah sama dengan kod penerbit mesej, kecuali tiada operasi manual untuk tugasan penerbitan, sebaliknya, ia mendengar baris gilir dan memprosesnya serta-merta sebaik sahaja tugasan masuk.

Dengan dua skrip yang diperoleh di atas, kami boleh meletakkan tugas yang memakan masa ke dalam baris gilir mesej tanpa menjejaskan respons halaman, dan kemudian biarkan pengguna memproses tugasan ini secara tidak segerak. Ini meningkatkan prestasi tapak web dan pengalaman pengguna.

Ringkasnya, PHP boleh melaksanakan pemprosesan tak segerak bagi tugasan yang memakan masa melalui baris gilir mesej dan pemprosesan tugas tak segerak. Pada masa yang sama, dengan menggunakan sistem baris gilir mesej yang matang, kebolehpercayaan dan kebolehskalaan tugasan boleh dipertingkatkan. Saya harap pengenalan di atas akan membantu anda memahami pelaksanaan PHP bagi baris gilir mesej dan pemprosesan tugas tak segerak.

Atas ialah kandungan terperinci Bagaimanakah PHP melaksanakan baris gilir mesej dan pemprosesan tugas tak segerak?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!