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

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

WBOY

リリース： 2023-10-20 09:43:47

オリジナル

1448 人が閲覧しました

メッセージキュー処理に 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 サイトの他の関連記事を参照してください。