我對RPC的理解

1、簡介

　　這篇文章將會用最直白的方式介紹RPC，以及實現RPC客戶端的Ajax跨域調用的例子。

　　RPC(Remote Procedure Call Protocol)--遠程過程調用協議，它是一種通過網絡從遠程計算機程序上請求服務，而不需要了解底層網絡技術的協議。RPC協議假定某些傳輸協議的存在，如TCP或UDP，為通信程序之間攜帶信息數據。在OSI網絡通信模型中，RPC跨越了傳輸層和應用層。RPC使得開發包括網絡分布式多程序在內的應用程序更加容易。

　　RPC采用客戶機/服務器模式。請求程序就是一個客戶機，而服務提供程序就是一個服務器。首先，客戶機調用進程發送一個有進程參數的調用信息到服務進程，然后等待應答信息。在服務器端，進程保持睡眠狀態直到調用信息的到達為止。當一個調用信息到達，服務器獲得進程參數，計算結果，發送答復信息，然后等待下一個調用信息，最后，客戶端調用進程接收答復信息，獲得進程結果，然后調用執行繼續進行。

　　以上來自度娘！看完上面明白什么是RPC么，在心中能將RPC整個服務過程構造出來么？當然不能啦，對於我們這種小白來說最好是用最直白的語言進行描述。

　　從字面上我們是大概了解到是從一個服務器中調用另一個服務器中的方法，使用它提供的功能。在我最開始接觸RPC的時候，是在這本書中《PHP精粹:編寫高效PHP代碼》【(美)Lorna Mitchell，(美)Davey Shafik，(美)Matthew Turland著;彭沖，胡琳譯】。是的，我所從事的語言就是世界上最好的語言--PHP，222333哈哈。

　　在這本書中所介紹的RPC的實現方式是通過HTTP協議進行的。但是當我在尋找相關資料的時候，已看其他語言的例子，咋不一樣的咧，難道PHP就是獨特的？RPC即是遠程調用，一般來說是不關語言層面的呀！

　　的確，RPC=Remote Produce Call 是一種技術的概念名詞，它可以通過不同的方式實現。http是rpc實現的一種方式，RPC還可以通過Socket自己實現一套協議來實現。當然啦，不同的實現方式有不同的特點，長短連接、數據的傳輸方式、靈活性等等。

　　RPC的核心並不在於使用什么協議。RPC的目的是讓你在本地調用遠程的方法，而對你來說這個調用是透明的，你並不知道這個調用的方法是部署哪里。通過RPC能解耦服務，這才是使用RPC的真正目的。

RPC(遠程過程調用)是什么

• 簡單的說，RPC就是從一台機器（客戶端）上通過參數傳遞的方式調用另一台機器（服務器）上的一個函數或方法（可以統稱為服務）並得到返回的結果。
• RPC 會隱藏底層的通訊細節（不需要直接處理Socket通訊或Http通訊）
• RPC 是一個請求響應模型。客戶端發起請求，服務器返回響應（類似於Http的工作方式）
• RPC 在使用形式上像調用本地函數（或方法）一樣去調用遠程的函數（或方法）

　　即能夠調用遠程規定好的接口就可稱之為RPC！在我上一篇文章中所講的Web service（SOAP）也是RPC的一種實現方式。

　　Thrift ，這是我最近學習的一個RPC框架，它很強大，數據是通過二進制格式進行傳輸，相對 XML 和 JSON 體積更小，對於高並發、大數據量和多語言的環境更有優勢。當然啦，這里不講這個RPC框架，畢竟剛接觸，對於Thrift這方面的知識還是菜鳥級別。能懂一丟丟但是距離將它寫成博客文章還是差很遠的。

　　接下來我將采用HTTP方式來實現一個RPC，並且在客戶端中能夠在Ajax下進行跨域訪問。

2、PRC實例

　　環境介紹：www.test88.com作為服務主機、www.test99.com作為客戶端主機

　　一個好的api可以支持不同的格式輸出、大多RPC采用post方式提交數據！接下來我們將采用json格式輸出、POST提交數據

　　2.1、先建立具體服務功能的邏輯程序

　　WebServer.class.php【www.test88.com】

<?php
class WebServer
{
    public static function test($name,$age,$action)
    {
        return $name.',今年年齡'.$age.',最喜歡做的事情是'.$action;
    }
    public static function look()
    {
        return $_POST;
    }
    public static function nono()
    {
        return '啥雞毛都沒有';
    }
}
?>

 

　　2.2、服務端提供相應的入口

　　WebServer.php【www.test88.com】

　　返回數據使用json格式！一個最基本的RPC服務已經建成！

<?php
require './WebServer.class.php';
if(isset($_POST['method']))
{
    $post=$_POST;
    switch ($_POST['method']) {
        case 'test':
            $respond=WebServer::test($post['name'],$post['age'],$post['action']);
            break;
        case 'look':
            $respond=WebServer::look();
            break;
        default:
            $respond=WebServer::nono();
            break;
    }
}
else
{
    $respond='木有！';
}
header('content-type:application/json');
echo json_encode($respond);
#echo $respond;
?>

 

　　2.3、建立跨域代理腳本

