首页  >  文章  >  php教程  >  Hessian通讯协议【附PHP源代码】

Hessian通讯协议【附PHP源代码】

WBOY
WBOY原创
2016-06-06 09:52:391040浏览

 

提示:
  绿色加粗有下划线是文本的链接
  蓝色加粗强调
  红色加粗重点

PHP源码:
  点击下载

  

什么是Hessian

  

  Hessian是由caucho提供的一种开源的远程通讯协议。

  采用二进制 RPC 协议,基于 HTTP 传输,服务器端不用另开放防火墙端口。

  协议的规范是公开的,可以用于任意语言。

  采用客户机/服务器模式。

  请求程序就是一个客户机,而服务提供程序就是一个服务器。

  客户机调用进程发送一个有进程参数的调用信息到服务进程,然后等待应答信息。

  在服务器端,进程保持睡眠状态直到调用信息的到达为止。

  当一个调用信息到达,服务器获得进程参数,计算结果,发送答复信息,然后等待下一个调用信息,最后,客户端调用进程接收答复信息,

  获得进程结果,然后调用执行继续进行。

 

Hessian协议工作流程图

  

  客户端程序请求服务端函数 

  1.调用客户端句柄,执行传送参数。

  2.调用本地系统内核发送网络消息。

  3.消息传送到远程主机。

  4.服务器句柄得到消息并取得参数。

  5.执行远程过程。

  

  

  服务端函数返回结果给客户端 

  1.执行的过程将结果返回服务器句柄。

  2.服务器句柄返回结果,调用远程系统内核。

  3.消息传回本地主机。

  4.客户句柄由内核接收消息。

  5.客户接收句柄返回的数据。

  

 

  

