この記事では、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('exchange1'); $exchange->setType('fanout'); $exchange->declare();
キュー確立
<?php $connection = new AMQPConnection(); $connection->connect(); $channel = new AMQPChannel($connection); $queue = new AMQPQueue($channel); $queue->setName('queue1'); $queue->declare();
キューバインディング
<?php $connection = new AMQPConnection(); $connection->connect(); $channel = new AMQPChannel($connection); $queue = new AMQPQueue($channel); $queue->setName('queue1'); $queue->declare(); $queue->bind('exchange1', 'routekey');
メッセージ送信
<?php $connection = new AMQPConnection(); $connection->connect(); $channel = new AMQPChannel($connection); $exchange = new AMQPExchange($channel); $exchange->setName('exchange5'); $exchange->setType('fanout'); $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('queue1'); $queue->declare(); $queue->bind('exchange1', 'routekey'); while (true) { $queue->consume(function($envelope, $queue){ echo $envelope->getBody(), PHP_EOL; }, AMQP_AUTOACK); }
関連推奨事項:
以上がPHPを使用してRabbitMQメッセージキューにアクセスする方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。