メッセージキューの処理と配布に PHP と RabbitMQ を使用する方法

インターネット ビジネスの継続的な発展に伴い、システム間のデータ交換がますます頻繁になってきました。従来のリクエスト/レスポンスアーキテクチャでは、データ転送方式は同期型、つまりリクエストのレスポンス結果を待ってから次のステップに進むことが多く、データ量が多い場合やリクエストのレスポンス時間が長い場合には、この方式が採用されないことがよくあります。システムのパフォーマンスが低下する原因となります。現時点では、メッセージ キューは、非同期、分離、優れたスケーラビリティの利点を実現できる理想的なソリューションになります。

RabbitMQ は、メッセージ キュー ミドルウェアとして豊富な API を提供し、複数のプログラミング言語をサポートします。その中で最も広く使用されているのは PHP です。この記事では、PHP 言語と RabbitMQ ミドルウェアを使用してメッセージ キューの処理と配布を実装する方法を紹介します。

1. RabbitMQ のインストール

まず、開発とテストを実行できるように、RabbitMQ サーバーをローカルにインストールする必要があります。詳細な説明は省略しますが、RabbitMQ 公式 Web サイトから対応するシステム用のインストール パッケージをダウンロードしてインストールできます。

2. PHP 拡張機能

RabbitMQ サーバーをインストールした後、PHP に RabbitMQ 拡張機能をインストールする必要があります。 Windows 環境では、php_amqp 拡張機能をダウンロードし、amqp.dll ファイルを PHP 拡張機能ディレクトリにコピーし、php.ini に次の構成を追加できます:

extension=php_amqp.dll

Linux 環境では、pecl またはソース コードのコンパイルを使用して RabbitMQ 拡張機能をインストールできます。具体的な手順については、公式ドキュメントを参照してください。

3. メッセージ キューの処理と配布に PHP を使用する

1. RabbitMQ サービスに接続します

接続を確立するには、amqp_connection オブジェクトを使用する必要がありますRabbitMQ サービスを使用します。基本構成には、サーバー アドレス、ポート番号、ユーザー名、パスワードなどが含まれます。コード例は次のとおりです。

$connection = new AMQPConnection([
    'host' => 'localhost',
    'port' => 5672,
    'login' => 'guest',
    'password' => 'guest',
]);
$connection->connect();

2. メッセージ キューの作成

$channel = new AMQPChannel($connection);
$queue = new AMQPQueue($channel);
$queue->setName('my_queue');
$queue->setFlags(AMQP_DURABLE);
$queue->declare();

Publish message

$exchange = new AMQPExchange($channel);
$exchange->declare('my_exchange', AMQPExchange::FANOUT, false, true);
$message = 'Hello RabbitMQ!';
$exchange->publish($message, 'my_routing_key');

メッセージの消費

$consumer = new AMQPConsumer($channel, $queue);
$consumer->setCallback(function (AMQPEnvelope $envelope, AMQPQueue $queue) {
    $message = $envelope->getBody();
    echo $message;
});
$consumer->consume();

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