キューを使用して ThinkPHP6 で非同期タスクを実装するにはどうすればよいですか?-ThinkPHP-php.cn

キューを使用して ThinkPHP6 で非同期タスクを実装するにはどうすればよいですか?

PHPz

リリース： 2023-06-12 10:46:40

オリジナル

2976 人が閲覧しました

インターネットアプリケーションと情報システムの継続的な開発に伴い、多くの企業は、複雑なロジックや高いパフォーマンス要件を伴う操作を処理するために非同期タスクを使用する必要があります。しかし、従来の同期処理方式ではシステム性能への負荷が大きくなるため、メッセージキューを利用した非同期タスク処理を実現することで解決できます。この記事では、キューを使用して ThinkPHP6 フレームワークで非同期タスクを実装する方法を紹介します。

1. インストールと構成

1.1 拡張機能をダウンロードしてインストールします

ThinkPHP6 では、Queue コンポーネントを使用してキュー処理を実装できます。次のように、composer.json ファイルに依存関係を追加してインストールします。

composer require topthink/think-queue

1.2 構成ファイル

インストールが成功した後、構成ファイルをプロジェクトに追加し、関連する構成を実行する必要があります。 config ディレクトリに新しい queue.php ファイルを作成し、次の設定項目を追加します。

return [
    'default' => env('queue.driver', 'sync'),

    'connections' => [
        'sync' => [
            'driver' => 'sync',
        ],
        'redis' => [
            'driver' => 'redis',
            'queue' => 'default',
            'connection' => 'default',
            'retry_after' => 90,
            'block_for' => null,
        ],
    ],
];

ログイン後にコピー

これは主に、キューのデフォルトのドライバと接続方法を設定するためのものです。このうち、同期 (sync) と Redis (redis) の 2 つの駆動方法をサポートしています。 Redis は、さまざまなデータ構造、特にキーと値のペア、リスト、セット、ハッシュ、その他のデータ構造をサポートできる分散型インメモリデータベースです。 ThinkPHP6 の Queue コンポーネントでは、メッセージキューの保存方法として Redis ドライバーを使用することもできます。

さらに、キュー名 (queue)、接続名 (connection)、再試行時間 (retry_after) など、キューに対して他の構成を実行することもできます。

上記の設定項目は、アプリケーション設定ファイル(config/app.php)や環境設定ファイルでも設定できます。

2. キュータスクの作成

ThinkPHP 6 の場合、ファクトリモードを使用してキュータスクを作成でき、同時に、キュータスクを継承することで特定のタスクロジックを実装できます。ジョブクラス。

2.1 ファクトリの作成

app/job ディレクトリに Job.php ファイルを作成し、特定のキューメッセージを処理するためのメソッドハンドルが含まれるメッセージキューのファクトリクラスを定義できます。が実装されています。具体的な実装は次のとおりです。

namespace appjob;

use thinkqueueJob;

class MyJob
{
    public function handle(Job $job, $data)
    {
        //... 具体任务处理逻辑
        //... 执行成功，删除该消息
        $job->delete();
    }
}

ログイン後にコピー

ここでは、ハンドルメソッドが特定のキューメッセージロジックの処理を担当する MyJob クラスを定義します。実行が成功したら、$job->delete() メソッドを呼び出してこのキューメッセージを削除できます。

2.2 タスクの作成

Job クラスを継承することで、処理する必要のあるタスクを作成できます。たとえば、SendEmail クラスを作成し、このタスクを使用して電子メールを送信できます。

namespace appjob;

use thinkqueueJob;

class SendEmail extends Job
{
    public function handle()
    {
        // ...具体的邮件发送逻辑
        // ...任务执行完成，删除该消息
        $this->delete();
    }
}

ログイン後にコピー

handle メソッドでは、特定の電子メール送信ロジックを記述することができます。同時に、最後に delete メソッドを呼び出して、正常に実行されたキューメッセージを削除することもできます。

3. タスクをキューに追加します

キュータスクを作成した後、後続の非同期処理のためにそれをメッセージキューに追加する必要があります。 ThinkPHP6 フレームワークでは、キューサービスプロバイダーを使用してタスクを追加できます。

app('queue')->push(new SendEmail());

ログイン後にコピー

ここでは、$app['queue'] を呼び出してキューサービスインスタンスを取得し、プッシュメソッドを通じて SendEmail タスクをキューに追加します。

4. タスクの監視と実行

タスクがキューに追加された後は、タスクのステータスを時間内に把握し、タイムリーに処理できる必要があります。この要件には、ThinkPHP6 の Artisan Console ツールを使用できます。これは Symfony Console コンポーネントに基づく拡張機能であり、コンソールを通じていくつかの特定のコマンドを実行できるようになります。

4.1 キュー監視の開始

コンソールを起動し、コマンドラインで次のコマンドを直接実行できます。

php think queue:work --daemon --queue default

ログイン後にコピー

その中で、--queue はキューの名前を指定します。カスタマイズ可能なキュー。 --daemon はバックグラウンドで実行することを意味します。

このコマンドを実行すると、キューの監視が開始され、キュー内のメッセージが 1 つずつ処理されます。

4.2 タスクの実行ステータスを監視する

キューの実行中に、モニターを使用してキューの実行ステータスを表示できます。コマンドラインで次のコマンドを実行します。

php think queue:listen --queue default --tries=3

ログイン後にコピー

このうち、--queue はキュー名を指定し、--tries はタスクのリトライ回数を指定します。

実行後、現在のメッセージキューのステータスと具体的な実行ステータスが出力されます。出力された情報に基づいて、タスクの状況をタイムリーに監視および処理できます。

5. 概要

キューを使用して非同期タスクを実装することにより、システムのパフォーマンスと安定性を効果的に向上させることができます。この記事では、ThinkPHP6 でキューを使用して非同期タスクを実装する方法を主に紹介し、キューの構成、タスクの作成と追加、キューの監視と実行について詳しく説明します。実際のアプリケーションで非同期タスクを処理する際に、皆様のお役に立てれば幸いです。

以上がキューを使用して ThinkPHP6 で非同期タスクを実装するにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。