ThinkPHP6を使用してメッセージキューを実装する-ThinkPHP-php.cn

ThinkPHP6を使用してメッセージキューを実装する

PHPz

リリース： 2023-06-21 17:51:39

オリジナル

2798 人が閲覧しました

インターネットとビッグデータ時代の到来により、メッセージキューはビジネス開発とデータ処理に不可欠な部分になりました。 PHP の分野では、ThinkPHP フレームワークは開発者の間で常に人気のある選択肢です。この記事では、ThinkPHP6 を使用してメッセージキューを実装する方法を紹介し、いくつかの実用的なコード例を示します。

メッセージキュー拡張機能のインストール

メッセージキューの作成を開始する前に、メッセージキュー拡張機能 (RabbitMQ や Beanstalkd など) をインストールする必要があります。

1.1 Erlang のインストール

RabbitMQ は Erlang 言語で開発されているため、最初に Erlang をインストールする必要があります。

1.2 RabbitMQ のインストール

RabbitMQ をインストールする前に、最初に wget および gnupg ツールをインストールする必要があります。ターミナルで次のコマンドを実行します:

sudo apt-get install wget gnupg -y

ログイン後にコピー

次に、RabbitMQ をダウンロードしてインストールします。 :

wget -O - "https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkey" | sudo apt-key add -
sudo tee /etc/apt/sources.list.d/bintray.rabbitmq.list <<EOF
deb https://dl.bintray.com/rabbitmq-erlang/debian buster erlang
deb https://dl.bintray.com/rabbitmq/debian buster main
EOF
sudo apt-get update -y
sudo apt-get install rabbitmq-server -y

ログイン後にコピー

キューとコンシューマの作成

ThinkPHP6 では、Worker (ワーカープロセス) を使用してキューとコンシューマを作成できます。具体的な手順は次のとおりです:

2.1 ワーカーモードをオンにする

config ディレクトリの app.php ファイルで、次のコードセグメントを見つけます:

    'worker' => [
        'type'  => 'socket',   // 驱动方式
        'host'  => '0.0.0.0',  // 监听地址
        'port'  => 2345,       // 监听端口
    ],

ログイン後にコピー

これを次の内容に変更します:

    'worker' => [
        'type'      => 'rabbitmq',
        'host'      => 'localhost',
        'port'      => 5672,
        'user'      => 'guest',
        'password'  => 'guest',
        'vhost'     => '/',
        'exchange'  => 'test',  // 交换机名称
        'queue'     => 'test',  // 队列名称
    ],

ログイン後にコピー

ここにドライバーがあります。モードが Rabbitmq に変更され、RabbitMQ 接続の関連構成情報 (ローカルアドレス、ユーザー名、パスワードなど) およびスイッチとキューの名前が指定されます。

2.2 メッセージプロデューサーの作成

アプリディレクトリに Task という名前のコントローラーを作成します。メソッドは send と呼ばれます。コードは次のとおりです:

namespace appcontroller;

use thinkworkerServer;

class Task extends Server
{
    public function send()
    {
        $data = ['name'=>'ThinkPHP','score'=>100];
        $this->worker->push(json_encode($data));
    }
}

ログイン後にコピー

ここでは、Json を使用しますデータはメッセージキューにプッシュされます。

2.3 メッセージコンシューマーの作成

アプリディレクトリに Worker という名前のコントローラーを作成します。メソッドの名前は onMessage です。コードは次のとおりです。

namespace appcontroller;

use thinkworkerServer;

class Worker extends Server
{
    public function onMessage($connection, $data)
    {
        // 处理逻辑
    }
}

ログイン後にコピー

onMessage メソッド内, 受信したメッセージを処理するロジックをカスタマイズできます。たとえば、データを解析してデータベースに保存し、テキストメッセージや電子メール通知をユーザーに送信できます。