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

この記事では、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);
}

関連推奨事項:

PHPメッセージキューサービス

以上がPHPを使用してRabbitMQメッセージキューにアクセスする方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。