小试Hessian实现webservice

2024-01-04 16:38

本文主要是介绍小试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

相关文章

hdu1043(八数码问题,广搜 + hash(实现状态压缩) )

利用康拓展开将一个排列映射成一个自然数,然后就变成了普通的广搜题。 #include<iostream>#include<algorithm>#include<string>#include<stack>#include<queue>#include<map>#include<stdio.h>#include<stdlib.h>#include<ctype.h>#inclu

【C++】_list常用方法解析及模拟实现

相信自己的力量,只要对自己始终保持信心,尽自己最大努力去完成任何事,就算事情最终结果是失败了,努力了也不留遗憾。💓💓💓 目录   ✨说在前面 🍋知识点一:什么是list? •🌰1.list的定义 •🌰2.list的基本特性 •🌰3.常用接口介绍 🍋知识点二:list常用接口 •🌰1.默认成员函数 🔥构造函数(⭐) 🔥析构函数 •🌰2.list对象

【Prometheus】PromQL向量匹配实现不同标签的向量数据进行运算

✨✨ 欢迎大家来到景天科技苑✨✨ 🎈🎈 养成好习惯,先赞后看哦~🎈🎈 🏆 作者简介:景天科技苑 🏆《头衔》:大厂架构师,华为云开发者社区专家博主,阿里云开发者社区专家博主,CSDN全栈领域优质创作者,掘金优秀博主,51CTO博客专家等。 🏆《博客》:Python全栈,前后端开发,小程序开发,人工智能,js逆向,App逆向,网络系统安全,数据分析,Django,fastapi

让树莓派智能语音助手实现定时提醒功能

最初的时候是想直接在rasa 的chatbot上实现,因为rasa本身是带有remindschedule模块的。不过经过一番折腾后,忽然发现,chatbot上实现的定时,语音助手不一定会有响应。因为,我目前语音助手的代码设置了长时间无应答会结束对话,这样一来,chatbot定时提醒的触发就不会被语音助手获悉。那怎么让语音助手也具有定时提醒功能呢? 我最后选择的方法是用threading.Time

Android实现任意版本设置默认的锁屏壁纸和桌面壁纸(两张壁纸可不一致)

客户有些需求需要设置默认壁纸和锁屏壁纸  在默认情况下 这两个壁纸是相同的  如果需要默认的锁屏壁纸和桌面壁纸不一样 需要额外修改 Android13实现 替换默认桌面壁纸: 将图片文件替换frameworks/base/core/res/res/drawable-nodpi/default_wallpaper.*  (注意不能是bmp格式) 替换默认锁屏壁纸: 将图片资源放入vendo

C#实战|大乐透选号器[6]:实现实时显示已选择的红蓝球数量

哈喽,你好啊,我是雷工。 关于大乐透选号器在前面已经记录了5篇笔记,这是第6篇; 接下来实现实时显示当前选中红球数量,蓝球数量; 以下为练习笔记。 01 效果演示 当选择和取消选择红球或蓝球时,在对应的位置显示实时已选择的红球、蓝球的数量; 02 标签名称 分别设置Label标签名称为:lblRedCount、lblBlueCount

Kubernetes PodSecurityPolicy:PSP能实现的5种主要安全策略

Kubernetes PodSecurityPolicy:PSP能实现的5种主要安全策略 1. 特权模式限制2. 宿主机资源隔离3. 用户和组管理4. 权限提升控制5. SELinux配置 💖The Begin💖点点关注,收藏不迷路💖 Kubernetes的PodSecurityPolicy(PSP)是一个关键的安全特性,它在Pod创建之前实施安全策略,确保P

工厂ERP管理系统实现源码(JAVA)

工厂进销存管理系统是一个集采购管理、仓库管理、生产管理和销售管理于一体的综合解决方案。该系统旨在帮助企业优化流程、提高效率、降低成本,并实时掌握各环节的运营状况。 在采购管理方面,系统能够处理采购订单、供应商管理和采购入库等流程,确保采购过程的透明和高效。仓库管理方面,实现库存的精准管理,包括入库、出库、盘点等操作,确保库存数据的准确性和实时性。 生产管理模块则涵盖了生产计划制定、物料需求计划、

C++——stack、queue的实现及deque的介绍

目录 1.stack与queue的实现 1.1stack的实现  1.2 queue的实现 2.重温vector、list、stack、queue的介绍 2.1 STL标准库中stack和queue的底层结构  3.deque的简单介绍 3.1为什么选择deque作为stack和queue的底层默认容器  3.2 STL中对stack与queue的模拟实现 ①stack模拟实现

基于51单片机的自动转向修复系统的设计与实现

文章目录 前言资料获取设计介绍功能介绍设计清单具体实现截图参考文献设计获取 前言 💗博主介绍:✌全网粉丝10W+,CSDN特邀作者、博客专家、CSDN新星计划导师,一名热衷于单片机技术探索与分享的博主、专注于 精通51/STM32/MSP430/AVR等单片机设计 主要对象是咱们电子相关专业的大学生,希望您们都共创辉煌!✌💗 👇🏻 精彩专栏 推荐订阅👇🏻 单片机