【hessian】用hessian实现web 服务接口

红太狼 2022-07-17 00:17 190阅读 0赞

一、远程通讯协议的基本原理  
  
  
　　网络通信需要做的就是将流从一台计算机传输到另外一台计算机，基于传输协议和网络 IO 来实现，其中传输协议比较出名的有 http 、 tcp 、 udp 等等， http 、 tcp 、 udp 都是在基于 Socket 概念上为某类应用场景而扩展出的传输协议，网络 IO ，主要有 bio 、 nio 、 aio 三种方式，所有的分布式应用通讯都基于这个原理而实现，只是为了应用的易用，各种语言通常都会提供一些更为贴近应用易用的应用层协议。  
  
  
二、应用级协议Binary-RPC  
  
  
　　Binary-RPC(Remote Procedure Call Protocol，远程过程调用协议)是一种和RMI(Remote Method Invocation，远程方法调用)类似的远程调用的协议，它和RMI 的不同之处在于它以标准的二进制格式来定义请求的信息 ( 请求的对象、方法、参数等 ) ，这样的好处是什么呢，就是在跨语言通讯的时候也可以使用。  
  
  
　　Binary -RPC 协议的一次远程通信过程：  
  
  
　　1 、客户端发起请求，按照 Binary -RPC 协议将请求信息进行填充；  
  
  
　　2 、填充完毕后将二进制格式文件转化为流，通过传输协议进行传输；  
  
  
　　3 、接收到在接收到流后转换为二进制格式文件，按照 Binary -RPC 协议获取请求的信息并进行处理；  
  
  
　　4 、处理完毕后将结果按照 Binary -RPC 协议写入二进制格式文件中并返回。  
  
  
问题总结：  
  
  
　　1 、传输的标准格式是：标准格式的二进制文件。  
  
  
　　2 、怎么样将请求转化为传输的流？将二进制格式文件转化为流。  
  
  
　　3 、怎么接收和处理流？通过监听的端口获取到请求的流，转化为二进制文件，根据协议获取请求的信息，进行处理并将结果写入 XML 中返回。  
  
  
　　4 、传输协议是？http  
  
  
三、Hessian介绍  
  
  
Hessian是一个轻量级的remoting on http工具,采用的是Binary RPC协议，所以它很适合于发送二进制数据,同时又具有防火墙穿透能力。Hessian一般是通过Web应用来提供服务，因此非常类似于平时我们用的 WebService。只是它不使用SOAP协议,但相比webservice而言更简单、快捷。  
  
  
Hessian官网：http://hessian.caucho.com/  
  
  
Hessian 可通过Servlet提供远程服务，需要将匹配某个模式的请求映射到Hessian服务。也可Spring框架整合，通过它的 DispatcherServlet可以完成该功能，DispatcherServlet可将匹配模式的请求转发到Hessian服务。Hessian的server端提供一个servlet基类, 用来处理发送的请求，而Hessian的这个远程过程调用，完全使用动态代理来实现的,，建议采用面向接口编程，Hessian服务通过接口暴露。

Hessian处理过程示意图：客户端——>序列化写到输出流——>远程方法(服务器端)——>序列化写到输出流 ——>客户端读取输入流——>输出结果

四、Hessian实例

hessian应用分为两个部分：一部分是hessian的服务端，提供服务；一部分是客户端，使用hessian服务。下面具体讲解hessian的使用：

（一） Hessian服务端创建

本实例通过eclipse创建maven web项目，项目结构如下：

![Center][]

首先创建HessianService接口，这个接口最终要导出成jar包，供客户端调用。具体代码如下：

package hessian;
    
    public interface HessianService {
    	
    	public String getNewMessage(String msg);
    
    }

接下来创建实现类HessianServiceImpl来实现HessianService接口接口。具体代码如下：

package hessian.impl;
    
    import hessian.HessianService;
    
    public class HessianServiceImpl implements HessianService {
    
    	public String getNewMessage(String msg) {
    		return "HESSIAN --> " + msg;
    	}
    
    }

在pom.xml中添加hessian依赖，我用的jar包版本是4.0.7

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
      <modelVersion>4.0.0</modelVersion>
      <groupId>hessian</groupId>
      <artifactId>hessian</artifactId>
      <packaging>war</packaging>
      <version>0.0.1-SNAPSHOT</version>
      <name>hessian Maven Webapp</name>
      <url>http://maven.apache.org</url>
      <dependencies>
        <dependency>
          <groupId>junit</groupId>
          <artifactId>junit</artifactId>
          <version>3.8.1</version>
          <scope>test</scope>
        </dependency>
        
       
        <dependency>
    	  <groupId>com.caucho</groupId>
    	  <artifactId>hessian</artifactId>
    	  <version>4.0.7</version>
        </dependency>
        
        
        
        
      </dependencies>
      <build>
        <finalName>hessian</finalName>
      </build>
    </project>

最后是配置web.xml

<?xml version="1.0" encoding="UTF-8"?>
    <web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
        http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
        <welcome-file-list>
            <welcome-file>index.jsp</welcome-file>
        </welcome-file-list>
    
        <servlet>
            
            <servlet-name>ServiceServlet</servlet-name>
            <servlet-class>com.caucho.hessian.server.HessianServlet</servlet-class>
            
            
            <init-param>
                <param-name>home-api</param-name>
                <param-value>hessian.HessianService</param-value>
            </init-param>
            
            <init-param>
                <param-name>home-class</param-name>
                <param-value>hessian.impl.HessianServiceImpl</param-value>
            </init-param>
    
        </servlet>
        
        <servlet-mapping>
            <servlet-name>ServiceServlet</servlet-name>
            <url-pattern>/hs</url-pattern>
        </servlet-mapping>
    
    </web-app>

