Swoole RPC 的實現

FWHeart 發布于2019-07-01 12:49 / 1607人閱讀

摘要：概述這是關于學習的第七篇文章的實現。還有一些大佬加了微信，可能是出于對晚輩的提攜吧，偷偷告訴你，從大佬的朋友圈能學到很多東西。就到這了，上面的需要源碼的，加我微信。

概述

這是關于 Swoole 學習的第七篇文章：Swoole RPC 的實現。

第六篇：Swoole 整合成一個小框架

第五篇：Swoole 多協議多端口的應用

第四篇：Swoole HTTP 的應用

第三篇：Swoole WebSocket 的應用

第二篇：Swoole Task 的應用

第一篇：Swoole Timer 的應用

有位讀者說 “上篇文章，下載代碼后直接運行成功，代碼簡潔明了，簡直是 Swoole 入門最好的 Demo ”。

“哈哈哈...”

還有讀者說 “有一起學習的組織群嗎，可以在里面進行疑難答疑？”

這個還真沒有，總覺得維護一個微信群不容易，因為自己本身就不愛在群里說話，另外，自己也在很多微信群中，開始氛圍挺好的，大家都聊聊技術，后來技術聊的少了改成聊八卦啦，再后來慢慢就安靜了，還有在群里起沖突的...

當然我也知道維護一個微信群的好處是非常大的，如果有這方面經驗的同學，咱們一起交流交流 ~

還有出版社找我寫書的.

他們也真是放心，我自己肚子里幾滴墨水還是知道的，目前肯定是不行，以后嘛，再說。

還有一些大佬加了微信，可能是出于對晚輩的提攜吧，偷偷告訴你，從大佬的朋友圈能學到很多東西。

我真誠的建議，做技術的應該自己多總結總結，將自己會的東西寫出來分享給大家，先不說給別人帶來太多的價值，反正對自己的幫助是非常非常大的，這方面想交流的同學，可以加我，我可以給你無私分享。

可能都會說時間少，時間只要擠，總會有的，每個人都 24 小時，時間對每個人是最公平的。說到這推薦大家讀一下《暗時間》這本書，這是我這本書的讀書筆記，大家可以瞅瞅。

開始今天的文章吧，這篇文章實現了一個簡單的 RPC 遠程調用，在實現之前需要先了解什么是 RPC，不清楚的可以看下之前發的這篇文章《我眼中的 RPC》。

下面的演示代碼主要使用了 Swoole 的 Task 任務池，通過 OnRequest/OnReceive 獲得信息交給 Task 去處理。

舉個工作中的例子吧，在電商系統中的兩個模塊，個人中心模塊和訂單管理模塊，這兩個模塊是獨立部署的，可能不在一個機房，可能不是一個域名，現在個人中心需要通過用戶ID 和訂單類型獲取訂單數據。

實現效果 客戶端

HTTP 請求

//代碼片段
 "SW",
    "token" => "Bb1R3YLipbkTp5p0",
    "param" => [
        "class"  => "Order",
        "method" => "get_list",
        "param" => [
            "uid"  => 1,
            "type" => 2,
        ],
    ],
];

$ch = curl_init();
$options = [
    CURLOPT_URL  => "http://10.211.55.4:9509/",
    CURLOPT_POST => 1,
    CURLOPT_POSTFIELDS => json_encode($demo),
];
curl_setopt_array($ch, $options);
curl_exec($ch);
curl_close($ch);

TCP 請求

//代碼片段
$demo = [
    "type"  => "SW",
    "token" => "Bb1R3YLipbkTp5p0",
    "param" => [
        "class"  => "Order",
        "method" => "get_list",
        "param" => [
            "uid"  => 1,
            "type" => 2,
        ],
    ],
];
$this->client->send(json_encode($demo));

請求方式

SW 單個請求，等待結果

發出請求后，分配給 Task ，并等待 Task 執行完成后，再返回。

SN 單個請求，不等待結果

發出請求后，分配給 Task 之后，就直接返回。

發送數據

