Bagaimana untuk membangunkan baris gilir mesej dalam PHP7.0?

Dengan kemajuan berterusan dan pembangunan teknologi Internet, untuk memastikan kecekapan dan kestabilan teknologi, pelbagai cara teknikal sentiasa dicadangkan dan digunakan. Antaranya, teknologi Message Queue (selepas ini dirujuk sebagai MQ) merupakan kaedah teknikal yang paling popular dan digunakan secara meluas. MQ bertujuan untuk menyelesaikan masalah komunikasi tak segerak antara modul berbeza dalam sistem, membolehkan gandingan longgar dan kebolehskalaan yang lebih baik antara aplikasi. Artikel ini akan memperkenalkan cara untuk membangunkan baris gilir mesej dalam PHP7.0.

1. Asas MQ

1 Konsep baris gilir Mesej

MQ ialah teknologi pemprosesan mesej atau tak segerak. Baris gilir mesej membenarkan komunikasi gandingan longgar antara penghantar dan penerima, meningkatkan kesalinghubungan dan kebolehselenggaraan antara aplikasi. MQ menggunakan middleware pihak ketiga untuk menghantar mesej ke baris gilir melalui pengeluar, dan pengguna mengekstrak mesej daripada baris gilir untuk penggunaan. MQ boleh digunakan dalam sistem teragih, sistem konkurensi tinggi dan senario tunggakan data.

2. Jenis baris gilir mesej

MQ termasuk berbilang jenis:

P2P: Komunikasi titik ke titik, pengeluar menghantar mesej ke baris gilir, yang diterima oleh seseorang Pengguna Penggunaan boleh memastikan kebolehpercayaan penyampaian mesej.

Pub/Sub: Terbitkan model langganan. Pengeluar menerbitkan mesej kepada topik, dan pelanggan melanggan mesej daripada topik dan menggunakannya, yang boleh mencapai keanjalan dan skalabiliti penghantaran mesej.

3. Komponen MQ

MQ terutamanya terdiri daripada komponen berikut:

Mesej: unit asas komposisi mesej

Pengeluar: penjana mesej

Pengguna: pengguna mesej

Baris gilir: kawasan storan mesej

Pertukaran: penghalaan mesej

Pengikatan: perhubungan mengikat mesej

dua , Bagaimana untuk membangunkan MQ dalam PHP7.0

1 Pasang RabbitMQ

RabbitMQ ialah pelaksanaan MQ popular yang boleh menyokong mod P2P dan Pub/Sub, dan menyokong pembangunan berbilang bahasa pengaturcaraan, kemudahan penggunaan yang tinggi. Menggunakan RabbitMQ dalam PHP7.0 memerlukan pemasangan sambungan PHP-AMQP. Langkah-langkahnya adalah seperti berikut:

(1) Muat turun dan unzip RabbitMQ, alamat laman web rasmi adalah seperti berikut: http://www.rabbitmq.com/

(2) Pasang Erlang: RabbitMQ dibangunkan berdasarkan bahasa Erlang, sila mula-mula pasang persekitaran Erlang

(3) Mulakan pelayan RabbitMQ:

$ sudo rabbitmq-server

(4) Pasang Sambungan PHP-AMQP:

$ pecl install amqp

Selepas pemasangan selesai, tambah item konfigurasi berikut dalam fail php.ini: extension=amqp.so

(5) Mulakan semula pelayan web untuk memastikan konfigurasi sambungan PHP-AMQP berkuat kuasa

2. Tulis kod

Untuk menggunakan RabbitMQ pada bahagian PHP, anda perlu memasang sambungan amqp dan komposer, dan kemudian pasang pakej amqp.

(1) Pasang pakej amqp

$ composer memerlukan php-amqplib/php-amqplib

(2) Kod pengeluar

Berikut ialah penggunaan Kod pengeluar PHP untuk menghantar mesej ke baris gilir:

Pertama, pelanggan perlu dibuat instantiated, seperti berikut:

$connection = new AMQPConnection();
$connection-> setHost('localhost');
$connection->setPort('5672');
$connection->setLogin('guest');
$connection->setPassword('tetamu' );
$connection->connect();

Pelaksanaan penghantaran mesej:

$exchange = 'test-exchange';
$queue = 'test-queue ';
$message = 'Hello World';
cuba {

$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName($exchange);
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declareExchange();
$queue = new AMQPQueue($channel);
$queue->setName($queue);
$queue->setFlags(AMQP_DURABLE);
$queue->declareQueue();
$queue->bind($exchange->getName(), $queue->getName());
$exchange->publish($message, $queue->getName());

}
tangkap (AMQPException $e) {

var_dump($e);

}
$connection- >disconnect();

Dalam kod di atas, baris gilir ujian dan pertukaran ujian penukar dicipta, kemudian baris gilir dan penukar terikat, dan kemudian mesej dihantar.

(3) Kod pengguna

Berikut ialah kod pengguna untuk menggunakan mesej daripada baris gilir:

Pertama, nyatakan pelanggan seperti berikut:

$connection = new AMQPConnection();
$connection->setHost('localhost');
$connection->setPort('5672');
$connection-> ;setLogin('guest ');
$connection->setPassword('guest');
$connection->connect();

Pelaksanaan penggunaan mesej:

$exchange = 'test-exchange';
$queue = 'test-queue';
cuba {

$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName($exchange);
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declareExchange();
$queue = new AMQPQueue($channel);
$queue->setName($queue);
$queue->setFlags(AMQP_DURABLE);
$queue->declareQueue();
$queue->bind($exchange->getName(), $queue->getName());
$queue->consume(function(AMQPEnvelope $message, AMQPQueue $queue) {
    echo $message->getBody();
    $queue->ack($message->getDeliveryTag());
});

}
catch (AMQPException $e) {

var_dump($e);

}
$connection->disconnect();

Dalam kod di atas, baris gilir ujian dan pertukaran ujian penukar dicipta, dan kemudian baris gilir dan penukar terikat , kemudian pengguna mendapat mesej daripada baris gilir dan mencetaknya ke konsol, dan mengesahkan bahawa mesej itu digunakan melalui kaedah $queue->ack().

3. Ringkasan

Artikel ini memperkenalkan cara membangunkan MQ dalam PHP7.0. Pertama, anda perlu memasang sambungan RabbitMQ dan PHP-AMQP kedua, anda perlu memasang komposer dan memasang pakej amqp akhirnya, tulis kod untuk melaksanakan penghantaran dan penggunaan mesej; Kemunculan teknologi MQ menyediakan kaedah penyampaian mesej yang lebih mudah dan cekap untuk aplikasi Internet Terutamanya dalam senario konkurensi tinggi dan sistem pengedaran, MQ adalah bahagian yang amat diperlukan. Dengan mempelajari artikel ini, saya berharap pembaca dapat memahami langkah-langkah khusus dan kaedah pelaksanaan pembangunan MQ dalam PHP7.0, dan memberikan rujukan untuk mencuba teknologi MQ dalam aplikasi perniagaan mereka sendiri.

Atas ialah kandungan terperinci Bagaimana untuk membangunkan baris gilir mesej dalam PHP7.0?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!