PHP实现简单RPC

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了PHP实现简单RPC，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含8567字，纯文字阅读大概需要13分钟。

内容图文

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

目录结构

image.png

rpc服务端

  1 <?php
  2 /**
  3  * User: yuzhao
  4  * CreateTime: 2018/11/15 下午11:46
  5  * Description: Rpc服务端
  6  */
  7 class RpcServer {
  8 
  9     /**
 10      * User: yuzhao
 11      * CreateTime: 2018/11/15 下午11:51
 12      * @var array
 13      * Description: 此类的基本配置
 14      */
 15     private $params = [
 16         'host'  => '',  // ip地址，列出来的目的是为了友好看出来此变量中存储的信息
 17         'port'  => '', // 端口
 18         'path'  => '' // 服务目录
 19     ];
 20 
 21     /**
 22      * User: yuzhao
 23      * CreateTime: 2018/11/16 上午12:14
 24      * @var array
 25      * Description: 本类常用配置
 26      */
 27     private $config = [
 28         'real_path' => '',
 29         'max_size'  => 2048 // 最大接收数据大小
 30     ];
 31 
 32     /**
 33      * User: yuzhao
 34      * CreateTime: 2018/11/15 下午11:50
 35      * @var nul
 36      * Description:
 37      */
 38     private $server = null;
 39 
 40     /**
 41      * Rpc constructor.
 42      */
 43     public function __construct($params)
 44     {
 45         $this->check();
 46         $this->init($params);
 47     }
 48 
 49     /**
 50      * User: yuzhao
 51      * CreateTime: 2018/11/16 上午12:0
 52      * Description: 必要验证
 53      */
 54     private function check() {
 55         $this->serverPath();
 56     }
 57 
 58     /**
 59      * User: yuzhao
 60      * CreateTime: 2018/11/15 下午11:48
 61      * Description: 初始化必要参数
 62      */
 63     private function init($params) {
 64         // 将传递过来的参数初始化
 65         $this->params = $params;
 66         // 创建tcpsocket服务
 67         $this->createServer();
 68     }
 69 
 70     /**
 71      * User: yuzhao
 72      * CreateTime: 2018/11/16 上午12:0
 73      * Description: 创建tcpsocket服务
 74 
 75      */
 76     private function createServer() {
 77         $this->server = stream_socket_server("tcp://{$this->params['host']}:{$this->params['port']}", $errno,$errstr);
 78         if (!$this->server) exit([
 79             $errno,$errstr
 80         ]);
 81     }
 82 
 83     /**
 84      * User: yuzhao
 85      * CreateTime: 2018/11/15 下午11:57
 86      * Description: rpc服务目录
 87      */
 88     public function serverPath() {
 89         $path = $this->params['path'];
 90         $realPath = realpath(__DIR__ . $path);
 91         if ($realPath === false ||!file_exists($realPath)) {
 92             exit("{$path} error!");
 93         }
 94         $this->config['real_path'] = $realPath;
 95     }
 96 
 97     /**
 98      * User: yuzhao
 99      * CreateTime: 2018/11/15 下午11:51
100      * Description: 返回当前对象
101      */
102     public static function instance($params) {
103         return new RpcServer($params);
104     }
105 
106     /**
107      * User: yuzhao
108      * CreateTime: 2018/11/16 上午12:06
109      * Description: 运行
110      */
111     public function run() {
112         while (true) {
113             $client = stream_socket_accept($this->server);
114             if ($client) {
115                 echo "有新连接\n";
116                 $buf = fread($client, $this->config['max_size']);
117                 print_r('接收到的原始数据:'.$buf."\n");
118                 // 自定义协议目的是拿到类方法和参数(可改成自己定义的)
119                 $this->parseProtocol($buf,$class, $method,$params);
120                 // 执行方法
121                 $this->execMethod($client, $class, $method, $params);
122                 //关闭客户端
123                 fclose($client);
124                 echo "关闭了连接\n";
125             }
126         }
127     }
128 
129     /**
130      * User: yuzhao
131      * CreateTime: 2018/11/16 上午12:19
132      * @param $class
133      * @param $method
134      * @param $params
135      * Description: 执行方法
136      */
137     private function execMethod($client, $class, $method, $params) {
138         if($class && $method) {
139             // 首字母转为大写
140             $class = ucfirst($class);
141             $file = $this->params['path'] . '/' . $class . '.php';
142             //判断文件是否存在，如果有，则引入文件
143             if(file_exists($file)) {
144                 require_once $file;
145                 //实例化类，并调用客户端指定的方法
146                 $obj = new $class();
147                 //如果有参数，则传入指定参数
148                 if(!$params) {
149                     $data = $obj->$method();
150                 } else {
151                     $data = $obj->$method($params);
152                 }
153                 // 打包数据
154                 $this->packProtocol($data);
155                 //把运行后的结果返回给客户端
156                 fwrite($client, $data);
157             }
158         } else {
159             fwrite($client, 'class or method error');
160         }
161     }
162 
163     /**
164      * User: yuzhao
165      * CreateTime: 2018/11/16 上午12:10
166      * Description: 解析协议
167      */
168     private function parseProtocol($buf, &$class, &$method, &$params) {
169         $buf = json_decode($buf, true);
170         $class = $buf['class'];
171         $method = $buf['method'];
172         $params = $buf['params'];
173     }
174 
175     /**
176      * User: yuzhao
177      * CreateTime: 2018/11/16 上午12:30
178      * @param $data
179      * Description: 打包协议
180      */
181     private function packProtocol(&$data) {
182         $data = json_encode($data, JSON_UNESCAPED_UNICODE);
183     }
184 
185 }
186 
187 RpcServer::instance([
188     'host'  => '127.0.0.1',
189     'port'  => 8888,
190     'path'  => './api'
191 ])->run();

