小试Hessian实现webservice

2024-01-04 16:38
文章标签 实现 webservice hessian 小试

本文主要是介绍小试Hessian实现webservice，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

[color=red]blog迁移至[/color]:[url=http://www.micmiu.com]http://www.micmiu.com[/url]

[size=large]Hessian[/size]是一个轻量级的remoting on http工具,采用的是Binary RPC协议，所以它很适合于发送二进制数据,同时又具有防火墙穿透能力。Hessian一般是通过Web应用来提供服务，因此非常类似于平时我们用的WebService。只是它不使用SOAP协议,但相比webservice而言更简单、快捷。

[size=medium]Hessian官网：[url=http://hessian.caucho.com/]http://hessian.caucho.com/[/url][/size]

Hessian可通过Servlet提供远程服务，需要将匹配某个模式的请求映射到Hessian服务。也可Spring框架整合，通过它的DispatcherServlet可以完成该功能，DispatcherServlet可将匹配模式的请求转发到Hessian服务。Hessian的server端提供一个servlet基类, 用来处理发送的请求，而Hessian的这个远程过程调用，完全使用动态代理来实现的,，建议采用面向接口编程，Hessian服务通过接口暴露。

[size=medium]Hessian处理过程示意图：[/size]
[color=red]客户端——>序列化写到输出流——>远程方法（服务器端）——>序列化写到输出流 ——>客户端读取输入流——>输出结果[/color]

[size=medium]下面详细介绍最常用的两种方式实现Hessian提供webservice：[/size]
[color=blue][list]
[*]纯Hessian实现
[*]配合Spring框架实现
[/list][/color]
在开始之前当然需要到官网上下载相关的lib包，放入项目的/WEB-INF/lib/下
[color=blue][size=large]【一】、纯Hessian实现步骤：[/size][/color]
[size=medium]1.基本代码[/size]
首先编写一个服务的接口类：HelloHessian.java 
package michael.hessian;
import java.util.List;
import java.util.Map;

/**
 * @author michael
 * 
 */
public interface HelloHessian {

    String sayHello();

    MyCar getMyCar();

    List<String> myLoveFruit();

    Map<String, String> myBabays();

}

一个java bean文件MyCar.java: 
package michael.hessian;

import java.io.Serializable;

/**
 * @author michael
 * 
 */
public class MyCar implements Serializable {

    /**
     * 
     */
    private static final long serialVersionUID = 4736905401908455439L;

    private String carName;

    private String carModel;

    /**
     * @return the carName
     */
    public String getCarName() {
        return carName;
    }

    /**
     * @return the carModel
     */
    public String getCarModel() {
        return carModel;
    }

    /**
     * @param pCarName the carName to set
     */
    public void setCarName(String pCarName) {
        carName = pCarName;
    }

    /**
     * @param pCarModel the carModel to set
     */
    public void setCarModel(String pCarModel) {
        carModel = pCarModel;
    }

    /**
     * @see java.lang.Object#toString()
     * @return
     */
    @Override
    public String toString() {
        return "my car name:[" + this.carName + "] model:[" + this.carModel
                + "].";
    }

}

服务端接口的实现类：HelloHessianImpl.java 
package michael.hessian.impl;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import michael.hessian.HelloHessian;
import michael.hessian.MyCar;

/**
 * @author michael
 * 
 */
public class HelloHessianImpl extends HessianServlet implements HelloHessian {

    public MyCar getMyCar() {
        MyCar car = new MyCar();
        car.setCarName("阿斯顿·马丁");
        car.setCarModel("One-77");
        return car;
    }

    public Map<String, String> myBabays() {
        Map<String, String> map = new HashMap<String, String>();
        map.put("son", "孙吴空");
        map.put("daughter", "孙小美");
        return map;
    }

    public List<String> myLoveFruit() {
        List<String> list = new ArrayList<String>();
        list.add("apple");
        list.add("kiwi");
        list.add("orange");
        return list;
    }

    public String sayHello() {
        return "welcom to Hessian";
    }

}

[size=medium]2.配置文件web.xml修改[/size]
在web.xml配置文件里增加如下信息： 

<servlet>
		<servlet-name>HelloHessian</servlet-name>
		<servlet-class>
			com.caucho.hessian.server.HessianServlet
		</servlet-class>
		<init-param>
			<param-name>home-class</param-name>
			<param-value>michael.hessian.impl.HelloHessianImpl</param-value>
		</init-param>
		<init-param>
			<param-name>home-api</param-name>
			<param-value>michael.hessian.HelloHessian</param-value>
		</init-param>
		<load-on-startup>1</load-on-startup>
	</servlet>
	<servlet-mapping>
		<servlet-name>HelloHessian</servlet-name>
		<url-pattern>/HessianService</url-pattern>
	</servlet-mapping>
	<servlet-mapping>

[size=medium]3.java客户端验证[/size] 
package michael.hessian.client;

import java.net.MalformedURLException;
import java.util.Map;

import michael.hessian.HelloHessian;
import michael.hessian.MyCar;

import com.caucho.hessian.client.HessianProxyFactory;

/**
 * @author michael
 *
 */
public class HessianClientTest {

    /**
     * @param args
     */
    public static void main(String[] args) {
        String url = "http://localhost:8082/J2EE_sjsky/HessianService";
        HessianProxyFactory factory = new HessianProxyFactory();
        try {
            HelloHessian hello = (HelloHessian) factory.create(
                    HelloHessian.class, url);
            System.out.println(hello.sayHello());

            MyCar car = hello.getMyCar();
            System.out.println(car.toString());

            for (Map.Entry<String, String> entry : hello.myBabays().entrySet()) {
                System.out.println(entry.getKey() + "   " + entry.getValue());
            }

            for (String str : hello.myLoveFruit()) {
                System.out.println(str);
            }

        } catch (MalformedURLException e) {
            e.printStackTrace();
        }

    }

}

运行结果如下： 
welcom to Hessian
my car name:[阿斯顿·马丁] model:[One-77].
daughter   孙小美
son   孙吴空
apple
kiwi
orange


[color=blue][size=large]【二】、spring+hessian 实现服务端：[/size][/color]
[size=medium]1.基本代码见上面的demo[/size]
[size=medium]2.修改配置文件[/size]
在web.xml，增加内容如下： 

<servlet>
		<servlet-name>springhessian</servlet-name>
		<servlet-class>
			org.springframework.web.servlet.DispatcherServlet
		</servlet-class>
		<!-- 
		<init-param>
			<param-name>contextConfigLocation</param-name>
			<param-value>/WEB-INF/springhessian-servlet.xml</param-value>
		</init-param>
		 -->
		<load-on-startup>1</load-on-startup>
	</servlet>

	<servlet-mapping>
		<servlet-name>springhessian</servlet-name>
		<url-pattern>/springhessian/*</url-pattern>
	</servlet-mapping>

在/WEB-INF/增加一个叫[color=red]servlet-name[/color]-servlet.xml配置文件。该文件的命名有一定的规则，红色[color=red]servlet-name[/color]需要和web.xml中的<servlet-name>springhessian</servlet-name>定义的名称相匹配，比如本例子应叫[color=red]springhessian-servlet.xml[/color],这样简单也不容易出错。
[color=blue]当然该文件也可以自己任意命名。如果是自定义的文件名称不符合上述默认的规则，需要在<servlet>中增加<init-param>相关属性，人为指定加载配置文件，否则会报错。[/color]
范例：springhessian-servlet.xml 

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
	<bean id="helloHessianImpl"
		class="michael.hessian.impl.HelloHessianImpl" />
	<!-- 使用HessianServiceExporter 将bean生成Hessian服务-->
	<bean name="/helloHessianService"
		class="org.springframework.remoting.caucho.HessianServiceExporter">
		<!-- 定义需要生成服务的实现类-->
		<property name="service" ref="helloHessianImpl" />
		<!-- Hessian 提供服务的接口-->
		<property name="serviceInterface"
			value="michael.hessian.HelloHessian" />
	</bean>
</beans>


[size=medium]3.java客户端验证[/size]
和上面的例子相似，只需要把访问的url替换成新的即可如下： 
String url=http://localhost:8082/J2EE_sjsky/springhessian/helloHessianService

运行结果和上面例子一样。

[size=medium]4.spring配置客户端[/size]
增加一个spring的bean配置文件hessian-client.xml 
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
	<bean id="helloHessianClient"
		class="org.springframework.remoting.caucho.HessianProxyFactoryBean">
		<property name="serviceUrl">
			<value>
				http://localhost:8082/J2EE_sjsky/springhessian/helloHessianService
			</value>
		</property>
		<property name="serviceInterface"
			value="michael.hessian.HelloHessian" />
	</bean>
</beans>


测试代码HessianSpringClient.java： 

package michael.hessian.client;

import java.util.Map;

import michael.hessian.HelloHessian;
import michael.hessian.MyCar;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * @author michael
 * 
 */
public class HessianSpringClient {

    /**
     * @param args
     */
    public static void main(String[] args) {
        try {
            ApplicationContext context = new ClassPathXmlApplicationContext(
                    "hessian-client.xml");

            HelloHessian hello = (HelloHessian) context
                    .getBean("helloHessianClient");

            System.out.println(hello.sayHello());

            MyCar car = hello.getMyCar();
            System.out.println(car.toString());

            for (Map.Entry<String, String> entry : hello.myBabays().entrySet()) {
                System.out.println(entry.getKey() + "   " + entry.getValue());
            }

            for (String str : hello.myLoveFruit()) {
                System.out.println(str);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

}

运行结果和上面完全一致。
[size=medium]5.com.caucho.hessian.io.HessianProtocolException: expected string at 0x6d异常处理[/size]
我在spring+hessian整合测试过程中，客户端调用时，发生了异常，而服务端错误内容如下： 
2011-4-25 16:14:44 org.apache.catalina.core.StandardWrapperValve invoke
严重: Servlet.service() for servlet remoting threw exception
com.caucho.hessian.io.HessianProtocolException: expected string at 0x6d
	at com.caucho.hessian.io.Hessian2Input.error(Hessian2Input.java:2882)
	at com.caucho.hessian.io.Hessian2Input.expect(Hessian2Input.java:2830)
	at com.caucho.hessian.io.Hessian2Input.readString(Hessian2Input.java:1362)
	at com.caucho.hessian.io.Hessian2Input.readMethod(Hessian2Input.java:272)
	at com.caucho.hessian.server.HessianSkeleton.invoke(HessianSkeleton.java:249)
	at com.caucho.hessian.server.HessianSkeleton.invoke(HessianSkeleton.java:221)
	at org.springframework.remoting.caucho.Hessian2SkeletonInvoker.invoke(Hessian2SkeletonInvoker.java:67)
	at org.springframework.remoting.caucho.HessianServiceExporter.handleRequest(HessianServiceExporter.java:147)
	at org.springframework.web.servlet.mvc.HttpRequestHandlerAdapter.handle(HttpRequestHandlerAdapter.java:49)
	at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:819)
	at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:754)
	at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:399)
	at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:364)
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:710)
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:803)
	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:290)
	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
	at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:230)
	at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:175)
	at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:128)
	at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:104)
	at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109)
	at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:261)
	at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:844)
	at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:581)
	at org.apache.tomcat.util.net.JIoEndpoint$Worker.run(JIoEndpoint.java:447)
	at java.lang.Thread.run(Thread.java:619)

