ThinkPHP6 でメッセージキュー操作を実行するにはどうすればよいですか?-ThinkPHP-php.cn

ThinkPHP6 でメッセージキュー操作を実行するにはどうすればよいですか?

王林

リリース： 2023-06-12 09:14:23

オリジナル

2428 人が閲覧しました

インターネットの発展に伴い、アプリケーションのシナリオはますます複雑になり、パフォーマンス要件もますます高くなっています。メッセージキューは、同時実行性の高いシナリオでプログラムのパフォーマンスと安定性を向上させることができる典型的な非同期通信方法です。 PHP 言語では、ThinkPHP6 フレームワークでもメッセージキューのサポートが提供されています。この記事では、ThinkPHP6 でメッセージキューの操作を実行する方法を簡単に紹介します。

環境設定

まず、メッセージキューを使用する前に、メッセージキューコンポーネントまたはサーバーをインストールする必要があります。ここでは、RabbitMQ をメッセージキューサーバーとして使用します。 RabbitMQ をインストールするには、公式ドキュメントまたはその他のオンラインリソースを参照してください。

2 番目に、ThinkPHP6 では、composer: think-amqp を通じて公式に提供されているメッセージキューコンポーネントをインストールできます。ターミナルで次のコマンドを使用してインストールできます:

composer require topthink/think-amqp

ログイン後にコピー

構成ファイル

コンポーネントをインストールした後、amqp.php ファイルで関連する構成を行う必要があります。 config ディレクトリ内。例:

<?php
return [
    'default' => [
        'host'          => '127.0.0.1',
        'port'          => 5672,
        'vhost'         => '/',
        'login'         => 'guest',
        'password'      => 'guest',
        // 是否自动开启通道，默认为true
        'auto_declare'  => true,
        // 队列列表
        'queue_list'    => [
            'default'   => [
                'queue_name'    => 'default',
            ],
        ],
        // 交换机列表
        'exchange_list' => [
            'default'   => [
                'exchange_name' => 'default',
                // 默认使用direct交换机类型，也可以使用其他类型
                'exchange_type' => 'direct',
            ],
        ],
        // 绑定列表
        'bind_list'     => [
            'default'   => [
                'queue_name'    => 'default',
                'exchange_name' => 'default',
            ],
        ],
    ],
];

ログイン後にコピー

上記の設定ファイルでは、「default」が接続名で、配列には接続情報、キューリスト、スイッチリスト、バインディングリストが含まれています。キューリストとスイッチリストでは、複数のキューとスイッチ、およびそれらに関連する設定を定義できます。バインディングリストでは、キューとスイッチ間のバインディング関係を定義できます。

注: キュー名、スイッチ名、バインディング名を使用する場合は、それらが一意であることを確認する必要があります。

メッセージの送信

メッセージを送信するには、AMQP クラスのプロデューサーメソッドを使用できます。例:

<?php
namespace appindexcontroller;

use thinkmqpAMQP;

class Index
{
    public function index()
    {
        $config = config('amqp.default');
        $exchange_name = 'default';
        $routing_key = 'default';
        $message = "hello world";
        $producer = AMQP::instance($config)->producer($exchange_name, $routing_key);
        $producer->publish($message);
        echo "send message success";
    }
}

ログイン後にコピー

上記のコード, $config は上記の設定ファイルです。「デフォルト」接続情報の場合、$exchange_name はスイッチ名、$routing_key はルーティングキー、$message はメッセージの内容です。

メッセージの受信

メッセージを受信するには、AMQP クラスのコンシューマメソッドとコンシューマメソッドを使用する必要があります。例:

<?php
namespace appindexcontroller;

use thinkmqpAMQP;

class Index
{
    public function queue()
    {
        $config = config('amqp.default');
        $queue_name = 'default';
        $callback = function ($envelope, $queue) {
            $msg = $envelope->getBody();
            echo $msg."
";
            $queue->ack($envelope->getDeliveryTag());
        };
        $consumer = AMQP::instance($config)->consumer($queue_name);
        $consumer->consume($callback);
    }
}

ログイン後にコピー

上記の場合上記の設定ファイルの「デフォルト」接続情報の場合、$queue_name はキュー名、$callback はコールバック関数です。コールバック関数では、まずメッセージの内容を取得し、次に ack メソッドを実行してメッセージが消費されたことを示します。

概要

上記は、ThinkPHP6 でメッセージキューを使用する簡単な例です。メッセージキューを使用すると、プログラムを分離でき、システムのパフォーマンスと安定性を向上できます。その他のキューの種類、メッセージ確認メカニズム、クラスターソリューションについては、公式ドキュメントを参照して学習し、理解することができます。

以上がThinkPHP6 でメッセージキュー操作を実行するにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。