rpc 客户端

 1 <?php
 2 /**
 3  * User: yuzhao
 4  * CreateTime: 2018/11/16 上午12:2
 5  * Description: Rpc客户端
 6  */
 7 class RpcClient {
 8 
 9     /**
10      * User: yuzhao
11      * CreateTime: 2018/11/16 上午12:21
12      * @var array
13      * Description: 调用的地址
14      */
15     private $urlInfo = array();
16 
17     /**
18      * RpcClient constructor.
19      */
20     public function __construct($url)
21     {
22         $this->urlInfo = parse_url($url);
23     }
24 
25     /**
26      * User: yuzhao
27      * CreateTime: 2018/11/16 上午12:2
28      * Description: 返回当前对象
29      */
30     public static function instance($url) {
31         return new RpcClient($url);
32     }
33 
34     public function __call($name, $arguments)
35     {
36         // TODO: Implement __call() method.
37         //创建一个客户端
38         $client = stream_socket_client("tcp://{$this->urlInfo['host']}:{$this->urlInfo['port']}", $errno, $errstr);
39         if (!$client) {
40             exit("{$errno} : {$errstr} \n");
41         }
42         $data = [
43             'class'  => basename($this->urlInfo['path']),
44             'method' => $name,
45             'params' => $arguments
46         ];
47         //向服务端发送我们自定义的协议数据
48         fwrite($client, json_encode($data));
49         //读取服务端传来的数据
50         $data = fread($client, 2048);
51         //关闭客户端
52         fclose($client);
53         return $data;
54     }
55 }
56 $cli = new RpcClient('http://127.0.0.1:8888/test');
57 echo $cli->tuzisir1()."\n";
58 echo $cli->tuzisir2(array('name' => 'tuzisir', 'age' => 23));

提供服务的文件

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

效果

你是否有这样的烦恼，想学习高级技术，缺乏好的高级学习资料，11年架构师授课的TP5、laravel、swoole、swoft、高并发、分布式等资料，官方群：677079770 ，大牛带你装比带你飞

image.png

7.RPC的注意事项

性能:影响RPC性能的主要在几个方面：
1.序列化/反序列化的框架
2.网络协议，网络模型，线程模型等

安全
RPC安全的主要在于服务接口的鉴权和访问控制支持。

跨平台
跨不同的操作系统，不同的编程语言和平台。

你是否有这样的烦恼，想学习高级技术，缺乏好的高级学习资料，11年架构师授课的TP5、laravel、swoole、swoft、高并发、分布式等资料，官方群：677079770 ，大牛带你装比带你飞

推荐阅读：一：关于PHP在企业级开发领域的访谈二：浅谈 PHP 与手机 APP 开发（API 接口开发）三：比RBAC更好的权限认证方式（Auth类认证）四：2019年PHP面试题附答案（实战经验） ? ? ? ?

内容总结

以上是互联网集市为您收集整理的PHP实现简单RPC全部内容，希望文章能够帮你解决PHP实现简单RPC所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/681213.html

来源：【匿名】

【上一篇】PHP类基础（2）之生成对象的6种方法【下一篇】PHP 5 数据对象 (PDO) 抽象层与 Oracle

更多 ►

【PHP实现简单RPC】教程文章相关的互联网学习教程文章

昨天分享了在PHP网站开发中如何在php.ini中配置实现session功能的PHP教程，今天继续分享在利用PHP实现文件上传功能时几点关键php.ini的配置。　　说到在php.ini中的文件上传的配置，其实在之前介绍PHP文件上传功能代码实例教程以及Jquery AjaxUpload实现文件上传功能代码实例教程时我都有所提及。PHP文件上传功能配置主要涉及php.ini配置文件中的upload_tmp_dir、upload_max_filesize、post_max_size等选项。　　php.ini中文件上传...

thinkphp实现数组分页示例

在thinkphp的框架下实现分页。公司的网站基于Thinkphp框架，一直久闻thinkphp的大名，终于有机会实战了。thinkphp是MVC架构的，MVC对于任何ITers来说都不陌生，模型(model)－视图(view)－控制器(controller)。他将逻辑和数据分开处理，少了很多繁琐的过程。其实在官方的资料中已经详细的介绍了怎么分页，传送门：http://document.thinkphp.cn/manual_3_2.html#data_page可是并不适用于数据已经从DB中取出，并且转换为数组的情况，我...

PHP array_merge()函数实现多个数组合并【代码】

php代码段：$arr1 = array( ‘name‘ => ‘小明‘, ‘sex‘ => 1, ‘age‘ => 24, );$arr2 = array( ‘type‘ => ‘IT‘, ‘status‘ => ‘正常‘, ‘flag‘ => 1, ‘sort‘ => 100, );//假如以上两个数组是从两个表里读取的数据，现在需要将他们合并到一起 $userInfo = array_merge($arr1, $arr2);print_r($userInfo);output:array( ‘name‘ => ‘小明‘, ‘sex‘ => 1, ‘age‘ => 2...

PHP 实现“贴吧神兽”验证码【代码】【图】

最早看到 “贴吧神兽” 验证码是在百度贴吧，吧主防止挖坟贴，放出了究极神兽验证码例如：地址：http://tieba.baidu.com/p/3320323440 可以用 PHP + JavaScript 实现该种类型的验证码。使用 jQuery 版本：jQuery 1.9.1框架使用 ThinkPHP 3.2.3，自定义的验证码类基于 TP 的验证码类最终效果图：自定义验证码类路径：/Application/Home/Common/VerivyPostBar.class.php控制器：/Application/Home/Controller/PostBarController.cl...

php 实现各种经典算法【代码】【图】

//-------------------- // 基本数据结构算法 //-------------------- //二分查找（数组里查找某个元素） 1function bin_sch($array, $low, $high, $k){ 2if ( $low <= $high){ 3$mid = intval(($low+$high)/2 ); 4if ($array[$mid] == $k){ 5return$mid; 6 } elseif ( $k < $array[$mid]){ 7return bin_sch($array, $low, $mid-1, $k); 8 } else { 9return bin_sch($array, $mid+ ...

ThinkPHP无限级分类原理实现留言与回复功能实例

本文所述留言板程序使用了无限级分类的原理，可以实现无限级留言与回复。留言列表gclist保留了留言层次空格，使留言--回复层次分明。分享给大家供大家参考。具体分析如下：功能上，本程序可以实现无限级留言与回复，即对留言回复，对回复的留言回复。当然你也可以作有限制的控制，使其只对留言回复，关键是在模板代码中去掉回复的留言中的“回复该留言”即可。欢迎去拍砖！程序效果如下图所示：完整源码点击此处本站下载。数据表：...

php实现修改新闻时删除图片的方法【代码】

