详解如何利用PHP实现RPC

吾爱主题阅读：174 2022-11-08 15:09:00 评论：0

1.什么是RPC

RPC全称为Remote Procedure Call，翻译过来为“远程过程调用”。主流的平台中都支持各种远程调用技术，以满足分布式系统架构中不同的系统之间的远程通信和相互调用。远程调用的应用场景极其广泛，实现的方式也各式各样。

2.从通信协议的层面

基于HTTP协议的（例如基于文本的SOAP（XML）、Rest（JSON），基于二进制Hessian（Binary））

基于TCP协议的（通常会借助Mina、Netty等高性能网络框架）

3.从不同的开发语言和平台层面

单种语言或平台特定支持的通信技术(例如Java平台的RMI、.NET平台Remoting)

支持跨平台通信的技术（例如HTTP Rest、Thrift等）

4.从调用过程来看

同步通信调用（同步RPC）

异步通信调用（MQ、异步RPC）

5.常见的几种通信方式

远程数据共享（例如：共享远程文件，共享数据库等实现不同系统通信）

消息队列

RPC（远程过程调用）

6.php实现简单的rpc

1.目录结构

2.rpc服务端

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 <?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 = [ 'host' => '' , // ip地址，列出来的目的是为了友好看出来此变量中存储的信息 'port' => '' , // 端口 'path' => '' // 服务目录 ]; /** * User: yuzhao * CreateTime: 2018/11/16 上午12:14 * @var array * Description: 本类常用配置 */ private $config = [ 'real_path' => '' , 'max_size' => 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['host']}:{$this->params['port']}" , $errno , $errstr ); if (! $this ->server) exit ([ $errno , $errstr ]); } /** * User: yuzhao * CreateTime: 2018/11/15 下午11:57 * Description: rpc服务目录 */ public function serverPath() { $path = $this ->params[ 'path' ]; $realPath = realpath (__DIR__ . $path ); if ( $realPath === false ||! file_exists ( $realPath )) { exit ( "{$path} error!" ); } $this ->config[ 'real_path' ] = $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[ 'max_size' ]); print_r( '接收到的原始数据:' . $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[ 'path' ] . '/' . $class . '.php' ; //判断文件是否存在，如果有，则引入文件 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 , 'class or method error' ); } } /** * User: yuzhao * CreateTime: 2018/11/16 上午12:10 * Description: 解析协议 */ private function parseProtocol( $buf , & $class , & $method , & $params ) { $buf = json_decode( $buf , true); $class = $buf [ 'class' ]; $method = $buf [ 'method' ]; $params = $buf [ 'params' ]; } /** * User: yuzhao * CreateTime: 2018/11/16 上午12:30 * @param $data * Description: 打包协议 */ private function packProtocol(& $data ) { $data = json_encode( $data , JSON_UNESCAPED_UNICODE); } } RpcServer::instance([ 'host' => '127.0.0.1' , 'port' => 8888, 'path' => './api' ])->run();

3.rpc 客户端

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 <?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['host']}:{$this->urlInfo['port']}" , $errno , $errstr ); if (! $client ) { exit ( "{$errno} : {$errstr} \n" ); } $data = [ 'class' => basename ( $this ->urlInfo[ 'path' ]), 'method' => $name , 'params' => $arguments ]; //向服务端发送我们自定义的协议数据 fwrite( $client , json_encode( $data )); //读取服务端传来的数据 $data = fread ( $client , 2048); //关闭客户端 fclose( $client ); return $data ; } } $cli = new RpcClient( 'http://127.0.0.1:8888/test' ); echo $cli ->tuzisir1(). "\n" ; echo $cli ->tuzisir2( array ( 'name' => 'tuzisir' , 'age' => 23));

4.提供服务的文件

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 <?php /** * User: yuzhao * CreateTime: 2018/11/16 上午12:28 * Description: */ class Test { public function tuzisir1() { return '我是无参方法' ; } public function tuzisir2( $params ) { return $params ; } }