PHP遠(yuǎn)程調(diào)用以及RPC框架

前言

一個(gè)項(xiàng)目，從開(kāi)始到版本更新，一直到最后的版本維護(hù)。功能在不斷增多，對(duì)應(yīng)的代碼量也在不斷增加，也就意味著項(xiàng)目變得更不可維護(hù)，這時(shí)候，我們需要用拆分的方式將一個(gè)項(xiàng)目打散，以便開(kāi)發(fā)團(tuán)隊(duì)更好的對(duì)項(xiàng)目進(jìn)行維護(hù)。

分模塊

這個(gè)階段，一般也是項(xiàng)目的初級(jí)階段，由于人手不夠，一個(gè)服務(wù)端的接口項(xiàng)目只有一個(gè)開(kāi)發(fā)進(jìn)行維護(hù)，根據(jù)開(kāi)發(fā)的習(xí)慣，會(huì)把項(xiàng)目分成若干個(gè)模塊進(jìn)行開(kāi)發(fā)，在一個(gè)項(xiàng)目下進(jìn)行部署。

這樣做的缺點(diǎn)在于項(xiàng)目會(huì)隨著版本更新而變得不可維護(hù)。

分項(xiàng)目

隨著每個(gè)模塊功能的不斷完善，代碼變得更加臃腫。這時(shí)候需要對(duì)項(xiàng)目進(jìn)行拆分，比如上面的圖，分成用戶(hù)體系項(xiàng)目、支付體系項(xiàng)目。

CURL

開(kāi)始大家會(huì)采用CURL的方式對(duì)外部資源進(jìn)行訪問(wèn)。

比如某短信平臺(tái)SDK,比如各大第三方提供的SDK,糾結(jié)到源碼發(fā)現(xiàn)都是直接采用CURL函數(shù)的方式進(jìn)行訪問(wèn)。

優(yōu)點(diǎn)在于沒(méi)有環(huán)境要求，能直接用。
缺點(diǎn)在于并發(fā)訪問(wèn)的資源占用問(wèn)題。

//新浪微博SDK的http請(qǐng)求部分源碼
 /**
     * Make an HTTP request
     *
     * @return string API results
     * @ignore
     */
    function http($url, $method, $postfields = NULL, $headers = array()) {
        $this->http_info = array();
        $ci = curl_init();
        /* Curl settings */
        curl_setopt($ci, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_0);
        curl_setopt($ci, CURLOPT_USERAGENT, $this->useragent);
        curl_setopt($ci, CURLOPT_CONNECTTIMEOUT, $this->connecttimeout);
        curl_setopt($ci, CURLOPT_TIMEOUT, $this->timeout);
        curl_setopt($ci, CURLOPT_RETURNTRANSFER, TRUE);
        curl_setopt($ci, CURLOPT_ENCODING, "");
        curl_setopt($ci, CURLOPT_SSL_VERIFYPEER, $this->ssl_verifypeer);
        if (version_compare(phpversion(), '5.4.0', '')) {
            curl_setopt($ci, CURLOPT_SSL_VERIFYHOST, 1);
        } else {
            curl_setopt($ci, CURLOPT_SSL_VERIFYHOST, 2);
        }
        curl_setopt($ci, CURLOPT_HEADERFUNCTION, array($this, 'getHeader'));
        curl_setopt($ci, CURLOPT_HEADER, FALSE);

        switch ($method) {
            case 'POST':
                curl_setopt($ci, CURLOPT_POST, TRUE);
                if (!empty($postfields)) {
                    curl_setopt($ci, CURLOPT_POSTFIELDS, $postfields);
                    $this->postdata = $postfields;
                }
                break;
            case 'DELETE':
                curl_setopt($ci, CURLOPT_CUSTOMREQUEST, 'DELETE');
                if (!empty($postfields)) {
                    $url = "{$url}?{$postfields}";
                }
        }

        if ( isset($this->access_token)  $this->access_token )
            $headers[] = "Authorization: OAuth2 ".$this->access_token;

        if ( !empty($this->remote_ip) ) {
            if ( defined('SAE_ACCESSKEY') ) {
                $headers[] = "SaeRemoteIP: " . $this->remote_ip;
            } else {
                $headers[] = "API-RemoteIP: " . $this->remote_ip;
            }
        } else {
            if ( !defined('SAE_ACCESSKEY') ) {
//                $headers[] = "API-RemoteIP: " . $_SERVER['REMOTE_ADDR'];
            }
        }
        curl_setopt($ci, CURLOPT_URL, $url );
        curl_setopt($ci, CURLOPT_HTTPHEADER, $headers );
        curl_setopt($ci, CURLINFO_HEADER_OUT, TRUE );

        $response = curl_exec($ci);
        $this->http_code = curl_getinfo($ci, CURLINFO_HTTP_CODE);
        $this->http_info = array_merge($this->http_info, curl_getinfo($ci));
        $this->url = $url;

        if ($this->debug) {
            echo "=====post data======\r\n";
            var_dump($postfields);

            echo "=====headers======\r\n";
            print_r($headers);

            echo '=====request info====='."\r\n";
            print_r( curl_getinfo($ci) );

            echo '=====response====='."\r\n";
            print_r( $response );
        }
        curl_close ($ci);
        return $response;
    }

RPC

遠(yuǎn)程過(guò)程調(diào)用協(xié)議

RPC（Remote Procedure Call Protocol）——遠(yuǎn)程過(guò)程調(diào)用協(xié)議，它是一種通過(guò)網(wǎng)絡(luò)從遠(yuǎn)程計(jì)算機(jī)程序上請(qǐng)求服務(wù)，而不需要了解底層網(wǎng)絡(luò)技術(shù)的協(xié)議。RPC協(xié)議假定某些傳輸協(xié)議的存在，如TCP或UDP，為通信程序之間攜帶信息數(shù)據(jù)。在OSI網(wǎng)絡(luò)通信模型中，RPC跨越了傳輸層和應(yīng)用層。RPC使得開(kāi)發(fā)包括網(wǎng)絡(luò)分布式多程序在內(nèi)的應(yīng)用程序更加容易。