本文实例讲述了php实现修改新闻时删除图片的方法。分享给大家供大家参考。具体实现方法如下： //old_contents：待修改的公告内容; //$content：修改后的公告内容 $oldPic=array(); $nowPic=array(); preg_match_all("/\<IMG(.*?)src=\"(.*?)\">/",$old_contents,$match); if(!empty($match[2])){foreach($match[2] as $key=>$value){array_push($oldPic,basename($value));} } preg_match_all("/\<IMG(.*?)src=\"(.*?)\">/",$conte...

atitit.http get post的原理以及框架实现java php

atitit.http get post的原理以及框架实现java php 1. 相关的设置 11.1. urlencode 11.2. 输出流的编码 11.3. 图片，文件的post 12. get比较简单只是文字串 13. post 字节流（基础） 14. post文字（with编码） 25. 发送http请求的框架 25.1. jdk URLConnection 25.2. jdk HttpURLConnection 25.3. apache httpclient 25.4. http browser 36. 参考 3 1. 相关的设置1.1. urlencode1.2. 输出流的编码1.3. 图片，文件的post 2. get比...

thinkphp中在编辑一条数据时不用JS实现自动选中下拉框

<select name="auth_pid" id="auth_pid"> <option value="0" >--请选择--</option> <volist name="auth_list" id="item"> <eq name="item.auth_id" value="$auth_info.auth_pid"> <option value="<{$item.auth_id}>" selected ><{$item.auth_name}></option> <else /> <option value="<{$item.auth_id}>" ><{$item.auth_name}></option> </eq> </volist><...

php 发送带附件邮件的实现代码【代码】【图】

