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

不言
リリース: 2023-03-30 10:42:02
オリジナル
2537 人が閲覧しました

この記事では、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 サイトの他の関連記事を参照してください。

ソース:php.cn
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
最新の問題
人気のチュートリアル
詳細>
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート