本文實例講述了PHP程序員簡單的開展服務治理架構操作。分享給大家供大家參考，具體如下：
服務治理 治理的絕筆是服務，在一家公司有玩各種語言的程序員，如何去統一管理他們開發的服務，這是一個問題。
上一章主要講了下服務治理需要什么，如何實現，這章我們詳細的“肢解”一下服務治理的一個非常重要的組員 Thrift
上一章說明他的時候是這樣寫的
暫時大可理解為可以通過它去調用其他開發語言的方法
本猿人已經寫好的服務治理 https://github.com/CrazyCodes/Service-Govern
名詞解釋
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方法。
|
1
2
3
4
|
$client = new Client('UserSerivce');$userInfo = $client->getUserInfo(1);var_dump($userInfo); |
Client中我們只需要干這樣的一件事,使用php魔術方法__call去調用一個不存在的方法
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
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格式發送到了服務端
服務端
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
$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://segmentfault.com/a/1190000013544601
