Wie implementiert man PHP RPC?

1. Was ist rpc

RPC steht für Remote Procedure Call, was übersetzt „Remote Procedure Call“ bedeutet. . Derzeit unterstützen Mainstream-Plattformen verschiedene Remote-Calling-Technologien, um den Anforderungen der Remote-Kommunikation und des gegenseitigen Anrufs zwischen verschiedenen Systemen in einer verteilten Systemarchitektur gerecht zu werden. Die Anwendungsszenarien von Remote Calls sind äußerst vielfältig und auch die Implementierungsmethoden sind vielfältig.

2. Von der Ebene des Kommunikationsprotokolls

Basierend auf HTTP-Protokoll (z. B. textbasiertes SOAP (XML), Rest (JSON), basierend auf binärem Hessisch (Binär))
Basierend auf dem TCP-Protokoll (normalerweise mit Hilfe von leistungsstarken Netzwerk-Frameworks wie Mina und Netty)

3. Aus verschiedenen Entwicklungssprachen und Plattformebenen

Sprach- oder plattformspezifische unterstützte Kommunikationstechnologien (z. B. RMI der Java-Plattform, .NET-Plattform-Remoting)
Technologien, die plattformübergreifende Kommunikation unterstützen (z. B. HTTP Rest, Thrift usw.)

4. Schauen wir uns den Aufrufprozess an

Synchroner Kommunikationsaufruf (synchroner RPC)
Asynchroner Kommunikationsaufruf (MQ, asynchroner RPC)

5. Mehrere gängige Kommunikationsmethoden

Remote-Datenfreigabe (z. B. gemeinsame Nutzung von Remote-Dateien, gemeinsame Nutzung von Datenbanken usw., um die Kommunikation zwischen verschiedenen Systemen zu erreichen)
Nachrichtenwarteschlange
RPC (Remote Procedure Call)

6 .php implementiert einfachen RPC

Verzeichnisstruktur

RPC-Server

