PHP创建简单RPC服务案例详解
这篇文章主要介绍了PHP创建简单RPC服务案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
RPC 定义
RPC(Remote Procedure Call)即远程过程调用,指被调用方法的具体实现不在程序运行本地,而是在别的某个地方。主要应用于不同的系统之间的远程通信和相互调用。
如 A 调用 B 提供的 remoteAdd 方法:
- 首先A与B之间建立一个TCP连接;
- 然后A把需要调用的方法名(这里是remoteAdd)以及方法参数(10, 20)序列化成字节流发送出去;
- B接受A发送过来的字节流,然后反序列化得到目标方法名,方法参数,接着执行相应的方法调用(可能是localAdd)并把结果30返回;
- A接受远程调用结果
有些远程调用选择比较底层的 socket 协议,有些远程调用选择比较上层的 HTTP 协议。
远程调用的好处:
- 解耦:当方法提供者需要对方法内实现修改时,调用者完全感知不到,不用做任何变更;这种方式在跨部门,跨公司合作的时候经常用到,并且方法的提供者我们通常称为:服务的暴露方
这里使用 PHP Socket 来创建一个服务端和客户端,目录结构如下:
服务端
<?php class RpcServer { protected $server = null; public function __construct($host, $port, $path) { // 创建一个 Socket 服务 if(($this->server = socket_create(AF_INET,SOCK_STREAM,SOL_TCP)) < 0) { exit("socket_create() 失败的原因是:".socket_strerror($this->server)."n"); } if(($ret = socket_bind($this->server,$host,$port)) < 0) { exit("socket_bind() 失败的原因是:".socket_strerror($ret)."n"); } if(($ret = socket_listen($this->server,3)) < 0) { exit("socket_listen() 失败的原因是:".socket_strerror($ret)."n"); } // 判断 RPC 服务目录是否存在 $realPath = realpath(__DIR__ . $path); if ($realPath === false || !file_exists($realPath)) { exit("{$path} error n"); } do { $client = socket_accept($this->server); if($client) { // 一次性读取 $buf = socket_read($client, 8024); echo $buf; //解析客户端发送过来的协议 $classRet = preg_match('/Rpc-Class:s(.*);rn/i', $buf, $class); $methodRet = preg_match('/Rpc-Method:s(.*);rn/i', $buf, $method); $paramsRet = preg_match('/Rpc-Params:s(.*);rn/i', $buf, $params); if($classRet && $methodRet) { $class = ucfirst($class[1]); $method = $method[1]; $params = json_decode($params[1], true); $file = $realPath . '/' . $class . '.php'; // 类文件需要和类名一致 $data = ''; // 执行结果 // 判断类文件是否存在 if(file_exists($file)) { // 引入类文件 require_once $file; // 实例化类 $rfc_obj = new ReflectionClass($class); // 判断该类指定方法是否存在 if($rfc_obj->hasMethod($method)) { // 执行类方法 $rfc_method = $rfc_obj->getMethod($method); $data = $rfc_method->invokeArgs($rfc_obj->newInstance(), [$params]); } else { socket_write($client, 'method error'); } //把运行后的结果返回给客户端 socket_write($client, $data); } } else { socket_write($client, 'class or method error'); } // 关闭客户端 socket_close($client); } }while(true); } public function __destruct() { socket_close($this->server); } } new RpcServer('127.0.0.1',8080,'./service');
客户端
<?php class RpcClient { protected $client = null; protected $url_info = []; // 远程调用 URL 组成部分 public function __construct($url) { // 解析 URL $this->url_info = parse_url($url); } public function __call($name, $arguments) { // 创建一个客户端 $this->client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); if(!$this->client) { exit('socket_create() 失败'); } socket_connect($this->client, $this->url_info['host'], $this->url_info['port']); // 传递调用的类名 $class = basename($this->url_info['path']); // 传递调用的参数 $args = ''; if(isset($arguments[0])) { $args = json_encode($arguments[0]); } // 向服务端发送我们自定义的协议数据 $proto = "Rpc-Class: {$class};".PHP_EOL ."Rpc-Method: {$name};".PHP_EOL ."Rpc-Params: {$args};".PHP_EOL; socket_write($this->client, $proto); // 读取服务端传来的数据 $buf = socket_read($this->client, 8024); socket_close($this->client); return $buf; } } $rpcClient = new RpcClient('http://127.0.0.1:8080/news'); echo $rpcClient->display(['title'=>'txl']); echo $rpcClient->display(['title'=>'hello world']);
服务类 News
<?php class News { public function display($data) { return json_encode(['result'=>"News display(), title is {$data['title']}"]); } }
运行测试:
Client
Server
到此这篇关于PHP创建简单RPC服务案例详解的文章就介绍到这了,更多相关PHP创建简单RPC服务内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
相关文章
- 一加 27W 冰点散热:高功率低噪音双制冷片,冷静制胜,畅享体验
- 大疆颠覆航拍界!史上最小无人机DJI Neo震撼发布!
- 华硕IFA 2024放大招!全新ZenBook S14惊艳亮相,性能与设计全面升级!
- 百度地图大动作!《黑神话:悟空》八戒语音包即将来袭!
- 华为三折屏手机即将亮相,而iPhone16却传来创新乏力的声音?
- 微信iOS系统更新啦!苹果放行,网友热议背后的利益博弈。
- 淘宝正式宣布接入微信支付,电商巨头合作引发热议!支付宝地位会受影响吗?
- 小米 14U、OPPO X7U 和 vivo X100 U 该怎么选?
- 一加 Ace 3与Redmi Turbo 3区别?一加 Ace 3 与 Redmi Turbo 3 哪个更值得购买?
- 厉害了,全新腾讯混元Turbo模型发布 价格再低50%