Traitement des taches asynchrones basé sur le service RPC de ThinkPHP6 et Swoole

Introduction :
Avec le développement rapide d'Internet, le traitement des taches asynchrones devient de plus en plus important dans le développement Web. Par exemple, lorsqu'un utilisateur soumet un formulaire et que le backend doit effectuer certaines opérations fastidieuses, afin d'éviter à l'utilisateur d'attendre longtemps, ces opérations peuvent être exécutées de manière asynchrone en arrière-plan pour améliorer l'expérience utilisateur. Dans cet article, nous présenterons comment utiliser ThinkPHP6 et Swoole pour implémenter le service RPC (Remote Procedure Call) afin de gérer ces taches asynchrones.

1. Introduction à RPC
RPC est un protocole de communication informatique qui permet aux programmes d'appeler des fonctions sur un ordinateur distant, tout comme l'appel de fonctions locales. Grace à RPC, nous pouvons nous concentrer sur l'écriture de la logique métier plut?t que sur la communication réseau, améliorant ainsi l'efficacité du développement et la maintenabilité du code.

2. Préparation
Avant de commencer, nous devons faire quelques préparatifs?:

1. Installer ThinkPHP6 et Swoole
   Peut être installé via Composer, exécutez la commande suivante?:

   composer require topthink/think-swoole

2. Configurer RPC
   Dans le fichier de configuration de ThinkPHP6 Ajoutez le code suivant à config/swoole.php?: config/swoole.php中加入以下代碼：

   <?php
   return [
       'rpc' => [
           'server' => 'http://localhost:9502',
           'timeout' => 3,
           'token' => 'your_rpc_token',
       ],
   ];

   其中，'server'是RPC服務(wù)的地址，'timeout'是超時(shí)時(shí)間，'token'是訪問令牌，可以根據(jù)自己的需求進(jìn)行配置。

3. 啟動(dòng)RPC服務(wù)
   創(chuàng)建一個(gè)RPC服務(wù)文件rpc_server.php，內(nèi)容如下：

   <?php
   require __DIR__ . '/vendor/autoload.php';
   
   use SwooleCoroutineHttpServer;
   use SwooleCoroutine;
   use SwooleHttpRequest;
   use SwooleHttpResponse;
   
   $server = new Server('0.0.0.0', 9502, false);
   
   $server->handle('/', function (Request $request, Response $response) {
       $data = $request->get;
       $response->header('Content-Type', 'application/json');
   
       // 驗(yàn)證訪問令牌
       $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;
       }
   
       // 執(zhí)行業(yè)務(wù)邏輯
       $result = invoke($method, $params);
   
       // 返回結(jié)果
       $response->end(json_encode(['result' => $result]));
   });
   
   function invoke($method, $params) {
       // TODO: 實(shí)現(xiàn)具體的業(yè)務(wù)邏輯
   
       // 模擬耗時(shí)的任務(wù)
       Coroutine::sleep(1);
   
       // 返回結(jié)果
       return "Hello, RPC!";
   }
   
   $server->start();

   在該文件中，我們使用Swoole創(chuàng)建了一個(gè)HTTP服務(wù)，監(jiān)聽9502端口。當(dāng)接收到一個(gè)請求時(shí)，會進(jìn)行訪問令牌的驗(yàn)證，并根據(jù)請求參數(shù)調(diào)用invoke函數(shù)來執(zhí)行具體的業(yè)務(wù)邏輯。在該示例中，我們模擬了一個(gè)耗時(shí)1秒的任務(wù)，并返回一個(gè)字符串作為結(jié)果。

三、調(diào)用RPC服務(wù)
在我們的ThinkPHP6項(xiàng)目中，要調(diào)用RPC服務(wù)，可以創(chuàng)建一個(gè)控制器，并在方法中使用Rpc::call來發(fā)起RPC請求。下面是一個(gè)示例代碼：

<?php
namespace appcontroller;

use thinkacadeRpc;
use thinkacadeView;

class Index
{
    public function index()
    {
        // 調(diào)用RPC服務(wù)
        $result = Rpc::call('task', ['param1', 'param2']);
        
        // 顯示結(jié)果
        return View::fetch('index', ['result' => $result]);
    }
}

在上述示例中，我們使用了Rpc::callrrreee

Parmi eux, 'server' est l'adresse du service RPC, 'timeout' est le timeout et 'token' est l'accès Jeton Vous pouvez le personnaliser selon votre propre configuration selon vos besoins.

??Démarrez le service RPC??Créez un fichier de service RPC rpc_server.php avec le contenu suivant?: ??rrreee??Dans ce fichier, nous utilisons Swoole pour créer un service HTTP en écoute sur le port 9502. Lorsqu'une demande est re?ue, le jeton d'accès sera vérifié et la fonction invoke sera appelée en fonction des paramètres de la demande pour exécuter une logique métier spécifique. Dans cet exemple, nous simulons une tache qui prend 1 seconde et renvoie une cha?ne comme résultat. ??????3. Appelez le service RPC??Dans notre projet ThinkPHP6, pour appeler le service RPC, vous pouvez créer un contr?leur et utiliser Rpc::call dans la méthode pour lancer la demande RPC. Voici un exemple de code?: ??rrreee??Dans l'exemple ci-dessus, nous avons utilisé la méthode Rpc::call pour appeler le service RPC. Le premier paramètre est le nom de la méthode et le deuxième paramètre est le paramètre de la méthode. Il peut être ajusté en fonction des besoins réels. ????4. Résumé??Cet article explique comment utiliser ThinkPHP6 et Swoole pour implémenter les services RPC afin de gérer les taches asynchrones. En pla?ant les taches fastidieuses en arrière-plan pour une exécution asynchrone, la vitesse de réponse de l'utilisateur peut être améliorée et l'expérience utilisateur améliorée. Dans le même temps, l’utilisation de RPC peut simplifier le développement de code et améliorer la maintenabilité et l’évolutivité du code. J'espère que cet article vous sera utile. ??

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!