<?php/**
 * User: yuzhao
 * CreateTime: 2018/11/15 下午11:46
 * Description: Rpc服务端
 */class RpcServer {    /**
     * User: yuzhao
     * CreateTime: 2018/11/15 下午11:51
     * @var array
     * Description: 此类的基本配置
     */
    private $params = [        &#39;host&#39;  => &#39;&#39;,  // ip地址，列出来的目的是为了友好看出来此变量中存储的信息
        &#39;port&#39;  => &#39;&#39;, // 端口
        &#39;path&#39;  => &#39;&#39; // 服务目录
    ];    /**
     * User: yuzhao
     * CreateTime: 2018/11/16 上午12:14
     * @var array
     * Description: 本类常用配置
     */
    private $config = [        &#39;real_path&#39; => &#39;&#39;,        &#39;max_size&#39;  => 2048 // 最大接收数据大小
    ];    /**
     * User: yuzhao
     * CreateTime: 2018/11/15 下午11:50
     * @var nul
     * Description:
     */
    private $server = null;    /**
     * Rpc constructor.
     */
    public function __construct($params)
    {        $this->check();        $this->init($params);
    }    /**
     * User: yuzhao
     * CreateTime: 2018/11/16 上午12:0
     * Description: 必要验证
     */
    private function check() {        $this->serverPath();
    }    /**
     * User: yuzhao
     * CreateTime: 2018/11/15 下午11:48
     * Description: 初始化必要参数
     */
    private function init($params) {        // 将传递过来的参数初始化
        $this->params = $params;        // 创建tcpsocket服务
        $this->createServer();
    }    /**
     * User: yuzhao
     * CreateTime: 2018/11/16 上午12:0
     * Description: 创建tcpsocket服务

     */
    private function createServer() {        $this->server = stream_socket_server("tcp://{$this->params[&#39;host&#39;]}:{$this->params[&#39;port&#39;]}", $errno,$errstr);        if (!$this->server) exit([
            $errno,$errstr
        ]);
    }    /**
     * User: yuzhao
     * CreateTime: 2018/11/15 下午11:57
     * Description: rpc服务目录
     */
    public function serverPath() {
        $path = $this->params[&#39;path&#39;];
        $realPath = realpath(__DIR__ . $path);        if ($realPath === false ||!file_exists($realPath)) {            exit("{$path} error!");
        }        $this->config[&#39;real_path&#39;] = $realPath;
    }    /**
     * User: yuzhao
     * CreateTime: 2018/11/15 下午11:51
     * Description: 返回当前对象
     */
    public static function instance($params) {        return new RpcServer($params);
    }    /**
     * User: yuzhao
     * CreateTime: 2018/11/16 上午12:06
     * Description: 运行
     */
    public function run() {        while (true) {
            $client = stream_socket_accept($this->server);            if ($client) {                echo "有新连接\n";
                $buf = fread($client, $this->config[&#39;max_size&#39;]);
                print_r(&#39;接收到的原始数据:&#39;.$buf."\n");                // 自定义协议目的是拿到类方法和参数(可改成自己定义的)
                $this->parseProtocol($buf,$class, $method,$params);                // 执行方法
                $this->execMethod($client, $class, $method, $params);                //关闭客户端
                fclose($client);                echo "关闭了连接\n";
            }
        }
    }    /**
     * User: yuzhao
     * CreateTime: 2018/11/16 上午12:19
     * @param $class
     * @param $method
     * @param $params
     * Description: 执行方法
     */
    private function execMethod($client, $class, $method, $params) {        if($class && $method) {            // 首字母转为大写
            $class = ucfirst($class);
            $file = $this->params[&#39;path&#39;] . &#39;/&#39; . $class . &#39;.php&#39;;            //判断文件是否存在，如果有，则引入文件
            if(file_exists($file)) {                require_once $file;                //实例化类，并调用客户端指定的方法
                $obj = new $class();                //如果有参数，则传入指定参数
                if(!$params) {
                    $data = $obj->$method();
                } else {
                    $data = $obj->$method($params);
                }                // 打包数据
                $this->packProtocol($data);                //把运行后的结果返回给客户端
                fwrite($client, $data);
            }
        } else {
            fwrite($client, &#39;class or method error&#39;);
        }
    }    /**
     * User: yuzhao
     * CreateTime: 2018/11/16 上午12:10
     * Description: 解析协议
     */
    private function parseProtocol($buf, &$class, &$method, &$params) {
        $buf = json_decode($buf, true);
        $class = $buf[&#39;class&#39;];
        $method = $buf[&#39;method&#39;];
        $params = $buf[&#39;params&#39;];
    }    /**
     * User: yuzhao
     * CreateTime: 2018/11/16 上午12:30
     * @param $data
     * Description: 打包协议
     */
    private function packProtocol(&$data) {
        $data = json_encode($data, JSON_UNESCAPED_UNICODE);
    }

}

RpcServer::instance([    &#39;host&#39;  => &#39;127.0.0.1&#39;,    &#39;port&#39;  => 8888,    &#39;path&#39;  => &#39;./api&#39;])->run();

RPC-Client

<?php/**
 * User: yuzhao
 * CreateTime: 2018/11/16 上午12:2
 * Description: Rpc客户端
 */class RpcClient {    /**
     * User: yuzhao
     * CreateTime: 2018/11/16 上午12:21
     * @var array
     * Description: 调用的地址
     */
    private $urlInfo = array();    /**
     * RpcClient constructor.
     */
    public function __construct($url)
    {        $this->urlInfo = parse_url($url);
    }    /**
     * User: yuzhao
     * CreateTime: 2018/11/16 上午12:2
     * Description: 返回当前对象
     */
    public static function instance($url) {        return new RpcClient($url);
    }    public function __call($name, $arguments)
    {        // TODO: Implement __call() method.
        //创建一个客户端
        $client = stream_socket_client("tcp://{$this->urlInfo[&#39;host&#39;]}:{$this->urlInfo[&#39;port&#39;]}", $errno, $errstr);        if (!$client) {            exit("{$errno} : {$errstr} \n");
        }
        $data = [            &#39;class&#39;  => basename($this->urlInfo[&#39;path&#39;]),            &#39;method&#39; => $name,            &#39;params&#39; => $arguments
        ];        //向服务端发送我们自定义的协议数据
        fwrite($client, json_encode($data));        //读取服务端传来的数据
        $data = fread($client, 2048);        //关闭客户端
        fclose($client);        return $data;
    }
}
$cli = new RpcClient(&#39;http://127.0.0.1:8888/test&#39;);echo $cli->tuzisir1()."\n";echo $cli->tuzisir2(array(&#39;name&#39; => &#39;tuzisir&#39;, &#39;age&#39; => 23));

Dateibereitstellungsdienst

<?php/**
 * User: yuzhao
 * CreateTime: 2018/11/16 上午12:28
 * Description:
 */class Test {    public function tuzisir1() {        return &#39;我是无参方法&#39;;
    }    public function tuzisir2($params) {        return $params;
    }
}

Effekt

7 . Vorsichtsmaßnahmen für RPC

Leistung: Es gibt mehrere Aspekte, die sich auf die RPC-Leistung auswirken:
1. Netzwerkprotokolle, Netzwerkmodelle, Thread-Modelle usw.

Sicherheit

RPC-Sicherheit liegt hauptsächlich in der Authentifizierungs- und Zugriffskontrollunterstützung der Serviceschnittstelle.

Plattformübergreifend

Über verschiedene Betriebssysteme, verschiedene Programmiersprachen und Plattformen hinweg.

Das obige ist der detaillierte Inhalt vonWie implementiert man PHP RPC?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!