分布式系统开发工具包 —— 基于Hessian的HTTP RPC调用技术

浠ラ箍发布于2019-08-15 14:47 / 3038人阅读

摘要：官网是二进制协议。处理大量数据分布式应用需要发送大量二进制数据时，使用会更加有效率，因为它避免了分配大量数组。方法参数中只有最后一个参数可能是，因为数据是在调用过程中读的。文件下载文件下载实现原文发布于

Hessian官网：http://hessian.caucho.com/

hessian是二进制web service协议。

Hessian介绍

创建Hessian服务包括四个步骤：

创建Java接口，用于提供公开服务

使用HessianProxyFactory创建客户端

创建服务实现类

在servlet引擎中配置服务

HelloWorld服务

public interface BasicAPI {
  public String hello();
}

服务实现

public class BasicService extends HessianServlet implements BasicAPI {
  private String _greeting = "Hello, world";

  public void setGreeting(String greeting)
  {
    _greeting = greeting;
  }

  public String hello()
  {
    return _greeting;
  }
}

客户端实现

String url = "http://hessian.caucho.com/test/test";

HessianProxyFactory factory = new HessianProxyFactory();
BasicAPI basic = (BasicAPI) factory.create(BasicAPI.class, url);

System.out.println("hello(): " + basic.hello());

部署标准web.xml


  
   hello
   com.caucho.hessian.server.HessianServlet
    
      home-class
      example.BasicService
    
    
      home-api
      example.Basic
    
  

  
    /hello
    hello

Hessian序列化

Hessian类可以用来做序列化与反序列化

序列化

Object obj = ...;

OutputStream os = new FileOutputStream("test.xml");
Hessian2Output out = new Hessian2Output(os);

out.writeObject(obj);
os.close();

反序列化

InputStream is = new FileInputStream("test.xml");
Hessian2Input in = new Hessian2Input(is);

Object obj = in.readObject(null);
is.close();

如果要序列化比基础类型或String类型更加复杂的java对象，务必确保对象实现了java.io.Serializable接口。

Hessian处理大量数据

分布式应用需要发送大量二进制数据时，使用InputStream会更加有效率，因为它避免了分配大量byte数组。方法
参数中只有最后一个参数可能是InputStream，因为数据是在调用过程中读的。

下面是一个上传文件的API的例子

package example;

public interface Upload {
  public void upload(String filename, InputStream data);
}

如果返回结果是InputStream，客户端必须在finally块中调用InputStream.close()方法，因为Hessian不会关闭
底层HTTP流，直到所有数据被读取并且input stream被关闭。

文件下载API：
package example;

public interface Download {
  public InputStream download(String filename, InputStream data);
}

文件下载实现：
InputStream is = fileProxy.download("test.xml");

try {
  ... // read data here
} finally {
  is.close();
}

原文发布于：http://www.yesdata.net/2018/03/11/hessian/

服务器托管私有云基于防火墙技术的网络安全加固系统分布式存储系统megastore的核心技术基于android系统开发分布式调用系统

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/68815.html

后端必备——数据通信知识(RPC、消息队列)一站式总结

摘要：具体可以参考消息队列之具体可以参考实战之快速入门十分钟入门阿里中间件团队博客是一个分布式的可分区的可复制的基于发布订阅的消息系统主要用于大数据领域当然在分布式系统中也有应用。目前市面上流行的消息队列就是阿里借鉴的原理用开发而得。我自己总结的Java学习的系统知识点以及面试问题，目前已经开源，会一直完善下去，欢迎建议和指导欢迎Star： https://github.com/Snail...

Kahn 2019-08-16 12:34 评论0 收藏0
分布式服务框架之远程通讯技术及原理分析

摘要：微软的虽然引入了事件机制，可以在队列收到消息时触发事件，通知订阅者。由微软作为主要贡献者的，则对以及做了进一层包装，并能够很好地实现这一模式。在分布式服务框架中，一个最基础的问题就是远程服务是怎么通讯的，在Java领域中有很多可实现远程通讯的技术，例如：RMI、MINA、ESB、Burlap、Hessian、SOAP、EJB和JMS等，这些名词之间到底是些什么关系呢，它们背后到底是基...

sorra 2019-06-24 18:08 评论0 收藏0
分布式服务框架之远程通讯技术及原理分析

摘要：微软的虽然引入了事件机制，可以在队列收到消息时触发事件，通知订阅者。由微软作为主要贡献者的，则对以及做了进一层包装，并能够很好地实现这一模式。在分布式服务框架中，一个最基础的问题就是远程服务是怎么通讯的，在Java领域中有很多可实现远程通讯的技术，例如：RMI、MINA、ESB、Burlap、Hessian、SOAP、EJB和JMS等，这些名词之间到底是些什么关系呢，它们背后到底是基...

0xE7A38A 2019-08-19 10:58 评论0 收藏0
Java 远程通讯技术及原理分析

摘要：对于与而言，则可以看做是消息传递技术的一种衍生或封装。在生产者通知消费者时，传递的往往是消息或事件，而非生产者自身。通过消息路由，我们可以配置路由规则指定消息传递的路径，以及指定具体的消费者消费对应的生产者。采用和来进行远程对象的通讯。消息模式归根结底，企业应用系统就是对数据的处理，而对于一个拥有多个子系统的企业应用系统而言，它的基础支撑无疑就是对消息的处理。与对象不同，消息本质上...

rozbo 2019-08-14 15:42 评论0 收藏0
PowerDotNet平台化软件架构设计与实现系列（04）：服务治理平台

摘要：的服务治理平台发源于早期的个人项目。客户端发现模式要求客户端负责查询注册中心，获取服务提供者的列表信息，使用负载均衡算法选择一个合适的服务提供者，发起接口调用请求。系统和系统之间，少不了数据的互联互通。随着微服务的流行，一个系统内的不同应用进行互联互通也是常态。 PowerDotNet的服务治理平台发源于早期的个人项目Power.Apix。这个项目借鉴了工作过的公司的服务治理方案，站在...

reclay 2021-11-22 12:08 评论0 收藏0