php发送邮件，可以发送带附件邮件。1，emailclass.php<? class CMailFile {var$subject; var$addr_to; var$text_body; var$text_encoded; var$mime_headers; var$mime_boundary = "--==================_846811060==_"; var$smtp_headers;function CMailFile($subject,$to,$from,$msg,$filename,$downfilename,$mimetype = "application/octet-stream",$mime_filename = false) { $this->subject = $subject; $this->addr...

基于 ThinkPHP 3.2.3 的页面静态化功能的实现【代码】

PHP 的页面静态化有多种实现方式，比如使用输出缓冲（output buffering），该种方式是把数据缓存在 PHP 的缓冲区（内存）中，下一次取数据时直接从缓冲区中读取数据，从而避免了脚本的编译和访问数据库等过程；另一种方式是直接生成静态的 HTML 文件，使用文件读写函数来实现，一些内容不经常改动的页面可以使用静态页面，访客访问到的页面就是真实的 HTML 页面，一些常见的 CMS 会使用该种方法。以第二种方法为例，参考 DedeCMS ...

php简单浏览目录内容的实现代码

如下所示：复制代码代码如下:<?php$dir = dirname(__FILE__);$open_dir = opendir($dir);echo "<table border=1 borderColor=red cellpadding=6>";echo "<tr><th>文件名</th><th>大小</th><th>类型</th><th>修改日期</th></tr>";while ($file = readdir($open_dir)) { if ($file!= "." && $file != "..") { echo "<tr><td>" . $file . "</td>"; echo "<td>" . filesize($file) . "</td>"; echo "<td>" . filetype($file) . "</...

php+mysql实现数据库随机重排实例

本文实例实现了php+mysql数据库随机重排的方法，可将表中的所有数据随机读出来一次之后再进行随机保存到另一个表，从而达到了记录随机的功能。主要实现代码如下：复制代码代码如下:<?php //数据库连接就不写在这里面了 $s = isset( $_GET[‘s‘] )?$_GET[‘s‘]:0; $e = isset( $_GET[‘e‘])?$_GET[‘e‘]:50; $count =85000; if( $s < $count ) { $sql = "select * from 表前缀_info where isget =0 order by id desc limit $s...

php使用array_search函数实现数组查找的方法【代码】

本文实例讲述了php使用array_search函数实现数组查找的方法。分享给大家供大家参考。具体实现方法如下： <?php $array = array(4,5,7,8,9,10); $found = array_search(8, $array); //调用array_search函数并输出查找结果 if($found) //如果找到输出键 echo "已找到，键为".$found; else //如果没有找到输出错误信息 echo "没有找到"; ?>希望本文所述对大家的php程序设计有所帮助。原文：http://www.jb51.net/article/67770.htm

PHP实现随机打乱一个二维数组【代码】

<?php/* * @Author: wyy * @Date: 2019-01-28 10:26:29 * @Email: 2752154874@qq.com * @Last Modified by: wyy * @Last Modified time: 2019-01-28 10:30:12*/function shuffle_assoc($list) {if (!is_array($list)) {return$list;}$keys = array_keys($list);shuffle($keys);$random = array();foreach ($keysas$key) {$random[$key] = $list[$key];}return$random; }$list = [[‘id‘=>518,‘gift_name‘=>‘礼物一‘,‘op...

PHP - 技术教程分类

PHP 教程 PHP 简介 PHP 安装 PHP 语法 PHP 变量 PHP echo/print PHP EOF(heredoc) PHP 数据类型 PHP 类型比较 PHP 常量 PHP 字符串 PHP 运算符 PHP If...Else PHP Switch PHP 数组 PHP 数组排序 PHP 超级全局变量 PHP While 循环 PHP For 循环 PHP 函数 PHP 魔术常量 PHP 命名空间 PHP 面向对象 PHP 测验 PHP 表单 PHP 表单验证 PHP 表单 - 必需字段 PHP 完整表单实例 PHP $_GET 变量 PHP $_POST 变量 PHP 多维数组 PHP 日期 PHP 包含 PHP 文件 PHP 文件上传 PHP Cookie PHP Session PHP E-mail PHP Error PHP Exception PHP 过滤器 PHP 7 新特性 PHP MySQL 简介 PHP MySQL 连接 PHP MySQL 创建数据库 PHP MySQL 创建数据表 PHP MySQL 插入数据 PHP MySQL 插入多条数据 PHP MySQL 预处理语句 PHP MySQL 读取数据 PHP MySQL Where PHP MySQL Order By PHP MySQL Update PHP MySQL Delete PHP ODBC AJAX 简介 AJAX PHP AJAX 数据库 AJAX 实时搜索 AJAX 投票 PHP Array PHP Calendar PHP cURL PHP Date PHP Directory PHP Error PHP Filesystem PHP Filter PHP FTP PHP HTTP PHP Mail PHP Math PHP Misc PHP MySQLi PHP PDO PHP String PHP Zip PHP Timezones PHP 图像处理 PHP RESTful PHP PCRE PHP 可用的函数 PHP Composer php 全部

PHP - 最热教程

php如何取出数组的前几个元素 PHP变量什么时候释放 PHP如何实现在数据库随机获取几条记录如何解决php base64解码乱码 php主要用于哪些领域 Laravel 批量插入(insert)数据六款国内优秀免费wordpress主题推荐 React如何从后端获取数据并渲染到前端？纯PHP实现定时器任务（Timer），php实现...php该如何安装pdo_mysql扩展

首页 / PHP / PHP实现简单RPC

PHP实现简单RPC

内容导读

内容图文

1.什么是rpc

2.从通信协议的层面

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

4.从调用过程来看

5.常见的几种通信方式

6.php实现简单的rpc

7.RPC的注意事项

内容总结

内容备注

内容手机端

【PHP实现简单RPC】教程文章相关的互联网学习教程文章

配置php.ini实现PHP文件上传功能

thinkphp实现数组分页示例

PHP array_merge()函数实现多个数组合并【代码】

PHP 实现“贴吧神兽”验证码【代码】【图】

php 实现各种经典算法【代码】【图】

ThinkPHP无限级分类原理实现留言与回复功能实例

php实现修改新闻时删除图片的方法【代码】

atitit.http get post的原理以及框架实现java php

thinkphp中在编辑一条数据时不用JS实现自动选中下拉框

php 发送带附件邮件的实现代码【代码】【图】

基于 ThinkPHP 3.2.3 的页面静态化功能的实现【代码】

php简单浏览目录内容的实现代码

php+mysql实现数据库随机重排实例

php使用array_search函数实现数组查找的方法【代码】

PHP实现随机打乱一个二维数组【代码】

PHP - 相关标签

PHP - 技术教程分类

PHP - 最新教程

PHP - 最热教程