$demo = [
    "type"  => "SW",
    "token" => "Bb1R3YLipbkTp5p0",
    "param" => [
        "class"  => "Order",
        "method" => "get_list",
        "param" => [
            "uid"  => 1,
            "type" => 2,
        ],
    ],
];

type 同步/異步設置

token 可進行權限驗證

class 請求的類名

method 請求的方法名

uid 參數一

type 參數二

返回數據

request_method 請求方式

request_time 請求開始時間

response_time 請求結束時間

code 標識

msg 標識值

data 約定數據

query 請求參數

代碼 OnRequest.php

rawContent());
            self::$query   = $data;
            if (empty($data)) {
                self::$code = "-1";
                self::$msg  = "非法請求";
                self::end($request, $response);
            }

            //TODO 驗證Token

            switch ($data["type"]) {
                case "SW": //單個請求,等待結果
                    $task = [
                        "request" => $data,
                        "server"  => "http"
                    ];
                    $rs = $serv->task(json_encode($task), -1, function ($serv, $task_id, $rs_data) use ($request, $response) {
                        self::$code = "1";
                        self::$msg  = "成功";
                        self::$data = $rs_data["response"];
                        self::end($request, $response);
                    });
                    if ($rs === false) {
                        self::$code = "-1";
                        self::$msg  = "失敗";
                        self::end($request, $response);
                    }
                    break;

                case "SN": //單個請求,不等待結果
                    $task = [
                        "request" => $data,
                        "server"  => "http"
                    ];
                    $rs = $serv->task(json_encode($task));
                    if ($rs === false) {
                        self::$code = "-1";
                        self::$msg  = "失敗";
                    } else {
                        self::$code = "1";
                        self::$msg  = "成功";
                    }
                    self::end($request, $response);
                    break;
                default:
                    self::$code = "-1";
                    self::$msg  = "非法請求";
                    self::end($request, $response);
            }
        } catch(Exception $e) {
        }
    }

    private static function end($request = null, $response = null)
    {
        $rs["request_method"] = $request->server["request_method"];
        $rs["request_time"]   = $request->server["request_time"];
        $rs["response_time"]  = time();
        $rs["code"]           = self::$code;
        $rs["msg"]            = self::$msg;
        $rs["data"]           = self::$data;
        $rs["query"]          = self::$query;
        $response->end(json_encode($rs));
        self::$data = [];
        return;
    }
}

OnReceive.php

 $fd,
                        "request"      => $data,
                        "server"       => "tcp",
                        "request_time" => self::$request_time,
                    ];
                    $rs = $serv->task(json_encode($task));
                    if ($rs === false) {
                        self::$code = "-1";
                        self::$msg  = "失敗";
                        self::handlerTask($serv, $fd);
                    }
                    break;

                case "SN": //單個請求,不等待結果
                    $task = [
                        "fd"           => $fd,
                        "request"      => $data,
                        "server"       => "tcp",
                        "request_time" => self::$request_time,
                    ];
                    $rs = $serv->task(json_encode($task));
                    if ($rs === false) {
                        self::$code = "-1";
                        self::$msg  = "失敗";
                    } else {
                        self::$code = "1";
                        self::$msg  = "成功";
                    }
                    self::handlerTask($serv, $fd);
                    break;
                default:
                    self::$code = "-1";
                    self::$msg  = "非法請求";
                    self::handlerTask($serv, $fd);
            }
        } catch(Exception $e) {
        }
    }

    private static function handlerTask($serv, $fd)
    {
        $rs["request_method"] = "TCP";
        $rs["request_time"]   = self::$request_time;
        $rs["response_time"]  = time();
        $rs["code"]           = self::$code;
        $rs["msg"]            = self::$msg;
        $rs["data"]           = self::$data;
        $rs["query"]          = self::$query;
        $serv->send($fd, json_encode($rs));
    }
}

小結

Demo 代碼僅供參考，里面有很多不嚴謹的地方！

服務的調用方與提供方中間需要有一個服務注冊中心，很顯然上面的代碼中沒有，需要自己去實現。

服務注冊中心，負責管理 IP、Port 信息，提供給調用方使用，還要能負載均衡和故障切換。

