Analyser comment PHP peut créer rapidement des services RPC (démonstration de code)

Cet article vous présentera ce qu'est RPC et comment utiliser PHP pour créer un service RPC simplement et rapidement. C'est en fait très simple, jetons un coup d'oeil~ J'espère que cela sera utile aux amis dans le besoin~

.

RPC est appelé Remote Procedure Call, traduit par « appel de procédure à distance ». Principalement utilisé pour la communication à distance et les appels mutuels entre différents systèmes. [Apprentissage recommandé : Tutoriel vidéo PHP]

Par exemple, s'il y a deux systèmes, l'un est écrit en PHP et l'autre est écrit en JAVA, et PHP veut appeler une certaine méthode d'une certaine classe en JAVA, alors vous avez besoin que RPC soit utilisé.

Comment régler ? L'ajustement direct est impossible. PHP ne peut demander les services de JAVA que via un protocole personnalisé. JAVA analyse le protocole, instancie la classe localement et appelle la méthode, puis renvoie le résultat à PHP.

Ici, nous utilisons l'extension socket de PHP pour créer un serveur et un client afin de démontrer le processus d'appel.

Le code RpcServer.php est le suivant :

<?php
class RpcServer {
    protected $serv = null;
 
    public function __construct($host, $port, $path) {
        //创建一个tcp socket服务
        $this->serv = stream_socket_server("tcp://{$host}:{$port}", $errno, $errstr);
        if (!$this->serv) {
            exit("{$errno} : {$errstr} \n");
        }
        //判断我们的RPC服务目录是否存在
        $realPath = realpath(__DIR__ . $path);
        if ($realPath === false || !file_exists($realPath)) {
            exit("{$path} error \n");
        }
 
        while (true) {
            $client = stream_socket_accept($this->serv);
 
            if ($client) {
                //这里为了简单，我们一次性读取
                $buf = fread($client, 2048);
                //解析客户端发送过来的协议
                $classRet = preg_match(&#39;/Rpc-Class:\s(.*);\r\n/i&#39;, $buf, $class);
                $methodRet = preg_match(&#39;/Rpc-Method:\s(.*);\r\n/i&#39;, $buf, $method);
                $paramsRet = preg_match(&#39;/Rpc-Params:\s(.*);\r\n/i&#39;, $buf, $params);
                 
                if($classRet && $methodRet) {
                    $class = ucfirst($class[1]);
                    $file = $realPath . &#39;/&#39; . $class . &#39;.php&#39;;
                    //判断文件是否存在，如果有，则引入文件
                    if(file_exists($file)) {
                        require_once $file;
                        //实例化类，并调用客户端指定的方法
                        $obj = new $class();
                        //如果有参数，则传入指定参数
                        if(!$paramsRet) {
                            $data = $obj->$method[1]();
                        } else {
                            $data = $obj->$method[1](json_decode($params[1], true));
                        }
                        //把运行后的结果返回给客户端
                        fwrite($client, $data);
                    }
                } else {
                    fwrite($client, &#39;class or method error&#39;);
                }
                //关闭客户端
                fclose($client);
            }
        }
    }
 
    public function __destruct() {
        fclose($this->serv);
    }
}
 
new RpcServer(&#39;127.0.0.1&#39;, 8888, &#39;./service&#39;);

Le code RpcClient.php est le suivant :

<?php
 
class RpcClient {
    protected $urlInfo = array();
     
    public function __construct($url) {
        //解析URL
        $this->urlInfo = parse_url($url);
        if(!$this->urlInfo) {
            exit("{$url} error \n");
        }
    }
     
    public function __call($method, $params) {
        //创建一个客户端
        $client = stream_socket_client("tcp://{$this->urlInfo[&#39;host&#39;]}:{$this->urlInfo[&#39;port&#39;]}", $errno, $errstr);
        if (!$client) {
            exit("{$errno} : {$errstr} \n");
        }
        //传递调用的类名
        $class = basename($this->urlInfo[&#39;path&#39;]);
        $proto = "Rpc-Class: {$class};" . PHP_EOL;
        //传递调用的方法名
        $proto .= "Rpc-Method: {$method};" . PHP_EOL;
        //传递方法的参数
        $params = json_encode($params);
        $proto .= "Rpc-Params: {$params};" . PHP_EOL;
        //向服务端发送我们自定义的协议数据
        fwrite($client, $proto);
        //读取服务端传来的数据
        $data = fread($client, 2048);
        //关闭客户端
        fclose($client);
        return $data;
    }
}
 
$cli = new RpcClient(&#39;http://127.0.0.1:8888/test&#39;);
echo $cli->hehe();
echo $cli->hehe2(array(&#39;name&#39; => &#39;test&#39;, &#39;age&#39; => 27));

Ensuite, exécutez respectivement les deux scripts ci-dessus (notez que php doit ajouter des variables d'environnement)

> php RpcServer.php
> php RpcClient.php

Les résultats sont les suivants :

Le code Test.php est le suivant :

<?php
class Test {
 public function hehe() {
 return &#39;hehe&#39;;
 }
 public function hehe2($params) {
 return json_encode($params);
 }
}

La structure des répertoires est la suivante :

Notre protocole personnalisé ci-dessus peut être modifié à volonté, à condition que le client et le serveur le puissent être unifié et analysé.

Le client transmet la classe, la méthode et les paramètres à appeler au serveur en demandant au serveur, et le serveur renvoie le résultat en instanciant la méthode appelante.

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!