PHP のメッセージ キュー システム

インターネットの継続的な発展に伴い、Web アプリケーションのスケーラビリティに対する人々の要求もますます高まっています。この場合、Web アプリケーションが高い同時実行性と大規模なトラフィックをサポートできるようにする方法は、すべての Web プログラマーが直面しなければならない問題になります。この問題では、メッセージ キュー システムが不可欠な役割を果たしているのは明らかです。この記事では、PHP にメッセージ キュー システムを統合し、Web アプリケーションを最適化してアプリケーションのスケーラビリティを向上させる方法を紹介します。

メッセージキューシステムとは何ですか?

メッセージ キュー システムは、非同期、クロスプロセス、クロスサーバーの通信方法です。複数のシステム間でメッセージをやり取りすることでプロセスを分離および加速し、処理を高速化します。メッセージ キュー システムは、アプリケーションが他のアプリケーションと非同期に対話できるようにするメカニズムです。つまり、Web アプリケーションがメッセージ キューにメッセージを送信し、別のアプリケーションがメッセージ キューからメッセージを読み取ることができます。

メッセージ キュー システムを使用する理由

Web アプリケーションはさまざまなリクエストを処理する必要があり、処理する必要のあるリクエストもあれば、一時的に保留できるリクエストもあります。従来のアプリケーション システムは、次のリクエストのバッチを処理する前に、前処理が完了するまで待つ必要があります。そうすると、サーバー リソースが大量に無駄になります。

現時点では、メッセージ キューがこの問題の解決に役立ちます。メッセージ キューがあり、そのキューに複数のコンシューマがある場合、リクエストの処理をコンシューマに引き渡すことができます。 Web アプリケーションは単にリクエストをメッセージ キューにプッシュし、タスクが完了したことを通知します。

この場合、アプリケーションは生成タスクのみに集中する必要があり、コンシューマは処理タスクに集中する必要があります。これにより、処理プロセス全体が大幅に簡素化され、処理効率が向上し、サーバー リソースが節約されます。

PHP でメッセージ キュー システムを実装するにはどうすればよいですか?

PHP でメッセージ キュー システムを実装するには、メッセージ キュー エンジンと PHP のメッセージ キュー ソリューションを選択する必要があります。 3 つの一般的な PHP メッセージ キュー ソリューションを以下に示します:

1. Beanstalkd

Beanstalkd は、シンプル、高速、軽量の分散メッセージ キュー システムです。 Beanstalkd は、数百の消費プロセス間でタスクを分散できるため、非常に強力なソリューションになります。

PHP で Beanstalkd を使用するには、「Pheanstalk」ライブラリを使用できます。このライブラリは、Beanstalkd サーバーと通信するための使いやすいメソッドを提供します。

// 创建连接
$pheanstalk = new PheanstalkPheanstalk('127.0.0.1');
// 推送任务
$pheanstalk->useTube('mytube')->put('hello world');
// 获取任务
$job = $pheanstalk->watch('mytube')->ignore('default')->reserve();
echo $job->getData();

2. RabbitMQ

RabbitMQ は、オープン ソースの AMQP (Advanced Message Queue Protocol) メッセージ キュー システムです。 RabbitMQ には、非常に強力でスケーラブルなメッセージ ルーティング メカニズムが備わっています。複数のプログラミング言語をサポートしており、非常に優れたドキュメントとコミュニティ サポートが提供されています。

Beanstalkd とは異なり、RabbitMQ はサーバーにインストールする必要があるメッセージ キュー エンジンです。 「php-amqplib」ライブラリは、PHP との通信に使用されます。コードは次のとおりです:

// 建立连接
$connection = new PhpAmqpLibConnectionAMQPStreamConnection('localhost', 5672, 'guest', 'guest');
// 创建通道
$channel = $connection->channel();
// 声明队列
$channel->queue_declare('myqueue', false, false, false, false);
// 发送消息
$msg = new PhpAmqpLibMessageAMQPMessage('Hello World!');
$channel->basic_publish($msg, '', 'myqueue');
// 获取消息
$callback = function ($msg) {
    echo $msg->body;
};
$channel->basic_consume('myqueue', '', false, true, false, false, $callback);
while (count($channel->callbacks)) {
    $channel->wait();
}

3. Redis キュー サービス

Redis はキュー サービスとして使用できます。 Redisの「list」データ構造を利用してQueueを簡単に実装できます。 PHP では、事前に作成された「Predis」ライブラリを使用して Redis と通信できます。

// 初始化 Redis
$redis = new PredisClient([
    'scheme' => 'tcp',
    'host' => '127.0.0.1',
    'port' => 6379
]);
// 推送任务
$redis->rpush('myqueue', 'hello world');
// 获取任务
echo $redis->blpop('myqueue', 0)[1];

概要

この記事からわかるように、メッセージ キュー システムは、Web サイトのスケーラビリティとパフォーマンスを向上させることができる、非常に強力で適用可能なソリューションです。扱うワークロードのサイズに関係なく、PHP のメッセージ キュー システムを使用してさまざまな操作を簡単に処理できます。適切なメッセージ キュー エンジンと PHP メッセージ キュー ソリューションを使用すると、処理が高速化され、Web アプリケーションのスケーラビリティが向上します。

以上がPHP のメッセージ キュー システムの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。