Swoole RPC 的實(shí)現(xiàn)

FWHeart 發(fā)布于2019-07-01 12:49 / 1659人閱讀

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

概述

這是關(guān)于 Swoole 學(xué)習(xí)的第七篇文章：Swoole RPC 的實(shí)現(xiàn)。

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

第五篇：Swoole 多協(xié)議多端口的應(yīng)用

第四篇：Swoole HTTP 的應(yīng)用

第三篇：Swoole WebSocket 的應(yīng)用

第二篇：Swoole Task 的應(yīng)用

第一篇：Swoole Timer 的應(yīng)用

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

“哈哈哈...”

還有讀者說 “有一起學(xué)習(xí)的組織群嗎，可以在里面進(jìn)行疑難答疑？”

這個還真沒有，總覺得維護(hù)一個微信群不容易，因?yàn)樽约罕旧砭筒粣墼谌豪镎f話，另外，自己也在很多微信群中，開始氛圍挺好的，大家都聊聊技術(shù)，后來技術(shù)聊的少了改成聊八卦啦，再后來慢慢就安靜了，還有在群里起沖突的...

當(dāng)然我也知道維護(hù)一個微信群的好處是非常大的，如果有這方面經(jīng)驗(yàn)的同學(xué)，咱們一起交流交流 ~

還有出版社找我寫書的.

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

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

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

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

開始今天的文章吧，這篇文章實(shí)現(xiàn)了一個簡單的 RPC 遠(yuǎn)程調(diào)用，在實(shí)現(xiàn)之前需要先了解什么是 RPC，不清楚的可以看下之前發(fā)的這篇文章《我眼中的 RPC》。

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

舉個工作中的例子吧，在電商系統(tǒng)中的兩個模塊，個人中心模塊和訂單管理模塊，這兩個模塊是獨(dú)立部署的，可能不在一個機(jī)房，可能不是一個域名，現(xiàn)在個人中心需要通過用戶ID 和訂單類型獲取訂單數(shù)據(jù)。

實(shí)現(xiàn)效果 客戶端

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 單個請求，等待結(jié)果

發(fā)出請求后，分配給 Task ，并等待 Task 執(zhí)行完成后，再返回。

SN 單個請求，不等待結(jié)果

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

發(fā)送數(shù)據(jù)

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

type 同步/異步設(shè)置

token 可進(jìn)行權(quán)限驗(yàn)證

class 請求的類名

method 請求的方法名

uid 參數(shù)一

type 參數(shù)二

返回數(shù)據(jù)

request_method 請求方式

request_time 請求開始時間

response_time 請求結(jié)束時間

code 標(biāo)識

msg 標(biāo)識值

data 約定數(shù)據(jù)

query 請求參數(shù)

代碼 OnRequest.php

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

            //TODO 驗(yàn)證Token

            switch ($data["type"]) {
                case "SW": //單個請求,等待結(jié)果
                    $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": //單個請求,不等待結(jié)果
                    $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": //單個請求,不等待結(jié)果
                    $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));
    }
}

小結(jié)

Demo 代碼僅供參考，里面有很多不嚴(yán)謹(jǐn)?shù)牡胤剑?/p>

服務(wù)的調(diào)用方與提供方中間需要有一個服務(wù)注冊中心，很顯然上面的代碼中沒有，需要自己去實(shí)現(xiàn)。

服務(wù)注冊中心，負(fù)責(zé)管理 IP、Port 信息，提供給調(diào)用方使用，還要能負(fù)載均衡和故障切換。

根據(jù)自己的情況，服務(wù)注冊中心實(shí)現(xiàn)可容易可復(fù)雜，用 Redis 也行，用 Zookeeper、Consul 也行。

感興趣的也可以了解下網(wǎng)關(guān) Kong ，包括身份認(rèn)證、權(quán)限認(rèn)證、流量控制、監(jiān)控預(yù)警...

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

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

推薦閱讀

系統(tǒng)的講解 - SSO 單點(diǎn)登錄

系統(tǒng)的講解 - PHP WEB 安全防御

系統(tǒng)的講解 - PHP 緩存技術(shù)

系統(tǒng)的講解 - PHP 接口簽名驗(yàn)證

系統(tǒng)的講解 - PHP 浮點(diǎn)數(shù)高精度運(yùn)算

本文歡迎轉(zhuǎn)發(fā)，轉(zhuǎn)發(fā)請注明作者和出處，謝謝！

云服務(wù)器 GPU云服務(wù)器 rpc實(shí)現(xiàn) Swoole swoole+websocket php_swoole

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://m.hztianpu.com/yun/31542.html

發(fā)表評論

登陸后可評論

0條評論

FWHeart

男|高級講師

我要關(guān)注我要私信

TA的文章

Megalayer：雙十一優(yōu)惠，常規(guī)VPS五折，月付24.5元起，香港VPS/菲律賓VPS/美國VP

閱讀 2011·2021-11-15 17:58
CloudCone黑五預(yù)售款發(fā)布,洛杉磯MC機(jī)房KVM年付14.2美元起

閱讀 2203·2021-10-19 11:45
一文帶你簡單了解Wi-Fi Direct

閱讀 3638·2021-09-02 15:40
RackNerd提供美國大硬盤獨(dú)立服務(wù)器價格低至月費(fèi)$389 1Gbps 5IP

閱讀 2662·2021-07-25 10:50
background背景和border顏色，以及background-clip屬性，透明度問題探討

閱讀 3817·2019-08-30 15:56
CSS小技巧收藏

閱讀 3217·2019-08-30 12:44
精讀《Function VS Class 組件》

閱讀 1082·2019-08-26 13:38
使用node簡單實(shí)現(xiàn)記錄瀏覽量，不依賴數(shù)據(jù)庫

閱讀 1930·2019-08-23 18:29

成人无码视频,亚洲精品久久久久av无码,午夜精品久久久久久毛片,亚洲中文字幕日韩无码

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Swoole RPC 的實(shí)現(xiàn)

相關(guān)文章

swoolefy-基于swoole擴(kuò)展實(shí)現(xiàn)的高性能的常駐內(nèi)存型API和Web應(yīng)用服務(wù)框架

Swoft 源碼剖析 - RPC 功能實(shí)現(xiàn)

**Swoft 源碼剖析 - Swoole和Swoft的那些事 (Http/Rpc服務(wù)篇)**

PHP程序員如何簡單的開展服務(wù)治理架構(gòu)(一)

**Swoft 框架 1.0 正式來襲，首個基于 Swoole 原生協(xié)程的 PHP 框架**

發(fā)表評論

0條評論

FWHeart

男|高級講師

TA的文章

Megalayer：雙十一優(yōu)惠，常規(guī)VPS五折，月付24.5元起，香港VPS/菲律賓VPS/美國VP

CloudCone黑五預(yù)售款發(fā)布,洛杉磯MC機(jī)房KVM年付14.2美元起

一文帶你簡單了解Wi-Fi Direct

RackNerd提供美國大硬盤獨(dú)立服務(wù)器價格低至月費(fèi)$389 1Gbps 5IP

background背景和border顏色，以及background-clip屬性，透明度問題探討

CSS小技巧收藏

精讀《Function VS Class 組件》

使用node簡單實(shí)現(xiàn)記錄瀏覽量，不依賴數(shù)據(jù)庫

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Swoole RPC 的實(shí)現(xiàn)

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！