php的轻量级rpc框架yar
目的:
类方法的远程调用,也就是一个rpc请求。RPC本质上也是一个网络请求,既然是请求,对于效率来说,就需要考虑了。yar是基于http来做的。
使用场景:
多个项目共享model总的来说这种调用代价挺好的,因为有网络开销。其实咱们也可以采用其他方式替代使用的时候注意安全问题。比如只支持内网调用。
yar的安装
官网详细介绍页面
pecl install yar
yar的特点:
能够实现多个请求并发。
如何使用:
本地的server说明:
server url地址 http://other.program.php/php-library/source/yar/model/yar_server.php
sever代码:
$server = new Yar_Server(new MyYarServer());
$server->handle();
client url地址:http://other.program.php/php-library/source/yar/pc_yar.php
client代码:
$pc_client = new Yar_Client($server_url);
$id = 12;
//就像调用本地方法一样
$pc_client->SetOpt(YAR_OPT_CONNECT_TIMEOUT, 1000);
$res = $pc_client->getData($id);
print_r($res);
client的并行调用,是采用curl的方式实现的
function callback($retval, $callinfo) {
var_dump($retval,$callinfo);
}
function error_callback($type, $error, $callinfo) {
error_log($error);
}
$server_url = "http://other.program.php/php-library/source/yar/model/yar_server.php";
Yar_Concurrent_Client::call($server_url, "getData", array("1"), "callback");
Yar_Concurrent_Client::call($server_url, "getData", array("2"));// if the callback is not specificed,
// callback in loop will be used
Yar_Concurrent_Client::call($server_url, "getData", array("3"), "callback", NULL, array(YAR_OPT_PACKAGER => "json"));
//this server accept json packager
Yar_Concurrent_Client::call($server_url, "getData", array("11"), "callback", NULL, array(YAR_OPT_TIMEOUT=>1));
Yar_Concurrent_Client::loop("callback","error_callback");
这些调用通过扩展的c代码实现,简单高效