经查资料发现原来是hessian和spring的版本不兼容引起的，重新下载hessian-3.1.6.jar导入项目，一切运行正常，测试完全通过。

-----------------------------------分 ------------------------------------隔 ------------------------------------线 --------------------------------------

这篇关于小试Hessian实现webservice的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/569945。

相关文章

Springboot处理跨域的实现方式(附Demo)

Springboot处理跨域的实现方式(附Demo)

《Springboot处理跨域的实现方式(附Demo)》：本文主要介绍Springboot处理跨域的实现方式(附Demo),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不... 目录Springboot处理跨域的方式1. 基本知识2. @CrossOrigin3. 全局跨域设置4.
阅读更多...
Spring Boot 3.4.3 基于 Spring WebFlux 实现 SSE 功能(代码示例)

Spring Boot 3.4.3 基于 Spring WebFlux 实现 SSE 功能(代码示例)

《SpringBoot3.4.3基于SpringWebFlux实现SSE功能(代码示例)》SpringBoot3.4.3结合SpringWebFlux实现SSE功能,为实时数据推送提供... 目录1. SSE 简介1.1 什么是 SSE？1.2 SSE 的优点1.3 适用场景2. Spring WebFlu
阅读更多...
基于SpringBoot实现文件秒传功能

基于SpringBoot实现文件秒传功能

《基于SpringBoot实现文件秒传功能》在开发Web应用时,文件上传是一个常见需求,然而,当用户需要上传大文件或相同文件多次时,会造成带宽浪费和服务器存储冗余,此时可以使用文件秒传技术通过识别重复... 目录前言文件秒传原理代码实现1. 创建项目基础结构2. 创建上传存储代码3. 创建Result类4.
阅读更多...
SpringBoot日志配置SLF4J和Logback的方法实现

SpringBoot日志配置SLF4J和Logback的方法实现

《SpringBoot日志配置SLF4J和Logback的方法实现》日志记录是不可或缺的一部分,本文主要介绍了SpringBoot日志配置SLF4J和Logback的方法实现,文中通过示例代码介绍的非... 目录一、前言二、案例一：初识日志三、案例二：使用Lombok输出日志四、案例三：配置Logback一
阅读更多...
Python如何使用__slots__实现节省内存和性能优化

Python如何使用__slots__实现节省内存和性能优化

《Python如何使用__slots__实现节省内存和性能优化》你有想过,一个小小的__slots__能让你的Python类内存消耗直接减半吗,没错,今天咱们要聊的就是这个让人眼前一亮的技巧,感兴趣的... 目录背景：内存吃得满满的类__slots__：你的内存管理小助手举个大概的例子：看看效果如何？1.
阅读更多...
Python+PyQt5实现多屏幕协同播放功能

