メッセージ キュー処理に Hyperf フレームワークを使用する方法

メッセージ キュー処理に Hyperf フレームワークを使用する方法

はじめに:
インターネットと分散システムの発展に伴い、メッセージ キューは重要な役割を果たします。大規模アプリケーションの特徴。メッセージ キューは、非同期処理、デカップリング、ピークシェービング、バレーフィリングなどのシナリオで使用できます。開発時に適切なメッセージ キュー フレームワークを選択すると、システムのパフォーマンスと保守性が大幅に向上します。 Hyperf フレームワークは、高性能 PHP フレームワークとして、主流のメッセージ キュー システムをサポートするだけでなく、豊富な機能と便利な使用法も提供します。この記事では、メッセージ キューの構成および使用方法、具体的なコード例など、メッセージ キュー処理に Hyperf フレームワークを使用する方法を紹介します。

1. メッセージ キューの設定
Hyperf フレームワークでは、設定ファイル config/autoload/queue.php を通じてメッセージ キューを設定できます。まず、メッセージ キュー ドライバーを選択する必要があります。Hyperf フレームワークでサポートされるメッセージ キュー ドライバーには、RabbitMQ、Redis、NSQ などのオプションが含まれます。たとえば、メッセージ キュー ドライバーとして Redis を使用することを選択した場合、次のように構成できます。

<?php

return [
    'default' => env('QUEUE_DRIVER', 'redis'),
    'connections' => [
        'redis' => [
            'driver' => HyperfAsyncQueueDriverRedisDriver::class,
            'channel' => 'default',
            'redis' => [
                'pool' => 'default',
            ],
        ],
    ],
];

上記の構成では、default はデフォルトのメッセージ キュー ドライバーを表し、redis は Redis ドライバーの使用を表します。次に、ドライバー クラスや Redis 接続プールなどの Redis 関連のパラメーターが connections 配列で構成されます。この構成ファイルを変更することで、特定のニーズに合わせてさまざまなメッセージ キュー ドライバーを柔軟に選択できます。

2. メッセージとタスクの定義
メッセージ キューを使用する前に、最初にメッセージとタスクを定義する必要があります。メッセージは処理されるコンテンツであり、タスクはメッセージに対する特定の操作です。 Hyperf フレームワークでは、HyperfAsyncQueueMessageInterface インターフェイスを継承してメッセージを定義し、HyperfAsyncQueueJob クラスを継承してタスクを定義できます。たとえば、電子メールを送信するためのメッセージとタスクを定義します。

<?php

use HyperfAsyncQueueJob;
use HyperfAsyncQueueMessageInterface;

class SendEmailMessage implements MessageInterface
{
    protected $email;

    public function __construct($email)
    {
        $this->email = $email;
    }

    public function getName(): string
    {
        return 'send_email';
    }

    public function getPayload(): array
    {
        return ['email' => $this->email];
    }
}

class SendEmailJob extends Job
{
    public function __construct($email)
    {
        $this->message = new SendEmailMessage($email);
    }

    public function handle()
    {
        $email = $this->message->getPayload()['email'];
        // 发送邮件的具体逻辑
    }

    public function failed(Throwable $e)
    {
        // 处理任务执行失败的情况
    }
}

上記のコードでは、SendEmailMessage クラスは MessageInterface インターフェイスを継承し、getName を実装します。 メソッドと getPayload メソッドは、それぞれメッセージの名前とパラメーターを取得するために使用されます。 SendEmailJob クラスは、Job クラスを継承し、メール送信ロジックの処理に使用される handle メソッドを実装します。タスクの実行が失敗した場合は、failed メソッドを通じて処理できます。

3. メッセージの生成とタスクの利用
Hyperf フレームワークでは、HyperfAsyncQueueDriverDriverFactory クラスを使用してメッセージ キュー ドライバーをインスタンス化し、->push($ job) メッセージを生成するメソッド。たとえば、コントローラーで電子メールを送信するメッセージを生成できます。

<?php

use HyperfAsyncQueueDriverDriverFactory;

class EmailController
{
    public function send()
    {
        $driverFactory = new DriverFactory();
        $driver = $driverFactory->getDriver();
        $driver->push(new SendEmailJob('example@example.com'));
    }
}

上記のコードでは、DriverFactory クラスをインスタンス化してメッセージ キュー ドライバーを取得し、# を使用します。 ## Push メソッドは、SendEmailJob タスクをキューに追加します。

同時に、キュー内のタスクを処理するコンシューマーも定義する必要があります。 Hyperf フレームワークでは、

bin/hyperf.php コマンドを使用してコンシューマを起動できます。たとえば、コマンド ラインで次のコマンドを実行してコンシューマを起動します。

$ php bin/hyperf.php consume async-queue

上記のコマンドを実行すると、コンシューマはメッセージ キューのリッスンとタスクの処理を開始します。キューにタスクがある場合、コンシューマーは、処理するタスクに対応する

handle メソッドを自動的に呼び出します。

4. カスタム コンシューマ

デフォルトのコンシューマを使用することに加えて、特定のニーズに合わせてコンシューマをカスタマイズすることもできます。 Hyperf フレームワークでは、
HyperfAsyncQueueConsumer クラスを継承することで独自のコンシューマーを定義できます。たとえば、テキスト メッセージを送信するコンシューマーを定義します。

<?php

use HyperfAsyncQueueConsumer;
use HyperfAsyncQueueDriverDriverFactory;

class SmsConsumer extends Consumer
{
    protected function getDriver(): HyperfAsyncQueueDriverDriverInterface
    {
        $driverFactory = new DriverFactory();
        return $driverFactory->getDriver();
    }

    protected function getTopics(): array
    {
        return ['send_sms'];
    }
}

上記のコードでは、

Consumer クラスを継承し、getDriver と getTopics # を実装します。 ＃＃ 方法。 getDriver このメソッドはメッセージ キュー ドライバーを返します。このメソッドで使用されるメッセージ キュー ドライバー クラスを指定できます。 getTopics このメソッドは、リッスンするキューの名前を返します。 次に、コマンド ラインで次のコマンドを実行してカスタム コンシューマーを開始します。

$ php bin/hyperf.php consume sms-consumer

上記のコマンドを実行すると、カスタム コンシューマーは指定されたメッセージ キューのリッスンを開始し、タスクを処理します。 。

結論:

上記の手順により、Hyperf フレームワークのメッセージ キューを使用してタスクの非同期処理を行うことができます。まず、構成ファイルで適切なメッセージ キュー ドライバーを選択し、それに応じて構成する必要があります。次に、メッセージとタスクを定義し、メッセージ キュー ドライバーを使用してメッセージを生成します。最後に、デフォルト コンシューマまたはカスタム コンシューマを使用してキュー内のタスクを処理できます。メッセージ キューの処理に Hyperf フレームワークを使用すると、システムのパフォーマンスと保守性が向上するだけでなく、非同期処理、デカップリング、ピークシェービング、バレーフィル シナリオのニーズを満たすこともできます。

コード例:

GitHub ウェアハウス アドレス: https://github.com/example/hyperf-async-queue-demo

上記は、Hyperf フレームワークを使用する方法についてです。メッセージ キューの処理 はじめに、お役に立てば幸いです。

以上がメッセージ キュー処理に Hyperf フレームワークを使用する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。