詳解如何利用PHP實(shí)現(xiàn)RPC
1.什么是RPC
RPC全稱(chēng)為Remote Procedure Call,翻譯過(guò)來(lái)為“遠(yuǎn)程過(guò)程調(diào)用”。主流的平臺(tái)中都支持各種遠(yuǎn)程調(diào)用技術(shù),以滿(mǎn)足分布式系統(tǒng)架構(gòu)中不同的系統(tǒng)之間的遠(yuǎn)程通信和相互調(diào)用。遠(yuǎn)程調(diào)用的應(yīng)用場(chǎng)景極其廣泛,實(shí)現(xiàn)的方式也各式各樣。
2.從通信協(xié)議的層面
基于HTTP協(xié)議的(例如基于文本的SOAP(XML)、Rest(JSON),基于二進(jìn)制Hessian(Binary))
基于TCP協(xié)議的(通常會(huì)借助Mina、Netty等高性能網(wǎng)絡(luò)框架)
3.從不同的開(kāi)發(fā)語(yǔ)言和平臺(tái)層面
單種語(yǔ)言或平臺(tái)特定支持的通信技術(shù)(例如Java平臺(tái)的RMI、.NET平臺(tái)Remoting)
支持跨平臺(tái)通信的技術(shù)(例如HTTP Rest、Thrift等)
4.從調(diào)用過(guò)程來(lái)看
同步通信調(diào)用(同步RPC)
異步通信調(diào)用(MQ、異步RPC)
5.常見(jiàn)的幾種通信方式
遠(yuǎn)程數(shù)據(jù)共享(例如:共享遠(yuǎn)程文件,共享數(shù)據(jù)庫(kù)等實(shí)現(xiàn)不同系統(tǒng)通信)
消息隊(duì)列
RPC(遠(yuǎn)程過(guò)程調(diào)用)
6.php實(shí)現(xiàn)簡(jiǎn)單的rpc
1.目錄結(jié)構(gòu)
2.rpc服務(wù)端
<?php /** * User: yuzhao * CreateTime: 2018/11/15 下午11:46 * Description: Rpc服務(wù)端 */ class RpcServer { /** * User: yuzhao * CreateTime: 2018/11/15 下午11:51 * @var array * Description: 此類(lèi)的基本配置 */ private $params = [ 'host' => '', // ip地址,列出來(lái)的目的是為了友好看出來(lái)此變量中存儲(chǔ)的信息 'port' => '', // 端口 'path' => '' // 服務(wù)目錄 ]; /** * User: yuzhao * CreateTime: 2018/11/16 上午12:14 * @var array * Description: 本類(lèi)常用配置 */ private $config = [ 'real_path' => '', 'max_size' => 2048 // 最大接收數(shù)據(jù)大小 ]; /** * 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: 必要驗(yàn)證 */ private function check() { $this->serverPath(); } /** * User: yuzhao * CreateTime: 2018/11/15 下午11:48 * Description: 初始化必要參數(shù) */ private function init($params) { // 將傳遞過(guò)來(lái)的參數(shù)初始化 $this->params = $params; // 創(chuàng)建tcpsocket服務(wù) $this->createServer(); } /** * User: yuzhao * CreateTime: 2018/11/16 上午12:0 * Description: 創(chuàng)建tcpsocket服務(wù) */ 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服務(wù)目錄 */ 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: 返回當(dāng)前對(duì)象 */ public static function instance($params) { return new RpcServer($params); } /** * User: yuzhao * CreateTime: 2018/11/16 上午12:06 * Description: 運(yùn)行 */ public function run() { while (true) { $client = stream_socket_accept($this->server); if ($client) { echo "有新連接\n"; $buf = fread($client, $this->config['max_size']); print_r('接收到的原始數(shù)據(jù):'.$buf."\n"); // 自定義協(xié)議目的是拿到類(lèi)方法和參數(shù)(可改成自己定義的) $this->parseProtocol($buf,$class, $method,$params); // 執(zhí)行方法 $this->execMethod($client, $class, $method, $params); //關(guān)閉客戶(hù)端 fclose($client); echo "關(guān)閉了連接\n"; } } } /** * User: yuzhao * CreateTime: 2018/11/16 上午12:19 * @param $class * @param $method * @param $params * Description: 執(zhí)行方法 */ private function execMethod($client, $class, $method, $params) { if($class && $method) { // 首字母轉(zhuǎn)為大寫(xiě) $class = ucfirst($class); $file = $this->params['path'] . '/' . $class . '.php'; //判斷文件是否存在,如果有,則引入文件 if(file_exists($file)) { require_once $file; //實(shí)例化類(lèi),并調(diào)用客戶(hù)端指定的方法 $obj = new $class(); //如果有參數(shù),則傳入指定參數(shù) if(!$params) { $data = $obj->$method(); } else { $data = $obj->$method($params); } // 打包數(shù)據(jù) $this->packProtocol($data); //把運(yùn)行后的結(jié)果返回給客戶(hù)端 fwrite($client, $data); } } else { fwrite($client, 'class or method error'); } } /** * User: yuzhao * CreateTime: 2018/11/16 上午12:10 * Description: 解析協(xié)議 */ 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: 打包協(xié)議 */ 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 客戶(hù)端
<?php /** * User: yuzhao * CreateTime: 2018/11/16 上午12:2 * Description: Rpc客戶(hù)端 */ class RpcClient { /** * User: yuzhao * CreateTime: 2018/11/16 上午12:21 * @var array * Description: 調(diào)用的地址 */ private $urlInfo = array(); /** * RpcClient constructor. */ public function __construct($url) { $this->urlInfo = parse_url($url); } /** * User: yuzhao * CreateTime: 2018/11/16 上午12:2 * Description: 返回當(dāng)前對(duì)象 */ public static function instance($url) { return new RpcClient($url); } public function __call($name, $arguments) { // TODO: Implement __call() method. //創(chuàng)建一個(gè)客戶(hù)端 $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 ]; //向服務(wù)端發(fā)送我們自定義的協(xié)議數(shù)據(jù) fwrite($client, json_encode($data)); //讀取服務(wù)端傳來(lái)的數(shù)據(jù) $data = fread($client, 2048); //關(guān)閉客戶(hù)端 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.提供服務(wù)的文件
<?php /** * User: yuzhao * CreateTime: 2018/11/16 上午12:28 * Description: */ class Test { public function tuzisir1() { return '我是無(wú)參方法'; } public function tuzisir2($params) { return $params; } }
5.效果
7.RPC的注意事項(xiàng)
性能:影響RPC性能的主要在幾個(gè)方面:
- 序列化/反序列化的框架
- 網(wǎng)絡(luò)協(xié)議
- 網(wǎng)絡(luò)模型
- 線(xiàn)程模型等
安全
RPC安全的主要在于服務(wù)接口的鑒權(quán)和訪(fǎng)問(wèn)控制支持。
跨平臺(tái)
跨不同的操作系統(tǒng),不同的編程語(yǔ)言和平臺(tái)。
到此這篇關(guān)于詳解如何利用PHP實(shí)現(xiàn)RPC的文章就介紹到這了,更多相關(guān)PHP RPC內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
PHP生成靜態(tài)HTML文檔實(shí)現(xiàn)代碼
這篇文章主要為大家詳細(xì)介紹了PHP生成靜態(tài)HTML文檔實(shí)現(xiàn)代碼,將數(shù)據(jù)庫(kù)中的文章數(shù)據(jù)生成單個(gè)的HTML文檔原理,感興趣的小伙伴們可以參考一下2016-06-06PHP時(shí)間日期增減操作示例【date strtotime實(shí)現(xiàn)加一天、加一月等操作】
這篇文章主要介紹了PHP時(shí)間日期增減操作,結(jié)合實(shí)例形式分析了php使用date、strtotime等函數(shù)實(shí)現(xiàn)加一天、加一月等運(yùn)算相關(guān)實(shí)現(xiàn)技巧與問(wèn)題解決方法,需要的朋友可以參考下2018-12-12php基礎(chǔ)知識(shí):類(lèi)與對(duì)象(5) static
php基礎(chǔ)知識(shí):類(lèi)與對(duì)象(5) static...2006-12-12PHP.ini中配置屏蔽錯(cuò)誤信息顯示和保存錯(cuò)誤日志的例子
這篇文章主要介紹了PHP.ini中配置屏蔽錯(cuò)誤信息顯示和保存錯(cuò)誤日志的例子,需要的朋友可以參考下2014-05-05php實(shí)現(xiàn)獲取及設(shè)置用戶(hù)訪(fǎng)問(wèn)頁(yè)面語(yǔ)言類(lèi)
這篇文章主要介紹了php實(shí)現(xiàn)獲取及設(shè)置用戶(hù)訪(fǎng)問(wèn)頁(yè)面語(yǔ)言類(lèi),可實(shí)現(xiàn)獲取/設(shè)置用戶(hù)訪(fǎng)問(wèn)的頁(yè)面語(yǔ)言,如果用戶(hù)沒(méi)有設(shè)置訪(fǎng)問(wèn)語(yǔ)言,則讀取Accept-Language,需要的朋友可以參考下2014-09-09php中刪除字符串中最先出現(xiàn)某個(gè)字符的實(shí)現(xiàn)代碼
刪除字符串中最先出現(xiàn)某個(gè)字,就是通過(guò)explode的靈活用法,需要的朋友可以參考下2013-02-02