PHPとrabbitmqを使用して信頼できるメッセージングを実装する方法：インストールからコードサンプルまで

概要

最新のアプリケーション開発では、メッセージングは​​重要なコミュニケーションメカニズムになりました。 Rabbitmqは、一般的なメッセージキューミドルウェアとして、効率的で信頼できるメッセージングを達成するのに役立ちます。この記事では、PHPとRabbitMQを使用してこのメ​​ッセージングメカニズムを実装する方法を説明し、すぐに開始するのに役立つコード例を提供します。

rabbitmqをインストールします

まず、rabbitmqをインストールする必要があります。オペレーティングシステムに従って対応するインストールパッケージを選択し、公式ドキュメントの手順に従ってインストールできます。インストールが完了したら、RabbitMQサービスが正常に開始されたことを確認してください。

PHP AMQP拡張機能をインストールします

PHPがRabbitMQと通信するためには、AMQP拡張機能をインストールする必要があります。次のコマンドを使用してインストールできます。

＃PECLコマンドを使用して$ PECLインストールamqpをインストールします

＃Composerを使用して$ Composerにインストールするには、php-amqplib/php-amqplibが必要です

rabbitmqに接続します

PHPでRabbitMQを接続する場合、ホスト、ポート、ユーザー名、パスワードなど、必要な接続パラメーターを提供する必要があります。ここに、接続を確立するための例コードを次に示します。

require_once __dir__。 '/vendor/autoload.php';

$ connection = new phpamqplib \ connection \ amqpstreamconnection（
    「LocalHost」、5672、「ゲスト」、「ゲスト」
）;

$ channel = $ connection-> channel（）;

メッセージキューを作成します

rabbitmqを使用する場合、最初にメッセージを保存するためのキューを作成する必要があります。次のコードは、PHPでキューを作成する方法を示しています。

$ queuename = 'my_queue'; //キュー名前$ channel-> queue_declare（$ queuename、false、true、false、false）;

メッセージを送信します

次のコードを使用して、作成されたキューにメッセージを送信できます。

$ msg = new phpamqplib \ message \ amqpmessage（ 'hello rabbitmq！'）;
$ channel-> basic_publish（$ msg、 ''、$ queuename）;

メッセージを受け取り、確認してください

メッセージの受信は、消費者を通じて行われます。これが消費者のサンプルコードです：

$ callback = function（$ msg）{
    echo '受信メッセージ：'。 $ msg-> body。 "\ n";
    $ msg-> deliviry_info ['channel']  - > basic_ack（$ msg-> delivery_info ['delivery_tag']）;
};

$ channel-> basic_consume（$ queuename、 ''、false、true、false、false、$ callback）;

while（count（$ channel-> callbacks））{
    $ channel-> wait（）;
}

このコードでは、メッセージを受信および処理するコールバック関数を作成します。メッセージを処理した後、 Basic_Ackメソッドを使用して、メッセージが正常に処理されたことを確認して、消費者が失敗してもメッセージが失われないようにします。

接続を閉じます

メッセージを完了した後、rabbitmqへの接続を閉じることを忘れないでください。

$ channel-> close（）;
$ connection-> close（）;

要約します

PHPとRabbitMQを組み合わせることにより、信頼できるメッセージングメカニズムを簡単に実装できます。この記事では、RabbitMQとAMQP拡張機能をインストールする方法について説明し、キューの作成、メッセージの送信、受信にPHPを使用する方法を詳細に示します。この記事が、RabbitMQを理解して使用してアプリケーションの信頼性を向上させるのに役立つことを願っています。