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

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

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

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

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

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

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

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

composer create-project topthink/think app

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

composer require swoole/swoole

2. ThinkPHP6 の Swoole サーバーを構成します。 ThinkPHP6## のファイル #config/server.php
   で、Swoole サーバーの関連パラメーターを設定します。たとえば、サーバーの IP アドレス、ポート番号、ワーカー プロセスの数などを構成できます。

   'swoole' => [
       // 监听的地址
       'host' => '127.0.0.1',
       // 监听的端口
       'port' => 9501,
       // 工作进程数
       'worker_num' => 4,
   ],

非同期 RPC サービスの作成

ThinkPHP6 のコントローラーに、非同期 RPC サービスのメソッドを作成します。まず、Swoole を使用して非同期 RPC サーバーを作成し、指定された IP アドレスとポート番号をリッスンする必要があります。次に、コールバック関数を定義して受信したリクエストを処理し、結果をメッセージキューに入れます。最後に、通知は呼び出し元に非同期で送信されます。
3. 
   

   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 サービスの呼び出し

ThinkPHP6 のコントローラーで、非同期 RPC サービスを呼び出します。 Swoole の
4. 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 サイトの他の関連記事を参照してください。