ThinkPHP6 と Swoole で構築された非同期 RPC サービス-ThinkPHP-php.cn

ThinkPHP6 と Swoole で構築された非同期 RPC サービス

PHPz

リリース： 2023-10-12 11:10:41

オリジナル

1116 人が閲覧しました

ThinkPHP6 と Swoole で構築された非同期 RPC サービス

ThinkPHP6 と Swoole を使用して構築された非同期 RPC サービス

はじめに:
インターネットの発展と普及に伴い、分散システムの適用はますます増えています。分散システムでは、RPC (リモートプロシージャコール) は、異なるサービス間の通信を実現する重要な方法の 1 つです。従来の RPC は通常、同期要求応答モードを採用しています。つまり、呼び出し元は RPC 要求を開始し、応答結果が返されるのを待ちます。ただし、同期 RPC モードには、リクエスタが応答結果が返されるまで待つ必要があるため、リクエスタがブロックされ、システムのパフォーマンスに影響を与えるなど、いくつかの欠点があります。この問題を解決するために、非同期 RPC モードを使用できます。つまり、リクエスタがリクエストを送信した後、レスポンス結果が返されるのを待つ必要がなく、他のリクエストの処理を続行し、応答が返されるのを待つことができます。処理前に返される応答結果。この記事では、ThinkPHP6 と Swoole を使用して非同期 RPC サービスを構築する方法と、具体的なコード例を紹介します。

1. 非同期 RPC の概念と原理
非同期 RPC は、結果が返されるのを待つ必要のない RPC メソッドであり、同期 RPC と比較してパフォーマンスと同時実行パフォーマンスが優れています。非同期 RPC モードでは、呼び出し元がリクエストを送信した後、リモートサービスが結果を返すのを待つ必要がなく、他のビジネスロジックの実行を続けることができます。リモートサービスがリクエストを処理して結果を返すと、呼び出し元はコールバック通知を受け取ります。

非同期 RPC の基本原理は次のとおりです。

呼び出し元はリモートサービスにリクエストを送信します。
リモートサービスはリクエストを受信した後、リクエストをメッセージキューに入れます。
呼び出し元は一意の識別子をリモートサービスに返します。
リモートサービスはリクエストを処理し、結果をメッセージキューに入れます。
リモートサービスは呼び出し元に通知を非同期に送信し、通知にはリクエストの一意の識別子が指定されます。
呼び出し元は通知を受信すると、識別子に従ってメッセージキューから結果を取得します。

2. ThinkPHP6 と Swoole を使用して非同期 RPC サービスを構築する手順
このセクションでは、次の手順に従って、ThinkPHP6 と Swoole を使用して非同期 RPC サービスを構築します。

ThinkPHP6 と Swoole のインストール
まず、ThinkPHP6 と Swoole をインストールする必要があります。 ThinkPHP6 は、次のコマンドでインストールできます。

composer create-project topthink/think app

ログイン後にコピー

次に、次のコマンドで Swoole をインストールします。

composer require swoole/swoole

ログイン後にコピー

ThinkPHP6 の Swoole サーバーを構成します。 ThinkPHP6## のファイル #config/server.php
で、Swoole サーバーの関連パラメーターを設定します。たとえば、サーバーの IP アドレス、ポート番号、ワーカープロセスの数などを構成できます。
```
'swoole' => [
    // 监听的地址
    'host' => '127.0.0.1',
    // 监听的端口
    'port' => 9501,
    // 工作进程数
    'worker_num' => 4,
],
```
ログイン後にコピー

非同期 RPC サービスの作成

use SwooleHttpServer;
use SwooleProcess;

class RpcController
{
    public function index()
    {
        $server = new Server('127.0.0.1', 9501);
        $server->on('request', function ($request, $response) {
            // 处理请求并返回结果
            $result = $this->handleRequest($request);
            // 将结果放入消息队列中
            $this->putToQueue($result);
            // 异步发送通知给调用方
            $this->sendNotification($response);
        });
        // 启动RPC服务器
        $server->start();
    }

    private function handleRequest($request)
    {
        // 处理请求并返回结果
        // ...
    }

    private function putToQueue($result)
    {
        // 将结果放入消息队列中
        // ...
    }

    private function sendNotification($response)
    {
        // 异步发送通知给调用方
        // ...
    }
}

ログイン後にコピー

非同期 RPC サービスの呼び出し

HttpClient
を使用して非同期 RPC サーバーにリクエストを送信すると、結果が返されるまで待つ必要がなく、他のリクエストの処理を続けることができます。
```
use SwooleHttpClient;

class IndexController
{
    public function index()
    {
        $client = new Client('127.0.0.1', 9501);
        $client->post('/rpc', [], 'request data', function ($client) {
            // 发送请求后，不需要等待结果返回，可以继续处理其他请求
            // ...
        });
    }
}
```
ログイン後にコピー
要約: この記事の導入を通じて、非同期 RPC の概念と原則を理解し、ThinkPHP6 と Swoole を使用して単純な非同期 RPC サービスを構築しました。実際のアプリケーションでは、分散システムのニーズを満たすために、特定のニーズに応じて非同期 RPC を拡張および最適化できます。この記事が、ThinkPHP6 と Swoole を使用して非同期 RPC サービスを構築する開発者にとって役立つことを願っています。

参考資料:

ThinkPHP ドキュメント: https://www.kancloud.cn/manual/thinkphp6_0/1037639
1. Swoole ドキュメント: https://www 。 swoole.co.uk/docs
以上がThinkPHP6 と Swoole で構築された非同期 RPC サービスの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。