非同期タスク処理を実装するための ThinkPHP6 および Swoole ベースの RPC サービス-ThinkPHP-php.cn

非同期タスク処理を実装するための ThinkPHP6 および Swoole ベースの RPC サービス

ThinkPHP6 と Swoole の RPC サービスをベースにした非同期タスク処理の実現

はじめに:
インターネットの急速な発展に伴い、非同期タスク処理がますます増えています。 Web 開発ではますます重要性が増しています。たとえば、ユーザーがフォームを送信し、バックエンドで時間のかかる操作を実行する必要がある場合、ユーザーが長時間待たされることを避けるために、これらの操作をバックグラウンドで非同期に実行してユーザーエクスペリエンスを向上させることができます。この記事では、これらの非同期タスクを処理するために、ThinkPHP6 と Swoole を使用して RPC (リモートプロシージャコール) サービスを実装する方法を紹介します。

1. RPC の概要##RPC は、プログラムがローカル関数を呼び出すのと同じようにリモートコンピュータ上の関数を呼び出せるようにするコンピュータ通信プロトコルです。 RPC を使用すると、ネットワーク通信ではなくビジネスロジックの作成に集中できるため、開発効率とコードの保守性が向上します。

2. 準備作業

始める前に、いくつかの準備作業を行う必要があります:

ThinkPHP6 と Swoole のインストール
Composer を通じてインストールできます。次のコマンドを実行します:
```
composer require topthink/think-swoole
```
ログイン後にコピー
Configure RPC
次のコードを ThinkPHP6 構成ファイル
config/swoole.phpに追加します:
```
 [ 'server' => 'http://localhost:9502', 'timeout' => 3, 'token' => 'your_rpc_token', ], ];
```
ログイン後にコピー
ここで、「server」は RPC サービスのアドレス、「timeout」はタイムアウト、「token」はアクセストークンであり、必要に応じて構成できます。

RPC サービスを開始します

次の内容を含む RPC サービスファイル
rpc_server.phpを作成します。

handle('/', function (Request $request, Response $response) { $data = $request->get; $response->header('Content-Type', 'application/json'); // 验证访问令牌 $token = $request->header['authorization'] ?? ''; if ($token !== 'your_rpc_token') { $response->status(403); $response->end(json_encode(['msg' => 'Access denied'])); return; } // 处理RPC请求 $method = $data['method'] ?? null; $params = $data['params'] ?? []; if (!$method) { $response->status(400); $response->end(json_encode(['msg' => 'Bad request'])); return; } // 执行业务逻辑 $result = invoke($method, $params); // 返回结果 $response->end(json_encode(['result' => $result])); }); function invoke($method, $params) { // TODO: 实现具体的业务逻辑 // 模拟耗时的任务 Coroutine::sleep(1); // 返回结果 return "Hello, RPC!"; } $server->start();

ログイン後にコピー

このファイルには、ポート 9502 でリッスンする HTTP サービスを作成した Swoole を使用します。リクエストが受信されると、アクセストークンが検証され、リクエストパラメータに基づいて

invoke関数が呼び出され、特定のビジネスロジックが実行されます。この例では、1 秒かかり、結果として文字列を返すタスクをシミュレートします。

3. RPC サービスを呼び出す

ThinkPHP6 プロジェクトで RPC サービスを呼び出すには、コントローラーを作成し、メソッドで
Rpc::call を使用しますRPC リクエストを開始します。以下はサンプルコードです。

 $result]); } }

ログイン後にコピー

上記の例では、

Rpc::callメソッドを使用して RPC サービスを呼び出しました。最初のパラメータはメソッド名で、2 番目のパラメータはメソッドのパラメータです。実際のニーズに応じて調整できます。

4. 概要

この記事では、ThinkPHP6 と Swoole を使用して、非同期タスクを処理する RPC サービスを実装する方法を紹介します。時間のかかるタスクをバックグラウンドで非同期実行することで、ユーザーの応答速度が向上し、ユーザーエクスペリエンスが向上します。同時に、RPC を使用するとコード開発が簡素化され、コードの保守性と拡張性が向上します。この記事がお役に立てば幸いです。

以上が非同期タスク処理を実装するための ThinkPHP6 および Swoole ベースの RPC サービスの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。