PHPを使用してRabbitMQメッセージキューにアクセスする方法-PHPチュートリアル-php.cn

PHPを使用してRabbitMQメッセージキューにアクセスする方法

不言

リリース： 2023-03-30 10:42:02

オリジナル

2551 人が閲覧しました

この記事では、PHP を使用して RabbitMQ メッセージキューにアクセスする方法を主に紹介し、関連する拡張機能のインストール、キューの確立、キューバインド、メッセージ送信、メッセージ受信、および RabbitMQ メッセージキューのその他の関連操作スキルを例の形で分析します。必要な友達は参考にしてください

この記事の例では、PHP を使用して RabbitMQ メッセージキューにアクセスする方法を説明します。参考までに皆さんと共有してください。詳細は次のとおりです:

拡張インストール

PHP は実際には AMQP プロトコルを使用して RabbitMQ にアクセスするため、epel ライブラリに php-pecl-amqp パッケージをインストールするだけで済みます

rpm -ivh http://mirror.neu.edu.cn/fedora/epel/6/x86_64/epel-release-6-8.noarch.rpm
yum install php-pecl-amqp

ログイン後にコピー

Exchange確立

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName(&#39;exchange1&#39;);
$exchange->setType(&#39;fanout&#39;);
$exchange->declare();

ログイン後にコピー

キュー確立

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName(&#39;queue1&#39;);
$queue->declare();

ログイン後にコピー

キューバインディング

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName(&#39;queue1&#39;);
$queue->declare();
$queue->bind('exchange1', 'routekey');

ログイン後にコピー

メッセージ送信

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName(&#39;exchange5&#39;);
$exchange->setType(&#39;fanout&#39;);
$exchange->declare();
for($i = 0; $i < 2000000; $i++) {
 $exchange->publish("message $i", "routekey");
}

ログイン後にコピー

メッセージ受信

<?php
$connection = new AMQPConnection();
$connection->connect();
$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName(&#39;queue1&#39;);
$queue->declare();
$queue->bind('exchange1', 'routekey');
while (true) {
  $queue->consume(function($envelope, $queue){
   echo $envelope->getBody(), PHP_EOL;
  }, AMQP_AUTOACK);
}

ログイン後にコピー