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

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

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

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

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

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

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

composer create-project topthink/think app

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

composer require swoole/swoole

2. ThinkPHP6 の Swoole サーバーを構(gòu)成します。 ThinkPHP6## のファイル #config/server.php
   で、Swoole サーバーの関連パラメーターを設(shè)定します。たとえば、サーバーの IP アドレス、ポート番號(hào)、ワーカー プロセスの數(shù)などを構(gòu)成できます。

   'swoole' => [
       // 監(jiān)聽(tīng)的地址
       'host' => '127.0.0.1',
       // 監(jiān)聽(tīng)的端口
       'port' => 9501,
       // 工作進(jìn)程數(shù)
       'worker_num' => 4,
   ],

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

   use SwooleHttpServer;
   use SwooleProcess;
   
   class RpcController
   {
       public function index()
       {
           $server = new Server('127.0.0.1', 9501);
           $server->on('request', function ($request, $response) {
               // 處理請(qǐng)求并返回結(jié)果
               $result = $this->handleRequest($request);
               // 將結(jié)果放入消息隊(duì)列中
               $this->putToQueue($result);
               // 異步發(fā)送通知給調(diào)用方
               $this->sendNotification($response);
           });
           // 啟動(dòng)RPC服務(wù)器
           $server->start();
       }
   
       private function handleRequest($request)
       {
           // 處理請(qǐng)求并返回結(jié)果
           // ...
       }
   
       private function putToQueue($result)
       {
           // 將結(jié)果放入消息隊(duì)列中
           // ...
       }
   
       private function sendNotification($response)
       {
           // 異步發(fā)送通知給調(diào)用方
           // ...
       }
   }

ThinkPHP6 のコントローラーで、非同期 RPC サービスを呼び出します。 Swoole の
4. HttpClient
   を使用して非同期 RPC サーバーにリクエストを送信すると、結(jié)果が返されるまで待つ必要がなく、他のリクエストの処理を続けることができます。

   use SwooleHttpClient;
   
   class IndexController
   {
       public function index()
       {
           $client = new Client('127.0.0.1', 9501);
           $client->post('/rpc', [], 'request data', function ($client) {
               // 發(fā)送請(qǐng)求后，不需要等待結(jié)果返回，可以繼續(xù)處理其他請(qǐng)求
               // ...
           });
       }
   }

   要約: この記事の導(dǎo)入を通じて、非同期 RPC の概念と原則を理解し、ThinkPHP6 と Swoole を使用して単純な非同期 RPC サービスを構(gòu)築しました。実際のアプリケーションでは、分散システムのニーズを満たすために、特定のニーズに応じて非同期 RPC を拡張および最適化できます。この記事が、ThinkPHP6 と Swoole を使用して非同期 RPC サービスを構(gòu)築する開(kāi)発者にとって役立つことを願(yuàn)っています。

   
   參考資料:

   ThinkPHP ドキュメント: https://www.kancloud.cn/manual/thinkphp6_0/1037639
   1. Swoole ドキュメント: https://www 。 swoole.co.uk/docs

   以上がThinkPHP6 と Swoole で構(gòu)築された非同期 RPC サービスの詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國(guó)語(yǔ) Web サイトの他の関連記事を參照してください。