Pembangunan PHP: menggunakan RabbitMQ untuk melaksanakan baris gilir tugas

Dengan pembangunan Internet yang berterusan, trafik laman web semakin meningkat, dan pertumbuhan dalam lawatan telah membawa lebih banyak masalah. Apabila bilangan pengguna terlalu besar, beban pelayan akan meningkat, dan beberapa cara teknikal perlu digunakan untuk menyelesaikan masalah ini. Barisan tugasan adalah salah satu daripadanya, yang boleh melakukan beberapa operasi yang memakan masa secara tidak segerak untuk melegakan tekanan pelayan. Artikel ini akan memperkenalkan cara menggunakan RabbitMQ untuk melaksanakan baris gilir tugas.

1. Apakah RabbitMQ

RabbitMQ ialah perisian tengah pemesejan sumber terbuka yang melaksanakan mekanisme pemesejan yang cekap dan pantas serta menyokong berbilang protokol pemesejan. Ia digunakan secara meluas dalam sistem teragih untuk menyelesaikan masalah penghantaran mesej tak segerak yang boleh dipercayai dalam sistem.

Mekanisme pemesejan RabbitMQ adalah berdasarkan protokol AMQP (Advanced Message Qeuing Protocol) ialah protokol pemesejan tak segerak yang menyediakan protokol lapisan pengangkutan yang bersatu, boleh dipercayai dan selamat untuk penghantaran mesej tak segerak dalam sistem konvensional .

2. Mengapa menggunakan RabbitMQ untuk melaksanakan baris gilir tugas

Dalam proses pembangunan sebenar, kami sering menghadapi beberapa operasi yang memakan masa, seperti memuat naik fail, menghantar e-mel, pemprosesan data, dsb. Jika operasi ini dilakukan secara langsung semasa tindak balas kepada permintaan pengguna, ia akan memberi tekanan besar pada prestasi pelayan, sekali gus menjejaskan pengalaman pengguna.

Oleh itu, kami boleh mempertimbangkan untuk menukar operasi yang memakan masa ini kepada operasi tak segerak dan meletakkannya dalam baris gilir tugas untuk pelaksanaan, dengan itu melepaskan sumber pelayan dan meningkatkan kelajuan tindak balas dan kestabilan sistem. RabbitMQ, sebagai perisian tengah mesej yang cekap dan boleh dipercayai, boleh mencapai fungsi ini dengan baik.

3. Cara menggunakan RabbitMQ untuk melaksanakan baris gilir tugasan

Mari kita ambil bahasa PHP sebagai contoh untuk memperkenalkan cara menggunakan RabbitMQ untuk melaksanakan baris gilir tugas.

1. Pasang sambungan RabbitMQ

Sebelum menggunakan RabbitMQ untuk melaksanakan baris gilir tugas, anda perlu memasang sambungan RabbitMQ untuk PHP. Berikut ialah arahan untuk memasang sambungan PHP RabbitMQ di bawah sistem Ubuntu:

sudo apt-get install php7.0-dev php-pear librabbitmq-dev
sudo pecl install amqp

2. Sambung ke RabbitMQ

Apabila menyambung ke RabbitMQ dalam PHP, anda perlu memasang sambungan AMQP dan gunakan kelas AMQPConnection Buat sambungan. Kodnya adalah seperti berikut:

$config = array(
    'host' => 'localhost',
    'port' => 5672,
    'login' => 'guest',
    'password' => 'guest',
    'vhost' => '/'
);

$connection = new AMQPConnection($config);
$connection->connect();

$channel = new AMQPChannel($connection);

Dalam kod ini, kami mencipta sambungan RabbitMQ dan mencipta saluran saluran. Saluran saluran digunakan untuk menghantar dan menerima mesej.

3. Buat baris gilir tugas

Dalam RabbitMQ, baris gilir tugasan terdiri daripada baris gilir mesej (Baris gilir), pengeluar (Pengeluar) dan pengguna (Pengguna). Pengeluar menambah tugas pada baris gilir mesej, dan pengguna memperoleh tugas daripada baris gilir mesej dan melaksanakannya.

Kod untuk membuat baris gilir adalah seperti berikut:

$queue = new AMQPQueue($channel);
$queue->setName('task_queue');
$queue->setFlags(AMQP_DURABLE);
$queue->declare();

Dalam kod ini, kami mencipta baris gilir mesej bernama task_queue dan menetapkan baris gilir sebagai baris gilir berterusan, walaupun RabbitMQ memulakan semula Data dalam barisan ini hilang.

4. Menghantar tugasan

Apabila menghantar tugasan ke baris gilir tugas dalam PHP, anda perlu menggunakan kelas AMQPExchange. Kodnya adalah seperti berikut:

$message = 'hello world';

$exchange = new AMQPExchange($channel);
$exchange->setName('task_exchange');
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->setFlags(AMQP_DURABLE);
$exchange->declare();
$exchange->publish($message, 'task', AMQP_NOPARAM, array('delivery_mode' => 2));

Dalam kod ini, kami mencipta suis bernama task_exchange dan menetapkan jenis suis kepada mengarahkan. Tentukan nama baris gilir sebagai tugas dan hantar mesej ke baris gilir. Pada masa yang sama, kami juga menetapkan mod penghantaran mesej kepada 2, iaitu, menetapkan mesej sebagai mesej berterusan untuk memastikan mesej tidak akan hilang walaupun RabbitMQ dimulakan semula.

5. Menerima tugasan

Apabila menerima tugasan dalam PHP, anda perlu mencipta pengguna dan mendengar mesej dalam baris gilir mesej. Kodnya adalah seperti berikut:

$consumer = new AMQPConsumer($channel, $queue);
$consumer->consume(function ($message) {
    sleep(2);
    echo $message->body, "
";
    $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);
});

Dalam kod ini, kami mencipta pengguna bernama $consumer dan mendengar mesej dalam baris gilir $queue. Apabila mesej diterima, kami mensimulasikan operasi yang memakan masa melalui fungsi sleep() dan mencetak kandungan mesej tersebut. Pada masa yang sama, kami juga memberitahu RabbitMQ melalui kaedah $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']) bahawa mesej telah digunakan, dengan itu memastikan bahawa mesej berjaya diproses.

4. Ringkasan

Menggunakan RabbitMQ untuk melaksanakan baris gilir tugas dapat melegakan tekanan pada pelayan dengan berkesan dan meningkatkan kelajuan tindak balas dan kestabilan sistem. Melalui pengenalan artikel ini, kami telah memahami konsep asas dan penggunaan RabbitMQ, dan menguasai teknologi menggunakan PHP untuk melaksanakan baris gilir tugasan, yang sangat penting untuk membangunkan aplikasi Internet berkonkurensi tinggi dan beban tinggi.

Atas ialah kandungan terperinci Pembangunan PHP: menggunakan RabbitMQ untuk melaksanakan baris gilir tugas. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!