PHP程序員簡單的開展服務治理架構操作詳解(二)

更新時間：2020年05月14日 11:24:25 作者：CrazyCodes

這篇文章主要介紹了PHP程序員簡單的開展服務治理架構操作,結合實例形式分析了rpc客戶端與服務器相關實現(xiàn)技巧,需要的朋友可以參考下

名詞解釋

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

這個時候你就疑惑了?，如何跨語言調(diào)用

基本概念

如何調(diào)用這就需要講一下我們強大的通信協(xié)議了。

http (tcp)

超文本傳輸協(xié)議，正常訪問瀏覽器啥看新聞、購物的時候必定使用，需要客戶端和服務端握手?成功才可以正常顯示，這中間握手的流出很復雜，執(zhí)行各種各樣的解碼編碼(為了方便理解，暫時這么想吧)

rpc

遠程過程調(diào)用協(xié)議,RPC采用客戶機/服務器模式。請求程序就是一個客戶機，而服務提供者就是一個服務器。首先，客戶機調(diào)用進程發(fā)送一個有進程參數(shù)的調(diào)用信息到服務進程，然后等待應答信息。在服務器端，進程保持睡眠狀態(tài)直到調(diào)用信息到達為止。當一個調(diào)用信息到達，服務器獲得進程參數(shù)，計算結果，發(fā)送答復信息，然后等待下一個調(diào)用信息，最后，客戶端調(diào)用進程接收答復信息，獲得進程結果，然后調(diào)用執(zhí)行繼續(xù)進行。

rpc的優(yōu)勢很多，現(xiàn)在你大可理解為rpc通信要比http通信快很多就是了。

這個時候facebook和apache就厲害了，它們基于rpc通信協(xié)議開發(fā)出了一套thrift

實現(xiàn)方法

上面假設你都沒看懂，這里我們實戰(zhàn)下。
首先rpc我們通過使用swoole來實現(xiàn)，其他的手碼。
分為客戶端和服務端做下演示

客戶端

首先我們new一個client類，去調(diào)用服務端的UserSerivce這個類,并且調(diào)用UserService類中的getUserInfo方法。

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

var_dump($userInfo);

Client中我們只需要干這樣的一件事,使用php魔術方法__call去調(diào)用一個不存在的方法

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);
  // 我們將要發(fā)送的數(shù)據(jù)是事先約定好的，跟寫對外開放的Api一樣
  $rpcClient->send(json_encode([
   'service'=>$this->serviceName,
   'action'=>$name,
   'params'=>$arguments[0]
  ]));
  $rpcClient->close();
 }
}

這個時候數(shù)據(jù)就通過rpc協(xié)議以json格式發(fā)送到了服務端

服務端

$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 則就是客戶端發(fā)送過來的數(shù)據(jù)，我們可以這樣做來做到去調(diào)用類,當然你必須遵守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();