PHP程序員如何簡單的開展服務治理架構(二)

服務治理 治理的絕筆是服務，在一家公司有玩各類語言的程序員，如何去統一管理他們開發的服務，這是一個問題。

上一章主要講了下服務治理須要什麼，如何實現，這章咱們詳細的「肢解」一下服務治理的一個很是重要的組員 Thrift

上一章說明他的時候是這樣寫的

暫時大可理解爲能夠經過它去調用其餘開發語言的方法

本猿人已經寫好的服務治理 https://github.com/CrazyCodes...

名詞解釋

thrift實際上是一個軟件框架，用來進行可擴展且跨語言的服務的開發。它結合了功能強大的軟件堆棧和代碼生成引擎，以構建在 C++, Java, Go,Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, Smalltalk, and OCaml 這些編程語言間無縫結合的、高效的服務。

這個時候你就疑惑了?，如何跨語言調用

基本概念

如何調用這就須要講一下咱們強大的通訊協議了。

http (tcp)

超文本傳輸協議，正常訪問瀏覽器啥看新聞、購物的時候一定使用，須要客戶端和服務端握手?成功才能夠正常顯示，這中間握手的流出很複雜，執行各類各樣的解碼編碼(爲了方便理解，暫時這麼想吧)

rpc

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

rpc的優點不少，如今你大可理解爲rpc通訊要比http通訊快不少就是了。

這個時候facebook和apache就厲害了，它們基於rpc通訊協議開發出了一套thrift

實現方法

• 上面假設你都沒看懂，這裏咱們實戰下。
• 首先rpc咱們經過使用swoole來實現，其餘的手碼。
• 分爲客戶端和服務端作下演示

客戶端

首先咱們new一個client類，去調用服務端的UserSerivce這個類,而且調用UserService類中的getUserInfo方法。

$client = new Client('UserSerivce');
$userInfo = $client->getUserInfo(1);

var_dump($userInfo);

Client中咱們只須要幹這樣的一件事,使用php魔術方法__call去調用一個不存在的方法

class Client{
    protected $serviceName;
            
    public function __construct($serviceName){
        $this->serviceName = $serviceName;
    }
    public function __call($name, $arguments){
        $rpcClient = new \swoole_client(SWOOLE_SOCK_TCP);
        $rpcClient->connect('127.0.0.1',9503,0.5);
        // 咱們將要發送的數據是事先約定好的，跟寫對外開放的Api同樣
        $rpcClient->send(json_encode([
            'service'=>$this->serviceName,
            'action'=>$name,
            'params'=>$arguments[0]
        ]));
        $rpcClient->close();
    }
}

這個時候數據就經過rpc協議以json格式發送到了服務端

服務端

$server = new swoole_server("127.0.0.1", 9503);
$server->on('connect', function ($server, $fd){
    echo "connection open: {$fd}\n";
});
$server->on('receive', function ($server, $fd, $reactor_id, $data) {
    // $data 則就是客戶端發送過來的數據，咱們能夠這樣作來作到去調用類,固然你必須遵照PSR-4 Autoloader
    $request   = json_decode ($data, true);
    $className = $request['service'];
    $app       = new $className;
    $response  = $app->{$request['action']}($request['params']);
    
    $server->send($fd, "Swoole: {$data}");
    $server->close($fd);
});
$server->on('close', function ($server, $fd) {
    echo "connection close: {$fd}\n";
});
$server->start();

往期文章

• PHP程序員如何簡單的開展服務治理架構（一)

鳴謝

周夢康 https://mengkang.net/