至此整个 hessian服务已创建完成。

将该web项目加入到tomcat，运行tomcat，在浏览器中输入地址：http://localhost:8090/hessian/hs，出现如下页面表示hessian服务创建成功：

![Center 1][]

==========================================

**在创建hessian服务遇到的异常，如下：**

javax.servlet.ServletException: server must extend HessianServlet
    	at com.caucho.hessian.server.HessianServlet.init(HessianServlet.java:225)
    	at org.apache.catalina.core.StandardWrapper.initServlet(StandardWrapper.java:1282)
    	at org.apache.catalina.core.StandardWrapper.loadServlet(StandardWrapper.java:1195)
    	at org.apache.catalina.core.StandardWrapper.allocate(StandardWrapper.java:866)
    	at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:134)
    	at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:122)
    	at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:505)
    	at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:169)
    	at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:103)
    	at org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:956)
    	at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:116)
    	at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:436)
    	at org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:1078)
    	at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:625)
    	at org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:316)
    	at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
    	at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
    	at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
    	at java.lang.Thread.run(Unknown Source)

出现这种异常的原因是在web.xml配置初始化参数init-param时，参数名称param-name配置的不对，这个名称是固定写法（在上面配置web.xml中已说明）。这个参数param-name会被HessianServlet在初始化时调用，如果名称不存在的话，就会抛此异常，获取web.xml中的参数是通过getInitParameter方法获取的。具体的我们看下HessianServlet的源代码，用红色标出的是异常抛出的地方：

public void init(ServletConfig config)
        throws ServletException
      {
        super.init(config);
        
        try {
          if (_homeImpl != null) {
          }
          else if (getInitParameter("home-class") != null) {
            String className = getInitParameter("home-class");
    
            Class<?> homeClass = loadClass(className);
    
            _homeImpl = homeClass.newInstance();
    
            init(_homeImpl);
          }
          else if (getInitParameter("service-class") != null) {
            String className = getInitParameter("service-class");
    
            Class<?> homeClass = loadClass(className);
    
            _homeImpl = homeClass.newInstance();
    
            init(_homeImpl);
          }
          else {

//原来你在这里啊!!!!!!!!!!!!!!!!!!!!!!!!!

if (getClass().equals(HessianServlet.class))
           throw new ServletException("server must extend HessianServlet");
    
            _homeImpl = this;
          }
    
          if (_homeAPI != null) {
          }
          else if (getInitParameter("home-api") != null) {
            String className = getInitParameter("home-api");
    
            _homeAPI = loadClass(className);
          }
          else if (getInitParameter("api-class") != null) {
            String className = getInitParameter("api-class");
    
            _homeAPI = loadClass(className);
          }
          else if (_homeImpl != null) {
            _homeAPI = findRemoteAPI(_homeImpl.getClass());
    
            if (_homeAPI == null)
              _homeAPI = _homeImpl.getClass();
            
            _homeAPI = _homeImpl.getClass();
          }
          
          if (_objectImpl != null) {
          }
          else if (getInitParameter("object-class") != null) {
            String className = getInitParameter("object-class");
    
            Class<?> objectClass = loadClass(className);
    
            _objectImpl = objectClass.newInstance();
    
            init(_objectImpl);
          }
    
          if (_objectAPI != null) {
          }
          else if (getInitParameter("object-api") != null) {
            String className = getInitParameter("object-api");
    
            _objectAPI = loadClass(className);
          }
          else if (_objectImpl != null)
            _objectAPI = _objectImpl.getClass();
    
          _homeSkeleton = new HessianSkeleton(_homeImpl, _homeAPI);
          
          if (_objectAPI != null)
            _homeSkeleton.setObjectClass(_objectAPI);
    
          if (_objectImpl != null) {
            _objectSkeleton = new HessianSkeleton(_objectImpl, _objectAPI);
            _objectSkeleton.setHomeClass(_homeAPI);
          }
          else
            _objectSkeleton = _homeSkeleton;
    
          if ("true".equals(getInitParameter("debug"))) {
          }
    
          if ("false".equals(getInitParameter("send-collection-type")))
            setSendCollectionType(false);
        } catch (ServletException e) {
          throw e;
        } catch (Exception e) {
          throw new ServletException(e);
        }
      }

还有一步是将上面的hessian服务接口导出成jar包，以供客户端使用，jar包中只要包含接口HessianService就可以了，不要实现类。hessian-service.jar包结构如下：

![Center 2][]

（二） Hessian客户端创建

用eclipse创建一个java项目，引入jar：hessian-service.jar、hessian-4.0.7.jar。调用之前启动第一服务，启动tomcat运行项目，调用代码如下：

package gzy.hessian.client;
    
    import java.net.MalformedURLException;
    
    import com.caucho.hessian.client.HessianProxyFactory;
    
    import hessian.HessianService;
    
    public class HessianTest {
    
    	public static void main(String[] args) {
    		String url = "http://localhost:8090/hessian/hs";
    		HessianProxyFactory factory = new HessianProxyFactory();
    			
    		try {
    			HessianService hs = (HessianService)factory.create(HessianService.class, url);
    			String result = hs.getNewMessage("hello, successfully");
    			System.out.println(result);
    			
    		} catch (MalformedURLException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    	}
    
    }

运行结果如下：

HESSIAN --> hello, successfully

[Center]: /images/20220717/da081bbc332e4dbd82fb67ad5e09c625.png
[Center 1]: /images/20220717/3d93d97be6e24265b161249c4759fe6b.png
[Center 2]: /images/20220717/2e251e1c6830458991ae42ccf79f4f4c.png