php独特的语法混合了C、java、Perl以及PHP自创新的语法。它可以比CGI或者Perl更快速的执行动态网页。

概述

RPC这个东西是什么? 第一次听说他, 还要在它的前边加个G, 当时我以为GRPC是一项技术, 后来才知道, 并不是这样. GRPC只是RPC的谷歌实现.

谷歌搜了一下, RPC就是一种: 远程函数调用, 看到这里, 我已经等不及了, 不往下看了, 先自己实现一个. 如果只给你这样一个概念, 如何实现调用远程函数的功能呢?

自己实现

自己尝试实现一个粗糙的PHP版本. (不想看可以跳过的)

思路

远程调用, 只需要解决下面问题:

1. 通信问题
2. 定义传输的数据格式
3. 如何封装后可以达到像调用本地函数一样的效果

先来解决通信问题, 直接粗暴的tcp socket

传输的数据格式, 直接用json进行传输

调用本地函数?? 这就要借助一下PHP的魔术函数了, __call() 这个函数是一个类调用不存在的方法时会跑到这里来, 所以, 我们返回一个类, 在call方法中进行远程调用, 这样, 在本地看来就只是在调用一个方法.

开始实现

PHP中进行socket连接十分简单, 直接调用系统函数. 通信问题解决了, 剩下的就是传输数据了, so easy

经过一番摸索, 看下结果

服务器内容:

 

class RpcServer{

 

 

    private $port = 0; // 监听端口号

 

    private $host = ''; // IP

 

 

    public function __construct($host, $port){

 

        $this->host = $host;

 

        $this->port = $port;

 

    }

 

 

    /**

 

     * 运行, 监听端口并处理

 

     */

 

    public function run(){

 

        // 创建socket

 

        $server = stream_socket_server("tcp://{$this->host}:{$this->port}");

 

        if(empty($server)) throw new Exception('创建套接字失败');

 

        // 监听

 

        while (true){

 

            $client = stream_socket_accept($server);

 

            if(empty($client)) continue;

 

            // 处理请求

 

            $this->disposeClient($client);

 

            fclose($client);

 

        }

 

    }

 

 

    private function disposeClient($client){

 

        $buf = fread($client, 4096);

 

        $array = json_decode($buf, true);

 

        // 创建对象并调用方法

 

        $class = $array['class'] ?? '';

 

        $method = $array['method'] ?? '';

 

        $params = $array['params'] ?? [];

 

        $instance = new $class();

 

        $result = $instance->$method(...$params);

 

        fwrite($client, json_encode($result));

 

    }

 

}

 

// 测试调用类

 

class Test{

 

    public function tt(){

 

        return 'return_tt';

 

    }

 

 

    public function add($a, $b){

 

        return $a + $b;

 

    }

 

}

 

 

(new RpcServer('127.0.0.1', 8888))

 

    ->run();

调用方:

 

class RpcClient{

 

    private $urlInfo = null;

 

    private $className = '';

 

 

    private function __construct($url, $className){

 

        $this->urlInfo = parse_url($url);

 

        $this->className = $className;

 

    }

 

 

    public static function getInstance($className){

 

        return new RpcClient('127.0.0.1:8888', $className);

 

    }

 

 

    public function __call($name, $arguments){

 

        // 创建客户端

 

        $client = stream_socket_client("tcp://{$this->urlInfo['host']}:{$this->urlInfo['port']}");

 

        if(empty($client)) return null;

 

        // 发送数据

 

        fwrite($client, json_encode([

 

            'class' => $this->className,

 

            'method' => $name,

 

            'params' => $arguments,

 

        ]));

 

        // 接收返回

 

        $data = fread($client, 4096);

 

        // 关闭客户端

 

        fclose($client);

 

        return json_decode($data, true);

 

    }

 

}

 

 

$test = RpcClient::getInstance('Test');

 

echo $test->tt(), PHP_EOL;

 

echo $test->add(4, 6);

结果: