TP6 Think-Swoole の RPC サービスとメッセージ キューの統合とアプリケーション

TP6 Think-Swoole の RPC サービスとメッセージ キューの統合とアプリケーション

現代のソフトウェア開発では、RPC サービス (リモート プロシージャ コール) とメッセージ キューが一般的な技術的手段です。分散システムでのサービス呼び出しと非同期メッセージ処理を実現します。 Think-Swoole コンポーネントを TP6 フレームワークに統合すると、RPC サービスとメッセージ キューの機能を簡単に実装でき、開発者が理解して適用できる簡潔なコード例が提供されます。

1. RPC サービスの統合と使用

1. Swoole 拡張機能のインストール
   Think-Swoole の RPC サービスを統合する前に、まず Swoole 拡張機能をインストールする必要があります。 pecl コマンドを使用するか、ソース コードを手動でダウンロードしてコンパイルしてインストールできます。
2. 構成フレームワーク ファイル
   TP6 フレームワークの config/service.php ファイルを開き、次の構成項目を追加します。

return [
    // ... 其他配置项
    
    // RPC服务配置
    'rpc' => [
        // 默认的RPC服务器
        'default' => [
            'host' => '0.0.0.0',      // 监听地址
            'port' => 9501,           // 监听端口
            'worker_num' => 4,        // 工作进程数
            'package_max_length' => 2 * 1024 * 1024,    // 最大包长度
            'open_eof_check' => true, // 开启EOF检测
            'package_eof' => "

",    // 包结束标记
        ]
    ],
];

3. RPC サービス クラスの作成
   アプリケーションの app/rpc ディレクトリに TestRpc クラスを作成します。コードは次のとおりです:

namespace apppc;

class TestRpc
{
    public function hello($name)
    {
        return 'Hello, ' . $name;
    }
}

4. RPC サービスの登録
   app/rpc/SwooleRpc.php ファイルを開き、次のコードを追加します:

namespace apppc;

use thinkswooleRpcServer;
use thinkswoolepcProtocol;
use apppcTestRpc;

class SwooleRpc extends Server
{
    protected function register(): void
    {
        $protocol = new Protocol();
        $protocol->withServices([
            'TestRpc' => new TestRpc(),
        ]);

        $this->setProtocol($protocol);
    }
}

5. RPC サービスの開始
   ターミナルを開き、アプリケーションのルート ディレクトリに切り替えて、次のコマンドを実行して RPC サービスを開始します。

php think swoole:rpc

この時点で、RPC サービスは正常に統合されました。 RPC クライアントを使用して、サーバーにリクエストを送信し、対応するデータを受信できます。

6. RPC クライアントを使用する
   app の下にあるコントローラー ファイルを開き、次のコードを追加します:

namespace appcontroller;

use thinkswoolepcClient;

class Index
{
    public function index()
    {
        $rpc = new Client('http://127.0.0.1:9501');

        $result = $rpc->call('TestRpc', 'hello', ['Think-Swoole']);

        var_dump($result);

        return 'Hello, ThinkPHP6 + Think-Swoole';
    }
}

このように、# にアクセスするときに、 # #/index/index インターフェイスでは、リクエストは RPC クライアントを通じて RPC サーバーに送信され、結果が返されます。

Redis 拡張機能のインストール
1. Think-Swoole のメッセージ キューを統合する前に、Redis 拡張機能をインストールする必要があります。
   pecl コマンドを使用するか、ソース コードを手動でダウンロードしてコンパイルしてインストールできます。
設定フレームワーク ファイル
2. TP6 フレームワークの
   config/swoole_http.php ファイルを開き、次の設定項目を追加します。

return [
    // ... 其他配置项
    
    // 消息队列配置
    'mq' => [
        // 默认的消息队列服务器
        'default' => [
            'host' => 'localhost',      // 主机地址
            'port' => 6379,             // 端口号
            'auth' => 'your_password',   // 密码（可选）
            'db' => 0,                  // 数据库编号（可选）
            'timeout' => 1,             // 超时时间（可选）
        ]
    ],
];

ログイン後にコピー

メッセージ キューを作成する Consumer
3. は、アプリケーションの
   app ディレクトリの下に mq ディレクトリを作成し、Consumer.php ファイルを作成します。コードは次のとおりです。

namespace appmq;

use thinkswoolemqConsumerInterface;
use thinkswoolemqMessageInterface;
use thinkswoolemqMessageHandlerInterface;

class Consumer implements ConsumerInterface
{
    public function consume(MessageInterface $message, MessageHandlerInterface $handler): void
    {
        // 根据自己的业务逻辑处理消息
        $data = $message->getBody();

        $handler->callback(MessageHandlerInterface::ACK);
    }
}

ログイン後にコピー

メッセージ キュー コンシューマの登録
4. 
   config/event.php ファイルを開き、次の構成を追加します:

use appmqConsumer;

return [
    // ... 其他配置项
    
    // 注册消息队列事件
    'subscribe' => [
        'mq:TestQueue' => Consumer::class,    // TestQueue为消息队列的名称
    ],
];

ログイン後にコピー

メッセージの発行
5. コントローラー ファイルを開き、次のコードを追加します。
   

namespace appcontroller;

use thinkswoolemqPublisher;

class Index
{
    public function index()
    {
        $queue = 'TestQueue';
        $data = 'Hello, Think-Swoole';

        Publisher::publish($queue, $data);

        return 'Hello, ThinkPHP6 + Think-Swoole';
    }
}

ログイン後にコピー
このようにして、

/index/index インターフェイスにアクセスすると、メッセージはメッセージ キューにパブリッシュされ、コンシューマーは自動的にメッセージを受信して​​処理します。

この時点で、メッセージ キューが正常に統合されました。パブリッシングメッセージとコンシューマを組み合わせることで、効率的な非同期メッセージ処理を実現できます。
概要:

この記事では、Think-Swoole の RPC サービスとメッセージ キューを ThinkPHP6 フレームワークに統合する方法を紹介し、具体的なコード例を示します。これらの例を通じて、RPC サービスとメッセージ キューを簡単に使用して、システムのパフォーマンスとスケーラビリティを向上させることができます。この記事が、Think-Swoole の RPC サービスとメッセージ キューの理解と適用に役立つことを願っています。


以上がTP6 Think-Swoole の RPC サービスとメッセージ キューの統合とアプリケーションの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。