根據自己的情況，服務注冊中心實現可容易可復雜，用 Redis 也行，用 Zookeeper、Consul 也行。

感興趣的也可以了解下網關 Kong ，包括身份認證、權限認證、流量控制、監控預警...

再推薦一個 Swoole RPC 框架 Hprose，支持多語言。

就到這了，上面的 Demo 需要源碼的，加我微信。（菜單-> 加我微信-> 掃我）

推薦閱讀

系統的講解 - SSO 單點登錄

系統的講解 - PHP WEB 安全防御

系統的講解 - PHP 緩存技術

系統的講解 - PHP 接口簽名驗證

系統的講解 - PHP 浮點數高精度運算

本文歡迎轉發，轉發請注明作者和出處，謝謝！

云服務器 GPU云服務器 rpc實現 Swoole swoole+websocket php_swoole

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/31542.html

swoolefy-基于swoole擴展實現的高性能的常駐內存型API和Web應用服務框架

摘要：是一個基于擴展實現的輕量級高性能的常駐內存型的和應用服務框架高度封裝了，，服務器，以及基于實現可擴展的服務，同時支持包方式安裝部署項目。基于實用，抽象事件處理類，實現與底層的回調的解耦，支持同步異步調用，內置等常用組件等。 swoolefy swoolefy是一個基于swoole擴展實現的輕量級高性能的常駐內存型的API和Web應用服務框架,高度封裝了http，websocket，ud...

lewinlee 2019-06-28 18:17 評論0 收藏0
Swoft 源碼剖析 - RPC 功能實現

摘要：值得一提的是目前的服務即服務，暫沒有其他的服務功能，所以基本上相關的配置指代的就是。會將請求傳遞給各個中間件，最終最終傳遞給處理。源碼剖析系列目錄作者：bromine鏈接：https://www.jianshu.com/p/411...來源：簡書著作權歸作者所有，本文已獲得作者授權轉載，并對原文進行了重新的排版。Swoft Github: https://github.com/swo...

marser 2019-06-28 18:49 評論0 收藏0
Swoft 源碼剖析 - Swoole和Swoft的那些事 (Http/Rpc服務篇)

摘要：和服務關系最密切的進程是中的進程組，絕大部分業務處理都在該進程中進行。隨后觸發一個事件各組件通過該事件進行配置文件加載路由注冊。事件每個請求到來時僅僅會觸發事件。服務器生命周期和服務基本一致，詳情參考源碼剖析功能實現作者：bromine鏈接：https://www.jianshu.com/p/4c0...來源：簡書著作權歸作者所有，本文已獲得作者授權轉載，并對原文進行了重新的排版。S...

張漢慶 2019-07-01 10:18 評論0 收藏0
PHP程序員如何簡單的開展服務治理架構(一)

摘要：管理這些服務方案則叫服務治理。協議假定某些傳輸協議的存在，如或，為通信程序之間攜帶信息數據。請求程序就是一個客戶機，而服務提供程序就是一個服務器。在服務器端，進程保持睡眠狀態直到調用信息到達為止。不涉及其他的語言及工具，我們從PHP本身來談如何實現服務治理本猿人已經寫好的服務治理 https://github.com/CrazyCodes... 治理什么？這個專業名詞很容易發現...

superPershing 2019-06-28 18:29 評論0 收藏0
Swoft 框架 1.0 正式來襲，首個基于 Swoole 原生協程的 PHP 框架

摘要：歷時年多緊鑼密鼓的開發，以及愉快而忙碌的春節假期，期間數從到快破，碼云首頁推薦，作者和社區的大力支持，正式版終于要和大家見面。此次更新新增了大量特性在易用性代碼復用性能方面都有所提升。可以用于構建高性能的系統中間件基礎服務等等。歷時 1 年多緊鑼密鼓的開發，以及愉快而忙碌的春節假期，期間 github star 數從 500 到快破 1k，碼云首頁推薦，Swoole作者 Rango ...

weij 2019-06-28 18:30 評論0 收藏0