Analysieren Sie, wie PHP schnell RPC-Dienste erstellen kann (Codedemonstration)

In diesem Artikel erfahren Sie, was RPC ist und wie Sie mit PHP einfach und schnell einen RPC-Dienst erstellen können. Ich hoffe, er wird Freunden in Not helfen

RPC steht für Remote Procedure Call, übersetzt als „Remote Procedure Call“. Wird hauptsächlich für die Fernkommunikation und gegenseitige Anrufe zwischen verschiedenen Systemen verwendet. [Empfohlenes Lernen:

PHP-Video-Tutorial]

Wenn es beispielsweise zwei Systeme gibt, eines ist in PHP und das andere in JAVA geschrieben, und PHP möchte dann eine bestimmte Methode einer bestimmten Klasse in JAVA aufrufen Sie benötigen RPC. Wie kann ich mich anpassen? Eine direkte Anpassung ist nicht möglich. PHP kann die Dienste von JAVA nur über ein benutzerdefiniertes Protokoll anfordern, instanziiert die Klasse lokal, ruft die Methode auf und gibt das Ergebnis dann an PHP zurück.

Hier verwenden wir die Socket-Erweiterung von PHP, um einen Server und einen Client zu erstellen, um den Aufrufprozess zu demonstrieren.

RpcServer.php-Code lautet wie folgt:

<?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;);

RpcClient.php-Code lautet wie folgt:

<?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));

Dann führen Sie jeweils die beiden oben genannten Skripte aus (beachten Sie, dass PHP Umgebungsvariablen hinzufügen muss)

> php RpcServer.php
> php RpcClient.php

Die Ergebnisse sind wie folgt:

Der Test.php-Code lautet wie folgt:

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

Die Verzeichnisstruktur lautet wie folgt:

Unser oben benutzerdefiniertes Protokoll kann nach Belieben geändert werden, sofern der Client und der Server dies können vereinheitlicht und analysiert werden.

Der Client übergibt die aufzurufende Klasse, Methode und Parameter an den Server, indem er den Server anfordert, und der Server gibt das Ergebnis zurück, indem er die aufrufende Methode instanziiert.

Das obige ist der detaillierte Inhalt vonAnalysieren Sie, wie PHP schnell RPC-Dienste erstellen kann (Codedemonstration). Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!