Hessian的优、缺点

  

  优缺点在实践中根据使用和同事反馈情况而写的,只代表个人的一些观点。

  
  优点
  1.目前的WEB端基本上都支持hessian,hessian本身就是使用http的传输协议,来保证安全性和稳定性。

  2.通信速度不错。(数据少的时候)。

  3.可以以对象方式接受数据。

  

  缺点

  1.报错机制不够完善。

  2.没有事务处理。

  3.PHP和Java之间经常会出现一些问题,如编码,需强制转换字符等。(已经在源码包体现了

  4.返回数据量大,总会感觉有延迟的情况。(返回数据加缓存机制可以避免)

 

附带源码解释

 1.引用配置文件,包括网站根目录,以及Hessian的地址。

 2.我本地配置的虚拟主机(域名qx.com),不会配置虚拟主机请参考我之前搭建环境文章。

<span style="color: #000000;">php
</span><span style="color: #008000;">/*</span><span style="color: #008000;">*
 * 文件名        : config.php
 * 创建人        : 吴佰清
 * 创建时间    : 2012-05-09 11:12
 * 用途        : Hessian配置文件
 *
 * @author wubaiqing <xinxiangmo>
 * @package system.core.code applied to the whole site
 * @copyright Copyright (c) 2012 
 * @since 1.0
 </xinxiangmo></span><span style="color: #008000;">*/</span>

<span style="color: #008000;">//</span><span style="color: #008000;"> 根目录</span>
<span style="color: #008080;">define</span>( 'PATH' , <span style="color: #008080;">dirname</span>(<span style="color: #ff00ff;">__FILE__</span>) .<span style="color: #000000;"> DIRECTORY_SEPARATOR );

</span><span style="color: #008000;">//</span><span style="color: #008000;"> Hessian Url地址</span>
<span style="color: #008080;">define</span>( 'HESSIAN_URL' , 'http://qx.com/server.php'<span style="color: #000000;"> );

</span><span style="color: #008000;">//</span><span style="color: #008000;"> IDE : Zend Studio 9.0
// IDE Extension : Toggle Vrapper</span>
?>

  3.下载HessianPHP.

  4.配置服务端。

<span style="color: #000000;">php
</span><span style="color: #008000;">/*</span><span style="color: #008000;">*
 * 文件名        : server.php
 * 创建人        : 吴佰清
 * 创建时间    : 2012-05-09 11:54
 *
 * 参考资料    :
 * 1.http://hessian.caucho.com/ ( Hessian主页 )
 * 2.http://hessianphp.sourceforge.net/ ( Hessian PHP )
 * 3.http://sourceforge.net/projects/hessianphp/ ( Hessian PHP开源 )
 * 4.http://baike.baidu.com/view/1859857.htm ( 单例模式 )
 *
 * @author wubaiqing <xinxiangmo>
 * @package system.core applied to the whole site
 * @copyright Copyright (c) 2012
 * @since 1.0
 </xinxiangmo></span><span style="color: #008000;">*/</span>
<span style="color: #0000ff;">require_once</span> ( <span style="color: #008080;">dirname</span>(<span style="color: #ff00ff;">__FILE__</span>) . DIRECTORY_SEPARATOR . 'config.php'<span style="color: #000000;"> );
</span><span style="color: #0000ff;">require_once</span> ( PATH . 'extensions/HessianPHP/HessianService.php'<span style="color: #000000;"> );

</span><span style="color: #0000ff;">class</span><span style="color: #000000;"> HessianServer
{
    </span><span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span><span style="color: #000000;"> __construct() {}
    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * 商品详细信息APi接口
     * @param string $title 标题
     * @param int $price 价格
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span> goodsInfomationApi( <span style="color: #800080;">$title</span> , <span style="color: #800080;">$price</span><span style="color: #000000;"> ) {
        </span><span style="color: #800080;">$price</span> = (int) <span style="color: #800080;">$price</span><span style="color: #000000;">;
        </span><span style="color: #0000ff;">return</span> '<h1 style="background-color:#036; color:#fff; font-size:16px; padding:10px 10px 10px 3px;">使用Hessian协议调用远程方法.</h1> 标题:' . <span style="color: #800080;">$title</span> . '<br>价格:'.<span style="color: #800080;">$price</span><span style="color: #000000;">;
    }
}

</span><span style="color: #800080;">$server</span> = <span style="color: #0000ff;">new</span> HessianService( <span style="color: #0000ff;">new</span><span style="color: #000000;"> HessianServer() );
</span><span style="color: #008000;">//</span><span style="color: #008000;">$server->displayInfo();</span>
<span style="color: #800080;">$server</span>-><span style="color: #000000;">handle();

</span><span style="color: #008000;">//</span><span style="color: #008000;"> IDE : Zend Studio 9.0
// IDE Extension : Toggle Vrapper</span>
?>


 5.可以通过HessianService类中的displayInfo方法去查看开启多少个通讯方法。

  如果搭建服务端要使用handle方法,如出现Hessian Requires POST提示,服务端就已经搭建成功。

 

 6.封装Hessian接口

<span style="color: #000000;">php
</span><span style="color: #008000;">/*</span><span style="color: #008000;">*
 * 类名        : HessianApi
 * 创建人        : 吴佰清
 * 创建时间    : 2012-05-08 18:00
 * 
 * 参考资料    : 
 * 1.http://hessian.caucho.com/ ( Hessian主页 )
 * 2.http://hessianphp.sourceforge.net/ ( Hessian PHP )
 * 3.http://sourceforge.net/projects/hessianphp/ ( Hessian PHP开源 )
 * 4.http://baike.baidu.com/view/1859857.htm ( 单例模式 )
 *
 * @author wubaiqing <xinxiangmo>
 * @package system.core applied to the whole site
 * @copyright Copyright (c) 2012
 * @since 1.0
 </xinxiangmo></span><span style="color: #008000;">*/</span>
<span style="color: #0000ff;">class</span><span style="color: #000000;"> HessianApi
{
    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * @var string 接口地址
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">private</span> <span style="color: #800080;">$_url</span> = <span style="color: #0000ff;">NULL</span><span style="color: #000000;">;
    
    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * @var result 句柄
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">private</span> <span style="color: #800080;">$_handle</span> = <span style="color: #0000ff;">NULL</span><span style="color: #000000;">;

    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * @var array 存放单例模式数组
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">private</span> <span style="color: #0000ff;">static</span> <span style="color: #800080;">$_objects</span> = <span style="color: #0000ff;">array</span><span style="color: #000000;">();

    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * 设置URL地址
     * 实例化HessianClient类
     * 参数    : (1) url地址 , 2
     * 
     * 2.Java调用字段
     * @param string $url
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span> __construct( <span style="color: #800080;">$url</span><span style="color: #000000;"> )
    {
        </span><span style="color: #800080;">$this</span>->setUrl( <span style="color: #800080;">$url</span><span style="color: #000000;"> );
        </span><span style="color: #800080;">$handler</span> = <span style="color: #0000ff;">new</span> HessianClient ( <span style="color: #800080;">$this</span>->getUrl (), <span style="color: #800080;">$this</span>-><span style="color: #000000;">getOptions () );
        </span><span style="color: #800080;">$this</span>->setHandler ( <span style="color: #800080;">$handler</span><span style="color: #000000;"> );
    }

    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * @return result $_handle 句柄
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span><span style="color: #000000;"> getHandler() {
        </span><span style="color: #0000ff;">return</span> <span style="color: #800080;">$this</span>-><span style="color: #000000;">_handle;
    }

    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * 设置句柄
     * @param result $_handle
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span> setHandler(<span style="color: #800080;">$_handle</span><span style="color: #000000;">) {
        </span><span style="color: #800080;">$this</span>->_handle = <span style="color: #800080;">$_handle</span><span style="color: #000000;">;
    }

    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * 获取URL地址
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span><span style="color: #000000;"> getUrl() {
        </span><span style="color: #0000ff;">return</span> <span style="color: #800080;">$this</span>-><span style="color: #000000;">_url;
    }

    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * 设置URL地址
     * @param string $url
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span> setUrl(<span style="color: #800080;">$url</span><span style="color: #000000;">) {
        </span><span style="color: #800080;">$this</span>->_url = <span style="color: #800080;">$url</span><span style="color: #000000;">;
    }

    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * typeMap映射Java等平台对象
     * @return array
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span><span style="color: #000000;"> getOptions() {
        </span><span style="color: #0000ff;">return</span> <span style="color: #0000ff;">array</span> (<br>      'version' => 1, <br>      'saveRaw' => <span style="color: #0000ff;">TRUE</span>, <br>      'typeMap' => <span style="color: #0000ff;">array</span>(<br>        'JavaNullPointException' => 'java.lang.NullPointerException' ,<br>        'StackTraceElement' => 'java.lang.StackTraceElement'<span style="color: #000000;">)<br>     );
    }

    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * 记录接口调用信息
     * @param string $method 调用的方法
     * @param string $returnMsg 需要记入log的文字信息
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span> resultLog( <span style="color: #800080;">$method</span> , <span style="color: #800080;">$returnMsg</span><span style="color: #000000;"> )
    {
        </span><span style="color: #800080;">$logPath</span> = PATH.'/runtime/hessian/'<span style="color: #000000;">;
        </span><span style="color: #0000ff;">if</span>( !<span style="color: #008080;">is_dir</span>( <span style="color: #800080;">$logPath</span><span style="color: #000000;"> ) ) {
            </span><span style="color: #008080;">mkdir</span>(<span style="color: #800080;">$logPath</span>,0777<span style="color: #000000;">);
        }
        </span><span style="color: #008080;">error_log</span>(<span style="color: #008080;">date</span>('Ymd H:i:s', <span style="color: #008080;">time</span>()) . '|' . <span style="color: #800080;">$method</span> . '|' . <span style="color: #800080;">$returnMsg</span>."\n", 3, <span style="color: #800080;">$logPath</span> . <span style="color: #008080;">date</span>('Y-m-d', <span style="color: #008080;">time</span>()) . '.log'<span style="color: #000000;">);
    }

    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * 静态工厂方法,生成单个URL的唯一实例
     * @param string $url
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">static</span> <span style="color: #0000ff;">function</span> start( <span style="color: #800080;">$url</span><span style="color: #000000;"> )
    {
        </span><span style="color: #800080;">$key</span> = <span style="color: #008080;">md5</span>( <span style="color: #800080;">$url</span><span style="color: #000000;"> );
        
        </span><span style="color: #0000ff;">if</span> ( <span style="color: #0000ff;">isset</span>(self::<span style="color: #800080;">$_objects</span>[<span style="color: #800080;">$key</span><span style="color: #000000;">]) ) {
            </span><span style="color: #0000ff;">return</span> self::<span style="color: #800080;">$_objects</span>[<span style="color: #800080;">$key</span><span style="color: #000000;">];
        }
        
        self</span>::<span style="color: #800080;">$_objects</span>[<span style="color: #800080;">$key</span>] = <span style="color: #0000ff;">new</span> HessianApi( <span style="color: #800080;">$url</span><span style="color: #000000;"> );
        </span><span style="color: #0000ff;">return</span> self::<span style="color: #800080;">$_objects</span>[<span style="color: #800080;">$key</span><span style="color: #000000;">];
    }
}

</span><span style="color: #0000ff;">class</span> JavaNullPointException <span style="color: #0000ff;">extends</span> <span style="color: #0000ff;">Exception</span><span style="color: #000000;"> {}

</span><span style="color: #0000ff;">class</span> StackTraceElement <span style="color: #0000ff;">extends</span> <span style="color: #0000ff;">Exception</span><span style="color: #000000;"> {}

</span><span style="color: #008000;">//</span><span style="color: #008000;"> IDE : Zend Studio 9.0
// IDE Extension : Toggle Vrapper</span>

?>

 7.封装客户端请求方法,继承HessianApi类

<span style="color: #000000;">php
</span><span style="color: #008000;">/*</span><span style="color: #008000;">*
 * 类名        : Goods
 * 继承类        : HessianApi
 * 创建人        : 吴佰清
 * 创建时间    : 2012-05-09 12:12
 * 用途        : 调用server.php方法
 *
 * @author wubaiqing <xinxiangmo>
 * @package system.core.code applied to the whole site
 * @copyright Copyright (c) 2012 
 * @since 1.0
 </xinxiangmo></span><span style="color: #008000;">*/</span>
<span style="color: #0000ff;">class</span> Goods <span style="color: #0000ff;">extends</span><span style="color: #000000;"> HessianApi
{
    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * 设置接口地址
     * @param string $url
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span> __construct( <span style="color: #800080;">$url</span><span style="color: #000000;"> ) {
        parent</span>::__construct( <span style="color: #800080;">$url</span><span style="color: #000000;"> );
    }

    </span><span style="color: #008000;">/*</span><span style="color: #008000;">*
     * 获取商品信息
     * 调用server.php文件中的goodsInfomationApi方法
     * @param string $title 标题
     * @param string $title 价格
     </span><span style="color: #008000;">*/</span>
    <span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span> getGoodsInfomation( <span style="color: #800080;">$title</span> , <span style="color: #800080;">$price</span><span style="color: #000000;"> )
    {
        </span><span style="color: #008000;">//</span><span style="color: #008000;"> 如果调用java平台的hessian服务 需要指定你传递参数的类型,特别是整形和字符串.</span>
        <span style="color: #800080;">$price</span> = (int) <span style="color: #800080;">$price</span><span style="color: #000000;">; 
        
        </span><span style="color: #800080;">$result</span> = <span style="color: #800080;">$this</span>->getHandler()->goodsInfomationApi( <span style="color: #800080;">$title</span> , <span style="color: #800080;">$price</span><span style="color: #000000;"> );
        </span><span style="color: #800080;">$this</span>->resultLog( 'getGoodsInfomation' , '访问接口,但接口没有进行逻辑验证.'<span style="color: #000000;">);
        </span><span style="color: #0000ff;">return</span> <span style="color: #800080;">$result</span><span style="color: #000000;">;
    }
}

</span><span style="color: #008000;">//</span><span style="color: #008000;"> IDE : Zend Studio 9.0
// IDE Extension : Toggle Vrapper</span>
?>

 8.修改index.php可以请求服务端接口

<span style="color: #000000;">php 
</span><span style="color: #008000;">/*</span><span style="color: #008000;">*
 * 文件名        : index.php
 * 创建人        : 吴佰清
 * 创建时间    : 2012-05-09 11:57
 *
 * 参考资料    :
 * 1.http://hessian.caucho.com/ ( Hessian主页 )
 * 2.http://hessianphp.sourceforge.net/ ( Hessian PHP )
 * 3.http://sourceforge.net/projects/hessianphp/ ( Hessian PHP开源 )
 * 4.http://baike.baidu.com/view/1859857.htm ( 单例模式 )
 *
 * @author wubaiqing <xinxiangmo>
 * @package system.core applied to the whole site
 * @copyright Copyright (c) 2012
 * @since 1.0
 </xinxiangmo></span><span style="color: #008000;">*/</span>


<span style="color: #0000ff;">require_once</span> ( <span style="color: #008080;">dirname</span>(<span style="color: #ff00ff;">__FILE__</span>) . DIRECTORY_SEPARATOR .'config.php'<span style="color: #000000;"> );

</span><span style="color: #008000;">//</span><span style="color: #008000;"> Hessian 扩展及配置文件</span>
<span style="color: #0000ff;">require_once</span> ( PATH . 'extensions/HessianPHP/HessianClient.php'<span style="color: #000000;"> );
</span><span style="color: #0000ff;">require_once</span> ( PATH . 'class/HessianApi.php'<span style="color: #000000;"> );


</span><span style="color: #008000;">//</span><span style="color: #008000;"> 调用 server.php 方法</span>
<span style="color: #0000ff;">require_once</span> ( PATH . 'class/Goods.php'<span style="color: #000000;">);

</span><span style="color: #008000;">//</span><span style="color: #008000;"> 请求接口获取数据</span>
<span style="color: #800080;">$goods</span> = <span style="color: #0000ff;">new</span><span style="color: #000000;"> Goods( HESSIAN_URL );

</span><span style="color: #008000;">//</span><span style="color: #008000;"> 设置商品标题 , 价格.</span>
<span style="color: #800080;">$title</span> = '北京移动充值平台'<span style="color: #000000;">;
</span><span style="color: #800080;">$price</span> = '50'<span style="color: #000000;">;

</span><span style="color: #008000;">//</span><span style="color: #008000;"> 请求Hessian协议</span>
<span style="color: #800080;">$goodsInfo</span> = <span style="color: #800080;">$goods</span>->getGoodsInfomation( (<span style="color: #0000ff;">string</span>) <span style="color: #800080;">$title</span> , (int) <span style="color: #800080;">$price</span><span style="color: #000000;"> );

</span><span style="color: #008000;">//</span><span style="color: #008000;"> 打印请求结果</span>
<span style="color: #0000ff;">echo</span> ( <span style="color: #800080;">$goodsInfo</span><span style="color: #000000;"> );

</span><span style="color: #008000;">//</span><span style="color: #008000;"> IDE : Zend Studio 9.0
// IDE Extension : Toggle Vrapper</span>

?>

 

参考资料

  1.Hessian主页:http://hessian.caucho.com/Hessian

  2.PHP实现主页:http://hessianphp.sourceforge.net/

  3.HessianPHP开源项目主页:http://sourceforge.net/projects/hessianphp/

  4.RMI协议:http://baike.baidu.com/view/99017.htm

  5.维基百科:http://en.wikipedia.org/wiki/Hessian

  6.PHP源码:http://files.cnblogs.com/wubaiqing/Hessian.zip

 

声明:
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
上一篇:php性能优化下一篇:php生成UUID