Spring+Hibernate整合Hessian

软件环境&＃xff1a; JDK1.6、Spring3.0.5、Hibernate3.2.2、Hessian3.1.5

参考Spring Documents&＃xff1a;中文|英文

服务端&＃xff1a;

###1. remoting-servlet.xml

###2. LazyHibernateSerializerFactory实现
参考: https://github.com/resthub/spring-amqp-hessian/issues/5

引用: http://code.google.com/p/rich-hibernate-lazy/wiki/HessianWithLazyHibernate

import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Set;import org.hibernate.Hibernate;
import org.hibernate.collection.PersistentList;
import org.hibernate.collection.PersistentMap;
import org.hibernate.collection.PersistentSet;import com.caucho.hessian.io.AbstractHessianOutput;
import com.caucho.hessian.io.CollectionSerializer;
import com.caucho.hessian.io.HessianProtocolException;
import com.caucho.hessian.io.JavaSerializer;
import com.caucho.hessian.io.MapSerializer;
import com.caucho.hessian.io.Serializer;
import com.caucho.hessian.io.SerializerFactory;/*** 处理&＃xff1a;Hessian远程调用时&＃xff0c;对象序列化hibernate实体bean中集合对象延迟加载问题 &＃xff0c;* 采取将集合对象替换为空集合。* **/
public class LazyHibernateSerializerFactory extends SerializerFactory {public static String versionString &＃61; org.hibernate.Version.getVersionString();&＃64;Overridepublic Serializer getSerializer(Class cls) throws HessianProtocolException {try {if(versionString.startsWith("3") &&Class.forName("org.hibernate.collection.PersistentCollection").isAssignableFrom(cls)){return new LazySerializerForHibernate3(cls); }else if(versionString.startsWith("4") && Class.forName("org.hibernate.collection.spi.PersistentCollection").isAssignableFrom(cls)){return new LazySerializerForHibernate4(cls); }} catch (ClassNotFoundException e) {e.printStackTrace();}return super.getSerializer(cls);}
}class LazySerializerForHibernate3 extends JavaSerializer {public LazySerializerForHibernate3(Class cls) {super(cls);}CollectionSerializer collectionSeiralizer &＃61; new CollectionSerializer();MapSerializer mapSerializer &＃61; new MapSerializer();/*** &＃64;Title: writeObject* &＃64;Description: TODO(override hessian write)* &＃64;param &＃64;param object* &＃64;param &＃64;param out* &＃64;param &＃64;throws IOException* &＃64;return void* &＃64;throws*/&＃64;SuppressWarnings("unchecked")&＃64;Overridepublic void writeObject(Object object, AbstractHessianOutput out)throws IOException {boolean ifHaveInit &＃61; Hibernate.isInitialized(object);Object obj &＃61; convertPersistent(object);if (ifHaveInit && object!&＃61;null) {out.writeObject(obj); out.flush();return;}if (PersistentMap.class.isAssignableFrom(object.getClass())) {mapSerializer.writeObject(new HashMap(), out);} else {collectionSeiralizer.writeObject(new ArrayList(), out);}}&＃64;SuppressWarnings("unchecked")public static List convertListFromPersistentList(PersistentList plist) {List list &＃61; new ArrayList();if (plist !&＃61; null) {for (int i &＃61; 0; i }class LazySerializerForHibernate4 extends JavaSerializer {public LazySerializerForHibernate4(Class cls) {super(cls);}CollectionSerializer collectionSeiralizer &＃61; new CollectionSerializer();MapSerializer mapSerializer &＃61; new MapSerializer();/*** &＃64;Title: writeObject* &＃64;Description: TODO(override hessian write)* &＃64;param &＃64;param object* &＃64;param &＃64;param out* &＃64;param &＃64;throws IOException* &＃64;return void* &＃64;throws*/&＃64;SuppressWarnings("unchecked")&＃64;Overridepublic void writeObject(Object object, AbstractHessianOutput out)throws IOException {boolean ifHaveInit &＃61; Hibernate.isInitialized(object);if (ifHaveInit) {out.writeObject(object);out.flush();return;}try {if (Class.forName("org.hibernate.collection.internal.PersistentMap").isAssignableFrom(object.getClass())) {mapSerializer.writeObject(new HashMap(), out);} else {collectionSeiralizer.writeObject(new ArrayList(), out);}} catch (ClassNotFoundException e) {// TODO Auto-generated catch blocke.printStackTrace();}}
}


###3. web.xml 中添加

osivFilterorg.springframework.orm.hibernate3.support.OpenSessionInViewFilter

osivFilter/remoting/*

hessianorg.springframework.web.servlet.DispatcherServletcontextConfigLocation/WEB-INF/config/application-context.xml,/WEB-INF/config/remoting-servlet.xml

hessian/remoting/*



客户端&＃xff1a;

###1. HessianClient.java


import com.caucho.hessian.client.HessianProxyFactory;
import service.UnifiedUserMng;public class HessianClient {public static void main(String[] args) throws Exception {// 远程调用地址String url &＃61; "http://localhost:8080/remoting/UnifiedUserService";// 默认写法HessianProxyFactory factory &＃61; new HessianProxyFactory(); // 实例化UnifiedUserService base &＃61; (UnifiedUserService) factory.create(UnifiedUserMng.class, url);// 调用接口&＃xff0c;并打印结果System.out.println(base.getByUsername("admin").getEmail());}
}


总结

Hibernate抛出no session or session closed原因&＃xff1a;Hessian调用服务器服务&＃xff0c;序列化Hibernate持久化对象中集合对象(Set)时&＃xff0c;session已经关闭。参考