欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

探讨Hessian在PHP中的使用分析

程序员文章站 2022-06-29 17:18:46
什么是hessian  hessian是由caucho提供的一种开源的远程通讯协议。  采用二进制 rpc 协议,基于 http 传输,服务器端不用另开放防火墙端口。  协...

什么是hessian
  hessian是由caucho提供的一种开源的远程通讯协议。
  采用二进制 rpc 协议,基于 http 传输,服务器端不用另开放防火墙端口。
  协议的规范是公开的,可以用于任意语言。
  采用客户机/服务器模式。
  请求程序就是一个客户机,而服务提供程序就是一个服务器。
  客户机调用进程发送一个有进程参数的调用信息到服务进程,然后等待应答信息。
  在服务器端,进程保持睡眠状态直到调用信息的到达为止。
  当一个调用信息到达,服务器获得进程参数,计算结果,发送答复信息,然后等待下一个调用信息,最后,客户端调用进程接收答复信息,
  获得进程结果,然后调用执行继续进行。

hessian协议工作流程图
  客户端程序请求服务端函数 
  1.调用客户端句柄,执行传送参数。
  2.调用本地系统内核发送网络消息。
  3.消息传送到远程主机。
  4.服务器句柄得到消息并取得参数。
  5.执行远程过程。

探讨Hessian在PHP中的使用分析

服务端函数返回结果给客户端
  1.执行的过程将结果返回服务器句柄。
  2.服务器句柄返回结果,调用远程系统内核。
  3.消息传回本地主机。
  4.客户句柄由内核接收消息。
  5.客户接收句柄返回的数据。

探讨Hessian在PHP中的使用分析

附带源码解释

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

复制代码 代码如下:

<?php
/**
 * 文件名        : config.php
 * 用途        : hessian配置文件
 *
 * @package system.core.code applied to the whole site
 * @copyright copyright (c) 2012
 * @since 1.0
 */

// 根目录
define( 'path' , dirname(__file__) . directory_separator );

// hessian url地址
define( 'hessian_url' , 'http://qx.com/server.php' );

// ide : zend studio 9.0
// ide extension : toggle vrapper
?>


2.配置服务端。
复制代码 代码如下:

<?php
/**
 * 文件名        : server.php
 *
 * 参考资料    :
 * 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@gmail.com>
 * @package system.core applied to the whole site
 * @copyright copyright (c) 2012
 * @since 1.0
 */
require_once ( dirname(__file__) . directory_separator . 'config.php' );
require_once ( path . 'extensions/hessianphp/hessianservice.php' );

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

$server = new hessianservice( new hessianserver() );
//$server->displayinfo();
$server->handle();

// ide : zend studio 9.0
// ide extension : toggle vrapper
?>


3.可以通过hessianservice类中的displayinfo方法去查看开启多少个通讯方法。
如果搭建服务端要使用handle方法,如出现hessian requires post提示,服务端就已经搭建成功。

4.封装hessian接口

复制代码 代码如下:

<?php
/**
 * 类名        : hessianapi
 *
 * 参考资料    :
 * 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@gmail.com>
 * @package system.core applied to the whole site
 * @copyright copyright (c) 2012
 * @since 1.0
 */
class hessianapi
{
    /**
     * @var string 接口地址
     */
    private $_url = null;

    /**
     * @var result 句柄
     */
    private $_handle = null;

    /**
     * @var array 存放单例模式数组
     */
    private static $_objects = array();

    /**
     * 设置url地址
     * 实例化hessianclient类
     * 参数    : (1) url地址 , 2
     *
     * 2.java调用字段
     * @param string $url
     */
    public function __construct( $url )
    {
        $this->seturl( $url );
        $handler = new hessianclient ( $this->geturl (), $this->getoptions () );
        $this->sethandler ( $handler );
    }

    /**
     * @return result $_handle 句柄
     */
    public function gethandler() {
        return $this->_handle;
    }

