探讨Hessian在PHP中的使用分析

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

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

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

附带源码解释

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

?>

(0)

相关推荐

  • 探讨Hessian在PHP中的使用分析

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

  • java 中ThreadLocal实例分析

    java  中ThreadLocal实例分析 从概念上理解,threadlocal使变量在多个线程中相互隔离实现线程安全,threadlocal包装的变量最终都专属于对应的每个线程,线程之间相互独立,用一个具体实现来说明: public interface Consumer { int consume(); } public class ComsumeThread implements Runnable { private Consumer consumer; public ComsumeThr

  • java 中ThreadPoolExecutor原理分析

    java 中ThreadPoolExecutor原理分析 线程池简介 Java线程池是开发中常用的工具,当我们有异步.并行的任务要处理时,经常会用到线程池,或者在实现一个服务器时,也需要使用线程池来接收连接处理请求. 线程池使用 JDK中提供的线程池实现位于java.util.concurrent.ThreadPoolExecutor.在使用时,通常使用ExecutorService接口,它提供了submit,invokeAll,shutdown等通用的方法. 在线程池配置方面,Executor

  • Android 开发中线程的分析

    Android 开发中线程的分析 今天早上把公司给的任务做完了之后,突然就有点无聊,于是,把以前学的那些东西翻了翻,博客看了看,就看到一个关于线程的博客,有了很大的争议,我也差点误解了(感觉高大上~~~).整体代码差不多是这样: package sw.angel.thread; import android.app.Activity; import android.os.Bundle; import android.os.Handler; import android.util.Log; pub

  • Python3爬虫中关于Ajax分析方法的总结

    这里还以前面的微博为例,我们知道拖动刷新的内容由Ajax加载,而且页面的URL没有变化,那么应该到哪里去查看这些Ajax请求呢? 1. 查看请求 这里还需要借助浏览器的开发者工具,下面以Chrome浏览器为例来介绍. 首先,用Chrome浏览器打开微博的链接https://m.weibo.cn/u/2830678474,随后在页面中点击鼠标右键,从弹出的快捷菜单中选择"检查"选项,此时便会弹出开发者工具,如图6-2所示: 此时在Elements选项卡中便会观察到网页的源代码,右侧便是节

  • Go语言中的逃逸分析究竟是什么?

    目录 1.逃逸分析介绍 2.Go中内存分配在哪里? 3.Go与C++内存分配的区别 4.逃逸分析骚操作 5.逃逸分析引申示例说明 1.逃逸分析介绍 学计算机的同学都知道,在编译原理中,分析指针动态范围的方法称之为逃逸分析.通俗来讲,当一个对象的指针被多个方法或线程引用时,我们称这个指针发生了"逃逸". Go语言的逃逸分析是编译器执行静态代码分析后,对内存管理进行的优化和简化,它可以决定一个变量是分配到堆还栈上. 写过C/C++的小伙伴应该知道,使用比较经典的malloc和new函数可以

  • ASP.NET Core在WebApi项目中使用MiniProfiler分析Entity Framework Core

    安装配置MiniProfiler 在现有的ASP.NET Core MVC WebApi 项目里,通过Nuget安装MiniProfiler: Install-Package MiniProfiler.AspNetCore.Mvc MiniProfiler.EntityFrameworkCore 当然也可以通过Nuget Package Manager可视化工具安装 接下来就是如何配置和使用 MiniProfiler 了,总共分三步: 第一步,来到Startup.cs的ConfigureServ

  • java  中ThreadLocal实例分析

    java  中ThreadLocal实例分析 从概念上理解,threadlocal使变量在多个线程中相互隔离实现线程安全,threadlocal包装的变量最终都专属于对应的每个线程,线程之间相互独立,用一个具体实现来说明: public interface Consumer { int consume(); } public class ComsumeThread implements Runnable { private Consumer consumer; public ComsumeThr

  • Python灰度变换中位图切割分析实现

    目录 1. 介绍 2. 实现方法 3. code 4. 比特平面重建图像 1. 介绍 图像的像素值是由比特组成的.例如一副256级灰度图像中,图像是由8 bit组成. 与之前对比度拉伸的区别是,之前我们主要强调在某一范围的灰度值作为我们能感兴趣的目标将其变亮或者变暗.而位图切割主要强调每个bit对图像的贡献,通过方法将不同位的灰度值值取出来还原成图像. 如图所示,一副8 bit图像,我们可以将图像分割成8个,将每个图像对应的比特位取出构建成一副新的图像 2. 实现方法 例如图像某一点的像素值为1

  • 简述Java编程语言中的逃逸分析

    大家一般认为new出来的对象都是被分配在堆上,但这并不是完全正确,通过对Java对象分配过程分析,我们发现对象除了可以被分配在堆上,还可以在栈或TLAB中分配空间.而栈上分配对象的技术基础是逃逸分析和标量替换,本文主要介绍下逃逸分析. 1.逃逸分析的定义 逃逸分析:是一种可以有效减少Java 程序中同步负载和内存堆分配压力的跨函数全局数据流分析算法. 通过逃逸分析,Java Hotspot编译器能够分析出一个新的对象的引用的使用范围从而决定是否要将这个对象分配到堆上. Java在Java SE

随机推荐