　　跨域請求解決：為避免同源策略，可使用服務器端代理即寫個代理腳本放入自己的域中，使用ajax來訪問代理腳本，腳本遠程訪問api接收數據，再將數據返回給需要的地方（好處：可是在代理的時候將接收回來的數據進行相應的數據類型結構處理，再返回需要的地方）

　　Agency.class.php【www.test99.com】

<?php
class Agency
{
    #允許訪問的api域名、返回的數據類型
    public $allowHost=array('test88.com'=>array('mimetype'=>'aplication/json'));
    public $host='';

    public function __construct()
    {
        $this->host=parse_url("http:/".$_SERVER['PATH_INFO'],PHP_URL_HOST); #提取域名參數
    }

    /**
    * @desc 設置允許去訪問的主機域名
    *
    * @param $host   string 域名
    * @param $array  array  數組，放回的數據類型
    */    
    public function setAllowHost($host, $array=array('mimetype'=>'aplication/json'))
    {
        $this->allowHost[$host]=$array;
    }

    /**
    * @desc 判斷域名
    *
    * @param $host string 域名
    */
    private function decide($host)
    {
        if(!isset($this->allowHost[$host])) #判斷host是否允許代理訪問
        {
            header("Status:403 Forbidden");
            exit;
        }
        return true;
    }

    public function requestPost()
    {
        $host=$this->host;
        $this->decide($host);   #判斷
        $host='www.'.$host;  //拼接host
        $uri=strrchr($_SERVER['PATH_INFO'],'/'); #提取具體URI
        $port=80;
        $link=fsockopen($host,$port);
        //請求行
        #$request_data="POST /WebServer.php HTTP/1.1\r\n";
        $request_data="POST $uri HTTP/1.1\r\n";
        //請求頭
        #$request_data.="Host: www.test88.com\r\n";
        $request_data.="Host: $host\r\n";
        $request_data.="User-Agent: Mozilla/5.0 (Windows NT 6.2; WOW64; rv:10.0) Gecko/20100101 Firefox/10.0\r\n";
        $request_data.="Connection: keep-alive\r\n";
        #post數據
        #$post_data=array('name'=>$_POST['name'],'ff'=>'bbb');
        $post_content=http_build_query($_POST);
        $len=strlen($post_content);
        $request_data.="Content-Length: ".$len."\r\n";
        $request_data.="Content-Type: application/x-www-form-urlencoded\r\n";
        
        $request_data.="\r\n"; //空行表示頭結束
        
        //請求主體
        $request_data.=$post_content;
        
        //發送數據
        fwrite($link,$request_data);
        
        //接收數據
        $inheader=1;
        while(!feof($link))
        {
            #echo fgets($link,1024);
            //除去請求頭，只顯示返回數據
            $data=fgets($link,1024);
            if($inheader && ($data=="\n" || $data=="\r\n"))
            {
                $inheader=0;
            }
            if($inheader==0)
            {
                var_dump(json_decode($data));
                echo ($data);  #用於測試
            }
        }
        //關閉請求
        fclose($link);
    }


}

 

　　實例化腳本：agency.php【www.test99.com】

<?php
include "./Agency.class.php";
$a=new Agency();
$a->requestPost();
?>

　　2.4、Ajax訪問

　　建立相應的html文件

　　button.html【www.test99.com】

<!DOCTYPE html>
<html>
<head>
    <meta charset="utf-8">
    <title>button</title>
</head>
<body>
<button id='b1'>按鈕1</button>
</body>
<script type="text/javascript">
var b1=document.getElementById('b1');
b1.onclick=function()
{
    var xhr=new XMLHttpRequest();
    xhr.onreadystatechange=function()
    {
        if(xhr.readyState==4)
        {
            //document.body.innerHTML+=xhr.responseText;
            alert(xhr.responseText)
        }
    }
    //代理文件+(需要訪問的api的域名+api具體的某個接口)
    xhr.open('post','./agency.php/test88.com/WebServer.php');   
        xhr.setRequestHeader('content-type','application/x-www-form-urlencoded');
        //api接口參數使用info來傳遞
        var info='method=look&name=小明&age=20&action=打架';   //相應參數
        xhr.send(info);
}
</script>
</html>

　　2.5、開始測試

　　訪問www.test99.com/button.html

　　並點擊按鈕1

　　

　　　　

　　更改訪問方法method=test，繼續訪問

大功告成！

3、總結

　　總的來說，我所寫的這個例子是非常非常簡單的，僅僅只是用來參考哈。當然啦，性能上肯定是雞肋。在我自己做簡單測試的時候，Ajax刷新返回數據都非常緩慢。對於小白的我們來說，結合一個簡單實用的例子來學習了解一門技術還是不錯的！希望大家對RPC的學習不要止步於此哈，畢竟我這篇博客是入門級的，更多相關的RPC知識還等着大家去挖掘呢！

 

（以上是自己的一些見解，若有不足或者錯誤的地方請各位指出）

 作者：那一葉隨風   http://www.cnblogs.com/phpstudy2015-6/

 原文地址：http://www.cnblogs.com/phpstudy2015-6/p/6850658.html 

 聲明：本博客文章為原創，只代表本人在工作學習中某一時間內總結的觀點或結論。轉載時請在文章頁面明顯位置給出原文鏈接