    /**
     * 设置句柄
     * @param result $_handle
     */
    public function sethandler($_handle) {
        $this->_handle = $_handle;
    }

    /**
     * 获取url地址
     */
    public function geturl() {
        return $this->_url;
    }

    /**
     * 设置url地址
     * @param string $url
     */
    public function seturl($url) {
        $this->_url = $url;
    }

    /**
     * typemap映射java等平台对象
     * @return array
     */
    public function getoptions() {
        return array (
      'version' => 1,
      'saveraw' => true,
      'typemap' => array(
        'javanullpointexception' => 'java.lang.nullpointerexception' ,
        'stacktraceelement' => 'java.lang.stacktraceelement')
     );
    }

    /**
     * 记录接口调用信息
     * @param string $method 调用的方法
     * @param string $returnmsg 需要记入log的文字信息
     */
    public function resultlog( $method , $returnmsg )
    {
        $logpath = path.'/runtime/hessian/';
        if( !is_dir( $logpath ) ) {
            mkdir($logpath,0777);
        }
        error_log(date('ymd h:i:s', time()) . '|' . $method . '|' . $returnmsg."\n", 3, $logpath . date('y-m-d', time()) . '.log');
    }

    /**
     * 静态工厂方法,生成单个url的唯一实例
     * @param string $url
     */
    public static function start( $url )
    {
        $key = md5( $url );

        if ( isset(self::$_objects[$key]) ) {
            return self::$_objects[$key];
        }

        self::$_objects[$key] = new hessianapi( $url );
        return self::$_objects[$key];
    }
}

class javanullpointexception extends exception {}

class stacktraceelement extends exception {}

// ide : zend studio 9.0
// ide extension : toggle vrapper

?>


5.封装客户端请求方法,继承hessianapi类
复制代码 代码如下:

<?php
/**
 * 类名        : goods
 * 继承类        : hessianapi
 * 用途        : 调用server.php方法
 *
 * @author wubaiqing <xinxiangmo@gmail.com>
 * @package system.core.code applied to the whole site
 * @copyright copyright (c) 2012
 * @since 1.0
 */
class goods extends hessianapi
{
    /**
     * 设置接口地址
     * @param string $url
     */
    public function __construct( $url ) {
        parent::__construct( $url );
    }

    /**
     * 获取商品信息
     * 调用server.php文件中的goodsinfomationapi方法
     * @param string $title 标题
     * @param string $title 价格
     */
    public function getgoodsinfomation( $title , $price )
    {
        // 如果调用java平台的hessian服务 需要指定你传递参数的类型,特别是整形和字符串.
        $price = (int) $price;

        $result = $this->gethandler()->goodsinfomationapi( $title , $price );
        $this->resultlog( 'getgoodsinfomation' , '访问接口,但接口没有进行逻辑验证.');
        return $result;
    }
}

// ide : zend studio 9.0
// ide extension : toggle vrapper
?>


6.修改index.php可以请求服务端接口
复制代码 代码如下:

<?php
/**
* 文件名 : index.php
*
* 参考资料 :
* 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@gmail.com>
* @package system.core applied to the whole site
* @copyright copyright (c) 2012
* @since 1.0
*/


require_once ( dirname(__file__) . directory_separator .'config.php' );

// hessian 扩展及配置文件
require_once ( path . 'extensions/hessianphp/hessianclient.php' );
require_once ( path . 'class/hessianapi.php' );


// 调用 server.php 方法
require_once ( path . 'class/goods.php');

// 请求接口获取数据
$goods = new goods( hessian_url );

// 设置商品标题 , 价格.
$title = '北京移动充值平台';
$price = '50';

// 请求hessian协议
$goodsinfo = $goods->getgoodsinfomation( (string) $title , (int) $price );

// 打印请求结果
echo ( $goodsinfo );

// ide : zend studio 9.0
// ide extension : toggle vrapper

?>