一直以来,我们都是采用Restfull的方式,今天让我们来认识一种更高效的调用协议——RPC

RPC(Remote Procedure Call Protocol)——远程过程调用协议,它是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在,如TCP或UDP,为通信程序之间携带信息数据。在OSI网络通信模型中,RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。

一直以来,我们都是采用Restfull的方式。

今天让我们来认识一种更高效的调用协议——RPC

PHP的RPC框架并不少,比如鸟叔的Yar,比如我们今天讲到的Hprose。

鸟叔的Yar只支持PHP,而Hprose提供了多种客户端。

Hprose

这就为我们搭建一个跨语言的服务提供了可能。

另外一个很重要的是原因是Hprose不止可以搭建基于HTTP协议的RPC服务,还可以搭建基于Socket协议的RPC服务!

众所周知,HTTP协议是应用层协议,而HTTP是基于Socket的。这就意味着更高效的RPC服务。

好了,废话不多说,现在我们直接来看Hprose官方给出的demo。

Server

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
<?php
    require_once('Hprose.php');

    function hello($name) {
        return 'Hello ' . $name;
    }

    $server = new HproseHttpServer();
    $server->addFunction('hello');
    $server->start();

##Client

1
2
3
4
<?php
    require_once("Hprose.php");
    $client = new HproseHttpClient('http://127.0.0.1/server.php');
    echo $client->hello('World');

RPC,远程过程调用协议

何为远程过程调用协议,通过这个demo就可以很轻松的理解了。

简单来说,就是通过RPC,你可以将你的一个方法发布出去对外提供服务。

而对于客户端来说,这就是一个方法,客户端可以像调用本地方法一样调用远程的方法。

是不是很酷!

那么我们该如何将RPC集成到Yaf中呢?

最理想的方式是将RPC服务封装成一个类,在我们的控制器里继承这个类就可以将我们的这个控制器变成一个RPC服务。

那么该如何来实现呢?

直接来看代码

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
<?php

/**
 * Created by PhpStorm.
 * User: yanbo
 * Date: 16/4/7
 * Time: 下午1:21
 */
class TestController extends Rpc
{

    public function test()
    {
        return 'This is a rpc function.';
    }
}
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
<?php

/**
 * @author yanbo
 * @desc 基础控制器
 */

class Rpc extends Yaf_Controller_Abstract {

    use Trait_Hprose;

    public function init() {

        $this->initRpc();
    }

可以看到,Rpc类就是我们的Base类。只不过在init方法中初始化了RPC服务。

这里有两个坑,一个是PHP不支持多重继承,一个是Yaf框架的控制器必须继承Yaf_Controller_Abstract。

所以,这里只能采用Trait的方式继承Hprose,然后在Rpc的构造函数中初始化Hprose。

小知识:Trait 是 PHP5.4 中的新特性,是 PHP 多重继承的一种解决方案。

最后给大家来看下Hprose类

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
<?php

/**
 * Created by PhpStorm.
 * User: yanbo
 * Date: 16/4/7
 * Time: 下午1:32
 */
Trait Trait_Hprose
{
    protected $allowMethodList  =   '';
    protected $crossDomain      =   false;
    protected $P3P              =   false;
    protected $get              =   true;
    protected $debug            =   false;

    /**
     * 架构函数
     * @access public
     */
    public function initRpc() {
        //控制器初始化
        if(method_exists($this,'_initialize'))
            $this->_initialize();
        //导入类库
        Yaf_Loader::import('Rpc/Hprose.php');

        //实例化HproseHttpServer
        $server     =   new \HproseHttpServer();
        if($this->allowMethodList){
            $methods    =   $this->allowMethodList;
        }else{
            $methods    =   get_class_methods($this);
            $methods    =   array_diff($methods, array('__construct','__call','_initialize', '__destruct', 'init', 'indexAction'));
        }

        $server->addMethods($methods,$this);
        if($this->debug) {
            $server->setDebugEnabled(true);
        }
        // Hprose设置
        $server->setCrossDomainEnabled($this->crossDomain);
        $server->setP3PEnabled($this->P3P);
        $server->setGetEnabled($this->get);
        // 启动server
        $server->start();

        exit;
    }

    /**
     * 魔术方法 有不存在的操作的时候执行
     * @access public
     * @param string $method 方法名
     * @param array $args 参数
     * @return mixed
     */
    public function __call($method,$args){}
}

这个类里的代码其实大部分都是抄TP的,天下代码一大抄嘛。

哈哈哈~

#后记 虽然实现了最初的目标,但是由于Yaf的特性,必须继承Yaf_Controller_Abstract。所以get_class_methods的时候会把Yaf_Controller_Abstract中的方法也变成RPC服务,这是唯一的一个缺憾。。。

我是闫大伯,一只求知欲旺盛的程序猿