How to implement php rpc?

1. What is rpc

RPC stands for Remote Procedure Call, which translates to "remote procedure call" . Currently, mainstream platforms support various remote calling technologies to meet remote communication and mutual calls between different systems in a distributed system architecture. The application scenarios of remote calling are extremely wide, and the implementation methods are also various.

2. From the level of communication protocol

Based on HTTP protocol (such as text-based SOAP (XML), Rest (JSON), based on binary Hessian (Binary) )
Based on TCP protocol (usually with the help of high-performance network frameworks such as Mina and Netty)

3. From different development languages ​​and platform levels

A language or platform-specific supported communication technology (such as Java platform's RMI, .NET platform Remoting)
Technology that supports cross-platform communication (such as HTTP Rest, Thrift, etc.)

4. From Let’s look at the calling process

Synchronous communication call (synchronous RPC)
Asynchronous communication call (MQ, asynchronous RPC)

5. Several common communication methods

Remote data sharing (for example: sharing remote files, sharing databases, etc. to achieve communication between different systems)
Message Queue
RPC (Remote Procedure Call)

6 .php implements simple rpc

Directory structure

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

Service file

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

Effect

##7. Precautions for RPC

Performance: There are several aspects that affect RPC performance:

1. Serialization/deserialization framework
2. Network protocol, network model, thread model, etc.

Security

RPC security mainly lies in the authentication and access control support of the service interface.

Cross-platform

Across different operating systems, different programming languages ​​and platforms.

The above is the detailed content of How to implement php rpc?. For more information, please follow other related articles on the PHP Chinese website!