RPC采用客戶(hù)機(jī)/服務(wù)器模式。請(qǐng)求程序就是一個(gè)客戶(hù)機(jī)，而服務(wù)提供程序就是一個(gè)服務(wù)器。首先，客戶(hù)機(jī)調(diào)用進(jìn)程發(fā)送一個(gè)有進(jìn)程參數(shù)的調(diào)用信息到服務(wù)進(jìn)程，然后等待應(yīng)答信息。在服務(wù)器端，進(jìn)程保持睡眠狀態(tài)直到調(diào)用信息到達(dá)為止。當(dāng)一個(gè)調(diào)用信息到達(dá)，服務(wù)器獲得進(jìn)程參數(shù)，計(jì)算結(jié)果，發(fā)送答復(fù)信息，然后等待下一個(gè)調(diào)用信息，最后，客戶(hù)端調(diào)用進(jìn)程接收答復(fù)信息，獲得進(jìn)程結(jié)果，然后調(diào)用執(zhí)行繼續(xù)進(jìn)行。

Yar

鳥(niǎo)哥出品的RPC框架，輕量級(jí)框架。

?php
class API {
    /**
     * the doc info will be generated automatically into service info page.
     * @params
     * @return
     */
    public function api($parameter, $option = "foo") {
    }

    protected function client_can_not_see() {
    }
}

$service = new Yar_Server(new API());
$service->handle();
?>

調(diào)用代碼

?php
$client = new Yar_Client("http://host/api/");
$result = $client->api("parameter);
?>

注意的是鳥(niǎo)哥出的東西文檔比較少，需要多調(diào)試。

Thrift

thrift是一個(gè)軟件框架，用來(lái)進(jìn)行可擴(kuò)展且跨語(yǔ)言的服務(wù)的開(kāi)發(fā)。它結(jié)合了功能強(qiáng)大的軟件堆棧和代碼生成引擎，以構(gòu)建在 C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, Smalltalk, and OCaml 這些編程語(yǔ)言間無(wú)縫結(jié)合的、高效的服務(wù)。

遠(yuǎn)程調(diào)用的意義在于，不同的子項(xiàng)目可以用更適合自己的語(yǔ)言來(lái)解決，更有效率的實(shí)現(xiàn)需求。

同時(shí)，對(duì)團(tuán)隊(duì)的開(kāi)發(fā)來(lái)講，更能提高整體的技術(shù)水平。

SOAP

由于用的XML就不多描述了，畢竟還是json用的多。

JSON-RPC

下面是返回值的標(biāo)準(zhǔn)

--> [

    {"jsonrpc": "2.0", "method": "sum", "params": [1,2,4], "id": "1"},

    {"jsonrpc": "2.0", "method": "notify_hello", "params": [7]},

    {"jsonrpc": "2.0", "method": "subtract", "params": [42,23], "id": "2"},

    {"foo": "boo"},

    {"jsonrpc": "2.0", "method": "foo.get", "params": {"name": "myself"}, "id": "5"},

    {"jsonrpc": "2.0", "method": "get_data", "id": "9"} 

    ]

-- [

    {"jsonrpc": "2.0", "result": 7, "id": "1"},

    {"jsonrpc": "2.0", "result": 19, "id": "2"},

    {"jsonrpc": "2.0", "error": {"code": -32600, "message": "Invalid Request"}, "id": null},

    {"jsonrpc": "2.0", "error": {"code": -32601, "message": "Method not found"}, "id": "5"},

    {"jsonrpc": "2.0", "result": ["hello", 5], "id": "9"}

    ]

實(shí)際上你會(huì)發(fā)現(xiàn)我們?cè)诮o客戶(hù)端提供接口的返回值，就是按照這個(gè)標(biāo)準(zhǔn)來(lái)做的。

相應(yīng)的，服務(wù)端對(duì)服務(wù)端的數(shù)據(jù)接收和返回，也要同樣按照這個(gè)標(biāo)準(zhǔn)來(lái)做。

項(xiàng)目拆分帶來(lái)的變化

項(xiàng)目細(xì)化

一個(gè)模塊對(duì)應(yīng)一個(gè)項(xiàng)目，項(xiàng)目之間通過(guò)基于REST的接口標(biāo)準(zhǔn)進(jìn)行面向資源的數(shù)據(jù)訪問(wèn)。

人員需求

項(xiàng)目拆分的前提是一個(gè)項(xiàng)目不足以滿足現(xiàn)有的業(yè)務(wù)發(fā)展要求，也就意味著拆分之后的開(kāi)發(fā)人員數(shù)量的擴(kuò)增。

游擊隊(duì)向正規(guī)軍編制的跨越！

文檔

更多的項(xiàng)目也就意味著更多的接口調(diào)用文檔，適當(dāng)?shù)奶幚砦臋n才能更好的提高團(tuán)隊(duì)協(xié)作效率。

后記

服務(wù)的遠(yuǎn)程調(diào)用在于怎么合理的把一個(gè)正在變得不可維護(hù)的項(xiàng)目從焦油坑中解救出來(lái)，并提高項(xiàng)目整體能承載的業(yè)務(wù)量，不過(guò)，世界上沒(méi)有銀彈。

以上就是PHP遠(yuǎn)程調(diào)用以及RPC框架的詳細(xì)內(nèi)容，更多關(guān)于PHP遠(yuǎn)程調(diào)用的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！