PHP キューを使用して分散メッセージ サブスクリプション システムを実装するにはどうすればよいですか?

PHP キューを使用して分散メッセージ サブスクリプション システムを実装するにはどうすればよいですか?

インターネットの普及と発展に伴い、高同時実行性と高可用性に対する要件はますます高くなっています。分散システムは、これらの問題を解決する効果的な方法となっています。この記事では、PHP キューを使用して分散メッセージ サブスクリプション システムを実装する方法を紹介し、具体的なコード例を示します。

1. キューについて理解する
キューは、先入れ先出し (FIFO) 原則に従う一般的に使用されるデータ構造です。分散システムでは、タスクの分離および非同期処理のシナリオでキューが広く使用されています。 PHP には、Redis、RabbitMQ など、成熟したキュー実装が多数あります。この記事では、例として Redis を使用して説明します。

2. 環境の構築
まず、Redis 環境を構築する必要があります。 Docker コンテナーを使用して迅速にビルドすることを選択できます。以下は Docker Compose の構成例です:

version: '3'
services:
  redis:
    image: redis
    ports:
      - 6379:6379

これを docker-compose.yaml ファイルとして保存し、# を実行します##docker-compose up ターミナルで -d コマンドを使用して Redis サービスを開始できます。

新しい PHP プロジェクトを作成し、Composer を使用して、
predis/predis などの Redis クライアント ライブラリを導入します。

composer require predis/predis

キューへのメッセージの送信は、分散メッセージ サブスクリプション システムの最初のステップです。以下は簡単なサンプル コードです。

<?php

require 'vendor/autoload.php';

use PredisClient;

$redis = new Client();
$message = [
    'id' => 1,
    'content' => 'This is a message',
];

$redis->lpush('messages', json_encode($message));

lpush メソッドを使用して、メッセージは messages という名前のキューにプッシュされます。

サブスクリプション メッセージは、分散型メッセージ サブスクリプション システムの 2 番目のステップです。以下は簡単なサンプル コードです。

<?php

require 'vendor/autoload.php';

use PredisClient;

$redis = new Client();
$pubsub = $redis->pubSubLoop();

$pubsub->subscribe('messages');

foreach ($pubsub as $message) {
    if ($message->kind === 'message') {
        $payload = json_decode($message->payload, true);
        echo $payload['content'] . PHP_EOL;
    }
}

pubSubLoop オブジェクトが作成されます。 subscribe メソッドを呼び出してキュー名を渡すことで、キューのメッセージをサブスクライブできます。最後に、foreach ループを通じてメッセージを受信し、メッセージの内容をコンソールに出力します。

send.php
と subscribe.php という名前の 2 つの PHP ファイルをそれぞれ作成し、上記のコードを対応するファイル。次に、ターミナルで次のコマンドを実行します。

php send.php
php subscribe.php