Python+PyQt5实现多屏幕协同播放功能

《Python+PyQt5实现多屏幕协同播放功能》在现代会议展示、数字广告、展览展示等场景中,多屏幕协同播放已成为刚需,下面我们就来看看如何利用Python和PyQt5开发一套功能强大的跨屏播控系统吧... 目录一、项目概述：突破传统播放限制二、核心技术解析2.1 多屏管理机制2.2 播放引擎设计2.3 专
阅读更多...
Python实现无痛修改第三方库源码的方法详解

Python实现无痛修改第三方库源码的方法详解

《Python实现无痛修改第三方库源码的方法详解》很多时候,我们下载的第三方库是不会有需求不满足的情况,但也有极少的情况,第三方库没有兼顾到需求,本文将介绍几个修改源码的操作,大家可以根据需求进行选择... 目录需求不符合模拟示例 1. 修改源文件2. 继承修改3. 猴子补丁4. 追踪局部变量需求不符合很
阅读更多...
idea中创建新类时自动添加注释的实现

idea中创建新类时自动添加注释的实现

《idea中创建新类时自动添加注释的实现》在每次使用idea创建一个新类时,过了一段时间发现看不懂这个类是用来干嘛的,为了解决这个问题,我们可以设置在创建一个新类时自动添加注释,帮助我们理解这个类的用... 目录前言：详细操作：步骤一：点击上方的 文件（File），点击&nbmyHIgsp;设置（Setti
阅读更多...
SpringBoot实现MD5加盐算法的示例代码

SpringBoot实现MD5加盐算法的示例代码

《SpringBoot实现MD5加盐算法的示例代码》加盐算法是一种用于增强密码安全性的技术,本文主要介绍了SpringBoot实现MD5加盐算法的示例代码,文中通过示例代码介绍的非常详细,对大家的学习... 目录一、什么是加盐算法二、如何实现加盐算法2.1 加盐算法代码实现2.2 注册页面中进行密码加盐2.
阅读更多...
MySQL大表数据的分区与分库分表的实现

MySQL大表数据的分区与分库分表的实现

《MySQL大表数据的分区与分库分表的实现》数据库的分区和分库分表是两种常用的技术方案,本文主要介绍了MySQL大表数据的分区与分库分表的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有... 目录1. mysql大表数据的分区1.1 什么是分区？1.2 分区的类型1.3 分区的优点1.4 分
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2