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

1. インストールと構(gòu)成

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

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

composer require topthink/think-queue

1.2 構(gòu)成ファイル

インストールが成功した後、構(gòu)成ファイルをプロジェクトに追加し、関連する構(gòu)成を?qū)g行する必要があります。 config ディレクトリに新しい queue.php ファイルを作成し、次の設(shè)定項(xiàng)目を追加します。

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

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

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

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

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

2. キュー タスクの作成

ThinkPHP 6 の場(chǎng)合、ファクトリ モードを使用してキュー タスクを作成でき、同時(shí)に、キュー タスクを継承することで特定のタスク ロジックを?qū)g裝できます。ジョブクラス。

2.1 ファクトリの作成

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

namespace appjob;

use thinkqueueJob;

class MyJob
{
    public function handle(Job $job, $data)
    {
        //... 具體任務(wù)處理邏輯
        //... 執(zhí)行成功，刪除該消息
        $job->delete();
    }
}

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

2.2 タスクの作成

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

namespace appjob;

use thinkqueueJob;

class SendEmail extends Job
{
    public function handle()
    {
        // ...具體的郵件發(fā)送邏輯
        // ...任務(wù)執(zhí)行完成，刪除該消息
        $this->delete();
    }
}

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

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

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

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

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

4. タスクの監(jiān)視と実行

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

4.1 キュー監(jiān)視の開(kāi)始

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

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

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

このコマンドを?qū)g行すると、キューの監(jiān)視が開(kāi)始され、キュー內(nèi)のメッセージが 1 つずつ処理されます。

4.2 タスクの実行ステータスを監(jiān)視する

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

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

このうち、--queue はキュー名を指定し、--tries はタスクのリトライ回?cái)?shù)を指定します。

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

5. 概要

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

以上がキューを使用して ThinkPHP6 で非同期タスクを?qū)g裝するにはどうすればよいですか?の詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國(guó)語(yǔ) Web サイトの他の関連記事を參照してください。