Comment implémenter php rpc ?

1. Qu'est-ce que rpc

RPC signifie Remote Procedure Call, qui se traduit par « appel de procédure à distance ». . Actuellement, les plates-formes grand public prennent en charge diverses technologies d'appel à distance pour répondre aux besoins de communication à distance et d'appels mutuels entre différents systèmes dans une architecture de système distribuée. Les scénarios d'application des appels à distance sont extrêmement larges et les méthodes de mise en œuvre sont également diverses.

2. Du niveau du protocole de communication

Basé sur le protocole HTTP (tel que SOAP basé sur texte (XML), Rest (JSON), basé sur la Hesse binaire (Binaire) )
Basé sur le protocole TCP (généralement à l'aide de frameworks réseau hautes performances tels que Mina et Netty)

À partir de différents langages de développement et niveaux de plate-forme

Technologies de communication prises en charge spécifiques au langage ou à la plate-forme (telles que RMI de la plate-forme Java, plate-forme .NET Remoting)

Technologies prenant en charge la communication multiplateforme (telles que HTTP Rest, Thrift, etc.)

4. De Regardons le processus d'appel

Appel de communication synchrone (RPC synchrone)

Appel de communication asynchrone (MQ, RPC asynchrone)

5. Plusieurs méthodes de communication courantes

Partage de données à distance (par exemple : partage de fichiers distants, partage de bases de données, etc. pour établir la communication entre différents systèmes)

File d'attente de messages
RPC (Appel de procédure à distance)

6 .php implémente un rpc simple

Structure de répertoire

serveur rpc

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

Client rpc

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

Service de fourniture de fichiers

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

Effet

7 . Précautions pour RPC

Performances : plusieurs aspects affectent les performances de RPC :

1. Cadre de sérialisation/désérialisation
2. 🎜>
Sécurité

La sécurité RPC réside principalement dans la prise en charge de l'authentification et du contrôle d'accès de l'interface de service.

Multiplateforme

Sur différents systèmes d'exploitation, différents langages de programmation et plates-formes.

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!