Bagaimana untuk melaksanakan pemberitahuan mesej yang diedarkan dan tolak dalam perkhidmatan mikro PHP

Berikut ialah kaedah pelaksanaan pemberitahuan mesej teragih dan tolak berdasarkan perkhidmatan mikro PHP, termasuk contoh kod terperinci.

Tajuk: Pemberitahuan mesej yang diedarkan dan pelaksanaan tolak dalam perkhidmatan mikro PHP

Pengenalan:
Dengan peningkatan seni bina perkhidmatan mikro, semakin banyak aplikasi Seni bina teragih diguna pakai untuk mencapai pemisahan sistem dan penyahgandingan perkhidmatan. Dalam sistem yang diedarkan, pemberitahuan mesej dan tolak adalah keperluan yang sangat biasa untuk komunikasi tak segerak antara perkhidmatan yang berbeza. Untuk perkhidmatan mikro PHP, cara melaksanakan pemberitahuan dan tolak mesej yang diedarkan adalah tugas yang penting dan mencabar. Artikel ini akan memperkenalkan kaedah untuk melaksanakan pemberitahuan mesej yang diedarkan dan menolak dalam perkhidmatan mikro PHP, dan memberikan contoh kod yang sepadan.

1. Menggunakan baris gilir mesej

1. Memasang dan mengkonfigurasi baris gilir mesej
   Dalam perkhidmatan mikro PHP, kami boleh menggunakan beberapa sistem baris gilir mesej yang popular, Seperti RabbitMQ , Kafka, dsb. Pertama, sistem baris gilir mesej yang sepadan perlu dipasang dan dikonfigurasikan pada pelayan. Mengambil RabbitMQ sebagai contoh, anda boleh memasangnya melalui arahan berikut:

# 安装依赖
sudo apt-get install -y curl gnupg debian-archive-keyring apt-transport-https
# 添加RabbitMQ官方GPG key
curl https://packages.rabbitmq.com/rabbitmq-release-signing-key.asc | sudo apt-key add -
# 添加RabbitMQ的APT源
echo "deb https://dl.bintray.com/rabbitmq/debian $(lsb_release -cs) main" | sudo tee /etc/apt/sources.list.d/bintray.rabbitmq.list
# 更新APT源
sudo apt-get update
# 安装RabbitMQ Server
sudo apt-get install -y rabbitmq-server

2. Buat baris gilir dan suis
   Selepas pemasangan selesai, anda boleh menggunakan Antara muka pengurusan RabbitMQ atau alat baris arahan membuat baris gilir dan suis. Sebagai contoh, anda boleh membuat baris gilir bernama "pemberitahuan" dan pertukaran bernama "pertukaran" menggunakan arahan berikut: Dalam kod PHP, anda boleh menggunakan perpustakaan klien RabbitMQ untuk menghantar dan menerima mesej. Pertama, anda perlu memasang perpustakaan klien RabbitMQ yang sepadan. Ia boleh dipasang melalui Komposer:

# 创建队列
sudo rabbitmqctl add_queue notification
# 创建交换机
sudo rabbitmqctl add_exchange exchange

Seterusnya, anda boleh menggunakan contoh kod berikut untuk menghantar mesej:

3. composer require php-amqplib/php-amqplib

   Salin selepas log masuk
   
   Berikut adalah contoh kod untuk diterima mesej: #🎜 🎜#

   <?php
   require_once __DIR__ . '/vendor/autoload.php';
   
   $connection = new PhpAmqpLibConnectionAMQPStreamConnection('localhost', 5672, 'guest', 'guest');
   $channel = $connection->channel();
   
   $channel->exchange_declare('exchange', 'direct', false, false, false);
   
   $message = 'Hello, world!';
   $channel->basic_publish(new PhpAmqpLibMessageAMQPMessage($message), 'exchange', 'notification');
   
   $channel->close();
   $connection->close();

   Salin selepas log masuk
2 Gunakan perkhidmatan tolak

Daftar dan konfigurasikan perkhidmatan tolak

Pasang Push SDK

1. <?php
   require_once __DIR__ . '/vendor/autoload.php';
   
   $connection = new PhpAmqpLibConnectionAMQPStreamConnection('localhost', 5672, 'guest', 'guest');
   $channel = $connection->channel();
   
   $channel->exchange_declare('exchange', 'direct', false, false, false);
   list($queue_name, ,) = $channel->queue_declare('', false, false, true, false);
   $channel->queue_bind($queue_name, 'exchange', 'notification');
   
   $callback = function ($msg) {
       echo 'Received message: ' . $msg->body;
   };
   
   $channel->basic_consume($queue_name, '', false, true, false, false, $callback);
   
   while ($channel->is_consuming()) {
       $channel->wait();
   }
   
   $channel->close();
   $connection->close();

   Salin selepas log masuk
   
   
Hantar mesej tekan
2. Anda boleh menghantar mesej tolak melalui contoh kod berikut:
   

composer require alibabacloud/sdk

Salin selepas log masuk
#🎜 🎜#Ringkasan: Dengan menggunakan baris gilir mesej dan perkhidmatan tolak, kami boleh melaksanakan pemberitahuan mesej teragih dan fungsi tolak dalam perkhidmatan mikro PHP. Sama ada anda menggunakan perkhidmatan baris gilir mesej atau tolak, anda perlu memasang, mengkonfigurasi dan memanggil API yang sepadan dengan sewajarnya. Membiasakan diri dengan konsep asas dan kaedah pengendalian ini boleh membantu kami melaksanakan fungsi pemberitahuan dan tolak mesej dengan lebih baik dalam sistem teragih serta meningkatkan kebolehpercayaan dan prestasi aplikasi. Sudah tentu, berdasarkan keperluan sebenar, kami juga boleh memilih penyelesaian lain yang sesuai untuk melaksanakan pemberitahuan dan tolak mesej yang diedarkan.

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan pemberitahuan mesej yang diedarkan dan tolak dalam perkhidmatan mikro PHP. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!