PHP でのタスクのスケジュール設定とキュー管理に RabbitMQ を使用する方法-PHPチュートリアル-php.cn

PHP でのタスクのスケジュール設定とキュー管理に RabbitMQ を使用する方法

WBOY

リリース： 2023-07-18 09:36:01

オリジナル

1067 人が閲覧しました

PHP でのタスクのスケジュール設定とキュー管理に RabbitMQ を使用する方法

1. はじめに
Web アプリケーションを開発するとき、電子メールの送信やレポートの生成など、時間のかかるタスクを処理する必要があることがよくあります。 . 大量のデータの処理など。これらのタスクが Web リクエスト内で直接実行される場合、応答時間が遅くなり、ユーザーエクスペリエンスに影響が出る可能性があります。この問題を解決するには、タスクのスケジュール設定とキュー管理にメッセージキューを使用します。 RabbitMQ は、PHP で簡単に使用できる豊富な API を提供する強力なメッセージキューシステムです。

2. RabbitMQ のインストール
まず、サーバーに RabbitMQ をインストールする必要があります。公式 Web サイトで提供されているインストールチュートリアルに従ってインストールすることも、Docker を直接使用して RabbitMQ コンテナーを実行することもできます。インストールが完了したら、RabbitMQ 管理ページにアクセスしてキューのステータスを表示し、キューを管理できます。

3. 操作には PHP-amqplib ライブラリを使用します
PHP で RabbitMQ を使用するには、PHP-amqplib などのサードパーティライブラリを使用する必要があります。このライブラリは Composer を通じて導入できます。コマンドは次のとおりです:

composer require php-amqplib/php-amqplib

ログイン後にコピー

インストールが完了したら、ライブラリファイルをコードに導入します:

use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibMessageAMQPMessage;

ログイン後にコピー

4. RabbitMQ
に接続します。 RabbitMQ を使用する前に、まず接続する必要があります RabbitMQ サーバーに移動します:

$host = 'localhost';
$port = 5672;
$user = 'guest';
$pass = 'guest';
$connection = new AMQPStreamConnection($host, $port, $user, $pass);
$channel = $connection->channel();

ログイン後にコピー

デフォルトの RabbitMQ ホスト、ポート、ユーザー名、およびパスワードがここで使用されます。カスタマイズされた要件がある場合は、これらのパラメーターは実際の状況。

5. キューにメッセージを送信する
タスクのスケジューリングでは、通常、バックグラウンドワーカーによる消費のためにタスクをメッセージキューに送信します。次のコードを使用してメッセージをキューに送信できます。

$message = new AMQPMessage('hello world');
$channel->basic_publish($message, '', 'task_queue');

ログイン後にコピー

ここでは AMQPMessage インスタンスを作成し、送信するメッセージ本文を設定します。次に、basic_publish メソッドを使用して、task_queue という名前のキューにメッセージを送信します。

6. キュー内のメッセージを消費する
キュー内のメッセージを消費するには、処理のためにバックグラウンドで 1 つ以上のワーカープロセスを開始する必要があります。ワーカープロセスはキューからメッセージを取得し、対応するタスクを実行します。次のコードを使用して、キュー内のメッセージを消費できます。

$callback = function ($message) {
    echo "Received: " . $message->body . "
";
    usleep(100000);
    echo "Done
";
    $message->ack();
};
$channel->basic_consume('task_queue', '', false, false, false, false, $callback);
while (count($channel->callbacks)) {
    $channel->wait();
}

ログイン後にコピー

ここでは、匿名関数 $callback をメッセージ処理ロジックとして定義します。この関数では、特定のタスク処理を実行し、$message->ack() メソッドを呼び出してタスクが完了したことを示すことができます。なぜ ack メソッドが呼ばれるかというと、RabbitMQ はデフォルトではタスクが正常に実行されたかどうかがわからないため、タスクの実行結果を手動で確認する必要があります。

7. メッセージの永続性
上記の例では、メッセージの永続性はデフォルトでオフになっており、RabbitMQ サーバーを再起動すると、メッセージは失われます。サーバーの再起動後にメッセージを自動的に復元したい場合は、メッセージの永続化を実行する必要があります。次のコードで設定できます。

$channel->queue_declare('task_queue', false, true, false, false);

ログイン後にコピー

3 番目のパラメータを true に設定します。これは、キューが永続キューとして設定されることを意味します。

8. 遅延タスク
場合によっては、遅延タスクを実装し、指定された時間の後にタスクを実行する必要もあります。 RabbitMQ 自体はタスクを遅延させる機能をサポートしていませんが、追加のプラグインを追加することで実現できます。一般的に使用されるプラグインは、rabbitmq_layed_message_exchange です。これは、次の方法でインストールできます。

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

ログイン後にコピー

インストールが完了した後、メッセージを送信するときに、AMQPMessage のプロパティを次のように設定します。

$message->set('application_headers', ['x-delay' => 3000]);

ログイン後にコピー

上記のコードはメッセージ送信時に送信されます。実行を 3 秒遅らせます。

9. 概要
この記事の導入部を通じて、PHP でのタスクのスケジュール設定とキュー管理に RabbitMQ を使用する方法を学びました。上記の手順を実践すると、RabbitMQ を簡単に使用して時間のかかるタスクを処理し、アプリケーションのパフォーマンスと信頼性を向上させることができます。同時に、メッセージの永続性と遅延タスクの処理方法も導入され、さまざまなニーズに適切に対応できるようになります。この記事が実際のプロジェクトで RabbitMQ を使用する一助になれば幸いです。

参考資料: