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