ThinkPHP6 でキューテクノロジーを使用する方法

Web Web サイトの継続的な開発とユーザー数の増加に伴い、システムの同時処理能力とタスク スケジューリング機能が設計のボトルネックになっています。これらの問題を解決するために、Webシステムではキュー技術が広く使われています。

ThinkPHP6 は、タスクの非同期処理とスケジュール設定に使用できる強力なキュー テクノロジを提供する優れた PHP 開発フレームワークです。この記事では、ThinkPHP6 でキューテクノロジーを使用する方法を紹介します。

1. キュー テクノロジーの概要

キュー テクノロジーは、タスクを非同期処理する方法です。タスクをキューに送信すると、バックグラウンド プロセスまたはサーバーがこれらのタスクを非同期に処理して、タスクの負担を軽減します。問題はWebシステムの負荷圧迫です。

キュー テクノロジは、メッセージ キューとタスク キューの 2 つのカテゴリに分類できます。メッセージ キューは通常、メッセージ通知など、即時応答が必要なメッセージを処理するために使用されます。タスク キューは、時間と計算能力を必要とするタスクを非同期に処理するために使用されます。

ThinkPHP6 では、タスク キューは「キュー」と呼ばれ、メッセージ キュー ドライバーとログ バックエンドで構成されます。

2. キュー テクノロジの使用手順

1. メッセージ キュー ドライバーのインストール

メッセージ キュー ドライバーは、タスク キューの保存と処理に使用されるサーバー プログラムです。 。 ThinkPHP6 では、Redis、MySQL などの複数のメッセージ キュー ドライバーがサポートされています。

Redis メッセージ キューを例に挙げると、「topthink/think-queue」拡張パッケージと「predis/predis」拡張パッケージを ThinkPHP6 にインストールする必要があります。インストール コマンドは次のとおりです。

composer require topthink/think-queue
composer require predis/predis

2. Configure queueparameters

In ThinkPHP6 では、ドライバータイプ、ドライバーパラメーター、キュー名などを含むキューパラメーターを構成ファイルで設定する必要があります。設定ファイルのパスは「config/queue.php」です。

設定例:

return [

// 默认队列驱动：Redis
'default' => 'redis',

// 队列连接参数
'connections' => [
    'redis' => [
        'driver' => 'redis',
        'queue' => 'default', // 队列名称
        'connection' => 'default',
        'host' => '127.0.0.1',
        'port' => 6379,
        'password' => '',
        'database' => 0,
        'expire' => 60,
    ],
],

];

3. タスククラスの記述

ThinkPHP6 では、キュータスククラスは appjob ディレクトリにあります。タスク クラスには、タスクの特定のロジックを実行するために使用されるメソッド handle() が含まれている必要があります。

タスク クラスの例:

namespace appjob;

class SendEmail
{

public function handle($data)
{
    // 处理发送邮件任务的逻辑
    echo '发送邮件：' . $data['email'] . PHP_EOL;
}

}

4. タスクの送信キューへ

コードでは、Queue クラスの Push() メソッドまたは Delay() メソッドを呼び出すことで、タスクをキューに送信できます。 Push() メソッドはタスクをキューに直接送信しますが、Delay() メソッドはタスクを非同期に処理するための遅延時間を設定できます。

タスクの送信例:

use think acadeQueue;
use appjobSendEmail;

//非同期メール送信タスクの送信
$data = [

'email' => 'example@example.com',
'title' => '邮件标题',
'content' => '邮件内容',

];
$job = new SendEmail($data);
Queue::push($job);

// 遅延メール送信タスクを送信
$job = new SendEmail($data);
Queue::later(10, $job);

5. キューのバックグラウンド プロセスを開始します

最後に、コマンド ラインで実行します。キュー バックグラウンド プロセス コマンドを開始して、キュー タスクの実行を開始します:

php think queue:work

3. まとめ

キュー テクノロジは優れた Web システムです 非同期処理とタスク スケジューリングこれらの方法により、システムの同時処理能力とタスク スケジューリング能力が大幅に向上します。

ThinkPHP6 では、キュー テクノロジの使用は非常に簡単です。必要なのは、メッセージ キュー ドライバーをインストールし、キュー パラメーターを構成し、タスク クラスを作成してキューにタスクを送信し、最後にキューのバックグラウンド プロセスを開始することだけです。

この記事が、ThinkPHP6 のキュー テクノロジの理解と使用に役立つことを願っています。

以上がThinkPHP6 でキューテクノロジーを使用する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。