詳解如何利用PHP實現RPC

第詳解如何利用PHP實現RPC目錄1.什么是RPC2.從通信協議的層面3.從不同的開發(fā)語言和平臺層面4.從調用過程來看5.常見的幾種通信方式6.php實現簡單的rpc1.目錄結構2.rpc服務端3.rpc客戶端4.提供服務的文件5.效果7.RPC的注意事項

1.什么是RPC

RPC全稱為RemoteProcedureCall，翻譯過來為遠程過程調用。主流的平臺中都支持各種遠程調用技術，以滿足分布式系統(tǒng)架構中不同的系統(tǒng)之間的遠程通信和相互調用。遠程調用的應用場景極其廣泛，實現的方式也各式各樣。

2.從通信協議的層面

基于HTTP協議的（例如基于文本的SOAP（XML）、Rest（JSON），基于二進制Hessian（Binary））

基于TCP協議的（通常會借助Mina、Netty等高性能網絡框架）

3.從不同的開發(fā)語言和平臺層面

單種語言或平臺特定支持的通信技術(例如Java平臺的RMI、.NET平臺Remoting)

支持跨平臺通信的技術（例如HTTPRest、Thrift等）

4.從調用過程來看

同步通信調用（同步RPC）

異步通信調用（MQ、異步RPC）

5.常見的幾種通信方式

遠程數據共享（例如：共享遠程文件，共享數據庫等實現不同系統(tǒng)通信）

消息隊列

RPC（遠程過程調用）

6.php實現簡單的rpc

1.目錄結構

2.rpc服務端

php

*User:yuzhao

*CreateTime:2025/11/15下午11:46

*Description:Rpc服務端

classRpcServer{

*User:yuzhao

*CreateTime:2025/11/15下午11:51

*@vararray

*Description:此類的基本配置

private$params=[

'host'='',//ip地址，列出來的目的是為了友好看出來此變量中存儲的信息

'port'='',//端口

'path'=''//服務目錄

*User:yuzhao

*CreateTime:2025/11/16上午12:14

*@vararray

*Description:本類常用配置

private$config=[

'real_path'='',

'max_size'=2048//最大接收數據大小

*User:yuzhao

*CreateTime:2025/11/15下午11:50

*@varnul

*Description:

private$server=null;

*Rpcconstructor.

publicfunction__construct($params)

$this-check();

$this-init($params);

*User:yuzhao

*CreateTime:2025/11/16上午12:0

*Description:必要驗證

privatefunctioncheck(){

$this-serverPath();

*User:yuzhao

*CreateTime:2025/11/15下午11:48

*Description:初始化必要參數

privatefunctioninit($params){

//將傳遞過來的參數初始化

$this-params=$params;

//創(chuàng)建tcpsocket服務

$this-createServer();

*User:yuzhao

*CreateTime:2025/11/16上午12:0

*Description:創(chuàng)建tcpsocket服務

privatefunctioncreateServer(){

$this-server=stream_socket_server("tcp://{$this-params['host']}:{$this-params['port']}",$errno,$errstr);

if(!$this-server)exit([

$errno,$errstr

*User:yuzhao

*CreateTime:2025/11/15下午11:57

*Description:rpc服務目錄

publicfunctionserverPath(){

$path=$this-params['path'];

$realPath=realpath(__DIR__.$path);

if($realPath===false||!file_exists($realPath)){

exit("{$path}error!");

$this-config['real_path']=$realPath;

*User:yuzhao

*CreateTime:2025/11/15下午11:51

*Description:返回當前對象

publicstaticfunctioninstance($params){

returnnewRpcServer($params);

*User:yuzhao

*CreateTime:2025/11/16上午12:06

*Description:運行

publicfunctionrun(){

while(true){

$client=stream_socket_accept($this-server);

if($client){

echo"有新連接\n";

$buf=fread($client,$this-config['max_size']);

print_r('接收到的原始數據:'.$buf."\n");

//自定義協議目的是拿到類方法和參數(可改成自己定義的)

$this-parseProtocol($buf,$class,$method,$params);

//執(zhí)行方法

$this-execMethod($client,$class,$method,$params);

//關閉客戶端

fclose($client);

echo"關閉了連接\n";

*User:yuzhao

*CreateTime:2025/11/16上午12:19

*@param$class

*@param$method

*@param$params

*Description:執(zhí)行方法

privatefunctionexecMethod($client,$class,$method,$params){

if($class$method){

//首字母轉為大寫

$class=ucfirst($class);

$file=$this-params['path'].'/'.$class.'.php';

//判斷文件是否存在，如果有，則引入文件

if(file_exists($file)){

require_once$file;

//實例化類，并調用客戶端指定的方法

$obj=new$class();

//如果有參數，則傳入指定參數

if(!$params){

$data=$obj-$method();

}else{

$data=$obj-$method($params);

//打包數據

$this-packProtocol($data);

//把運行后的結果返回給客戶端

fwrite($client,$data);

}else{

fwrite($client,'classormethoderror');

*User:yuzhao

*CreateTime:2025/11/16上午12:10

*Description:解析協議

privatefunctionparseProtocol($buf,$class,$method,$params){

$buf=json_decode($buf,true);

$class=$buf['class'];

$method=$buf['method'];

$params=$buf['params'];

*User:yuzhao

*CreateTime:2025/11/16上午12:30

*@param$data

*Description:打包協議

privatefunctionpackProtocol($data){

$data=json_encode($data,JSON_UNESCAPED_UNICODE);

RpcServer::instance([

'host'='',

'port'=8888,

'path'='./api'

])-run();

3.rpc客戶端

php

*User:yuzhao

*CreateTime:2025/11/16上午12:2

*Description:Rpc客戶端

classRpcClient{

*User:yuzhao

*CreateTime:2025/11/16上午12:21

*@vararray

*Description:調用的地址

private$urlInfo=array();

*RpcClientconstructor.

publicfunction__construct($url)

$this-urlInfo=parse_url($url);

*User:yuzhao

*CreateTime:2025/11/16上午12:2

*Description:返回當前對象

publicstaticfunctioninstance($url){

returnnewRpcClient($url);

publicfunction__call($name,$arguments)

//TODO:Implement__call()method.

//創(chuàng)建一個客戶端

$client=stream_socket_client("tcp://{$this-urlInfo['host']}:{$this-urlInfo['port']}",$errno,$errstr);

if(!$client){

exit("{$errno}:{$errstr}\n");

$data=[

'class'=basename($this-urlInfo['path']),

'method'=$name,

'params'=$arguments

//向服務端發(fā)送我們自定義的協議數據

fwrite($client,json_encode($data));

//讀取服務端傳來的數據

$data=fread($client,2048);

//關閉客戶端

fclose($client);

return$data;

$cli=newRpcClient(':8888/test');

echo$cli-tuzisir1()."\n";

echo$cli-tuzisir2(array('name'='tuzisir','age'=23));

4.提供服務的文件

php

*User:yuzhao

*CreateTime:2025/11/16上午12:28

*