RPC 定義
RPC（Remote Procedure Call）即遠程過程調用，指被調用方法的具體實現不在程序運行本地，而是在別的某個地方。主要應用于不同的系統之間的遠程通信和相互調用。
如 A 調用 B 提供的 remoteAdd 方法：
- 首先A與B之間建立一個TCP連接；
- 然后A把需要調用的方法名（這里是remoteAdd）以及方法參數（10， 20）序列化成字節流發送出去；
- B接受A發送過來的字節流，然后反序列化得到目標方法名，方法參數，接著執行相應的方法調用（可能是localAdd）并把結果30返回；
- A接受遠程調用結果
有些遠程調用選擇比較底層的 socket 協議，有些遠程調用選擇比較上層的 HTTP 協議。
遠程調用的好處：
- 解耦：當方法提供者需要對方法內實現修改時，調用者完全感知不到，不用做任何變更；這種方式在跨部門，跨公司合作的時候經常用到，并且方法的提供者我們通常稱為：服務的暴露方
這里使用 PHP Socket 來創建一個服務端和客戶端，目錄結構如下：
服務端
?php
class RpcServer {
protected $server = null;
public function __construct($host, $port, $path)
{
// 創建一個 Socket 服務
if(($this->server = socket_create(AF_INET,SOCK_STREAM,SOL_TCP)) 0) {
exit("socket_create() 失敗的原因是:".socket_strerror($this->server)."\n");
}
if(($ret = socket_bind($this->server,$host,$port)) 0) {
exit("socket_bind() 失敗的原因是:".socket_strerror($ret)."\n");
}
if(($ret = socket_listen($this->server,3)) 0) {
exit("socket_listen() 失敗的原因是:".socket_strerror($ret)."\n");
}
// 判斷 RPC 服務目錄是否存在
$realPath = realpath(__DIR__ . $path);
if ($realPath === false || !file_exists($realPath)) {
exit("{$path} error \n");
}
do {
$client = socket_accept($this->server);
if($client) {
// 一次性讀取
$buf = socket_read($client, 8024);
echo $buf;
//解析客戶端發送過來的協議
$classRet = preg_match('/Rpc-Class:\s(.*);\r\n/i', $buf, $class);
$methodRet = preg_match('/Rpc-Method:\s(.*);\r\n/i', $buf, $method);
$paramsRet = preg_match('/Rpc-Params:\s(.*);\r\n/i', $buf, $params);
if($classRet $methodRet) {
$class = ucfirst($class[1]);
$method = $method[1];
$params = json_decode($params[1], true);
$file = $realPath . '/' . $class . '.php'; // 類文件需要和類名一致
$data = ''; // 執行結果
// 判斷類文件是否存在
if(file_exists($file)) {
// 引入類文件
require_once $file;
// 實例化類
$rfc_obj = new ReflectionClass($class);
// 判斷該類指定方法是否存在
if($rfc_obj->hasMethod($method)) {
// 執行類方法
$rfc_method = $rfc_obj->getMethod($method);
$data = $rfc_method->invokeArgs($rfc_obj->newInstance(), [$params]);
} else {
socket_write($client, 'method error');
}
//把運行后的結果返回給客戶端
socket_write($client, $data);
}
} else {
socket_write($client, 'class or method error');
}
// 關閉客戶端
socket_close($client);
}
}while(true);
}
public function __destruct()
{
socket_close($this->server);
}
}
new RpcServer('127.0.0.1',8080,'./service');
客戶端
?php
class RpcClient {
protected $client = null;
protected $url_info = []; // 遠程調用 URL 組成部分
public function __construct($url)
{
// 解析 URL
$this->url_info = parse_url($url);
}
public function __call($name, $arguments)
{
// 創建一個客戶端
$this->client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if(!$this->client) {
exit('socket_create() 失敗');
}
socket_connect($this->client, $this->url_info['host'], $this->url_info['port']);
// 傳遞調用的類名
$class = basename($this->url_info['path']);
// 傳遞調用的參數
$args = '';
if(isset($arguments[0])) {
$args = json_encode($arguments[0]);
}
// 向服務端發送我們自定義的協議數據
$proto = "Rpc-Class: {$class};".PHP_EOL
."Rpc-Method: {$name};".PHP_EOL
."Rpc-Params: {$args};".PHP_EOL;
socket_write($this->client, $proto);
// 讀取服務端傳來的數據
$buf = socket_read($this->client, 8024);
socket_close($this->client);
return $buf;
}
}
$rpcClient = new RpcClient('http://127.0.0.1:8080/news');
echo $rpcClient->display(['title'=>'txl']);
echo $rpcClient->display(['title'=>'hello world']);
服務類 News
?php
class News {
public function display($data)
{
return json_encode(['result'=>"News display(), title is {$data['title']}"]);
}
}
運行測試：
Client
Server
到此這篇關于PHP創建簡單RPC服務案例詳解的文章就介紹到這了,更多相關PHP創建簡單RPC服務內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:- 詳解php中流行的rpc框架
- php實現的一個簡單json rpc框架實例
- PHP采用XML-RPC構造Web Service實例教程
- AMFPHP php遠程調用(RPC, Remote Procedure Call)工具 快速入門教程
- php xml-rpc遠程調用
