php函数作用（php8环境原生实现rpc）PHP函数 / PHP函数在分布式系统中的应用...

大数据分布式架构盛行时代的程序员面试，常常遇到分布式架构，RPC,本文的主角是RPC,英文名为Remote Procedure Call，翻译过来为“远程过程调用”主流的平台中都支持各种远程调用技术，以满足分布式系统架构中不同的系统之间的远程通信和相互调用。

远程调用的应用场景极其广泛，实现的方式也各式各样作为WEB开发中主力军，PHP也是支持RPC的，那么如何原生实现呢？PHP原生实现RPC，主要用到以下这6个函数：stream_socket_server、stream_socket_client、stream_socket_accept、fread、fwrite、 fclose

rpc由于服务端和客户端组成，下面让我们一起来实现服务端和客户端。开发环境或者工具：PHP8.0+Visual Studio Code

先写服务端：

$rpc_server = stream_socket_server("tcp://127.0.0.1:6661",$err_no,$err_msg); if(!$rpc_server) { echo

"代码异常：".$err_no.",信息异常：".$err_msg; exit(); } while(true){ $result = [];//定义返回结果数组try{ $buff = stream_socket_accept($rpc_server); $data = fread($buff,

2048);//读取客户端选数据 $json = json_decode($data,true);//转换客户端的json数据 $class = $json[class

];//客户端需要访问的类 $file = $class.".php"; require_once $file;//包含进来if(!file_exists($file)){

//如果文件不存在thrownewException(文件不存在,404); } $method = $json[method];//客户端需要访问的方法 $obj =

new $class();//实例化对象 $rpc_server_data = $obj->$method($json[can_shu]);//调用方法 $result[

code] = 1;//成功返回1 $result[data] = $rpc_server_data;//返回数据 $result[msg] = "请求成功"; $result_data = json_encode($result);

//转换为json数据 fwrite($buff,$result_data); fclose($rpc_server);//关闭资源 }catch(Excepiton $e){ $result[

code] = $e->getCode();//失败返回 $result[data] = $rpc_server_data;//返回空数据 $result[msg] = $e->getMessage();

//失败返回 $result_data = json_encode($result);//转换为json数据 fwrite($buff,$result); fclose($rpc_server);

//关闭资源 }编写服务端辅助文件login.php：

classlogin{ publicfunctionget_account($number=){ return"编程自学".$number; } }接着写客户端：

$rpc_client = stream_socket_client("tcp://127.0.0.1:6661",$err_no,$err_msg); if(!$rpc_client) { echo

"代码异常：".$err_no.",信息异常：".$err_msg; exit(); } $c_data[class] = "login"; $c_data[method] = "get_account"

; $c_data[can_shu] = "8"; $rpc_data = json_encode($c_data); fwrite($rpc_client,$rpc_data);//发送给服务端 $rpc_server_data = fread($rpc_client,

2048);//读取服务端数据 $sever_json = json_decode($rpc_server_data);//解码json数据 fclose($rpc_client);//关闭资源 var_dump($sever_json);

//打印启动服务端：php rpc_server.php

然后启动客户端：php rpc_client.php，可以看到下面效果：

改造成从浏览器中打开：

//rpc：publicfunctiontestRpc(){ $rpc_client = stream_socket_client("tcp://127.0.0.1:6661",$err_no,$err_msg);

if(!$rpc_client) { echo"代码异常：".$err_no.",信息异常：".$err_msg; exit(); } $c_data[

class] = $_GET[c]; $c_data[method] = $_GET[m]; $c_data[can_shu] = $_GET[n]; $rpc_data = json_encode($c_data); fwrite($rpc_client,$rpc_data);

//发送给服务端 $rpc_server_data = fread($rpc_client,2048);//读取服务端数据 $sever_json = json_decode($rpc_server_data,

true);//解码json数据 fclose($rpc_client);//关闭资源 dd($sever_json);//打印 }启动服务，在浏览器中打开http://127.0.0.1:8000/test-rpc?c=login&m=get_account&n=8

可以看到下面效果：

这一节就介绍到这里了。