[转]OpenSessionInView模式

OpenSessionInView模式解决的问题：
  * hibernate事物边界问题
  * 因session关闭导致hibernate延迟加载例外的问题

事物边界：
    一个事物的完成应该是在业务层完成的，但是事物的创建却是在数据层来做，这样必定造成业务层和数据层耦合性增强。

延迟加载例外：
     如你所知，延迟加载使用了动态代理机制，只有在真正使用这个对象的时候才会去访问数据库，但是如果在数据层进行了事物提交，session关闭，再去访问 数据就会导致延迟加载例外异常，所以我们必须加大session的生命周期，在访问数据之后关闭session。

因此我们可以通过OpenSessionInView模式来解决上面的问题


OpenSessionInView模式需要用到一个非常重要的一个类：ThreadLocal

OpenSessionInView模式：
  * 需要构建一个过滤器，把事物的创建及提交放在过滤器里进行。
  * 加大session的有效范围，把session放在当前线程里（ThreadLocal），使session在当前线程内有效，并且在当前线程内访问的是同一个session。

OpenSessionInView模式缺点：
  *并发性减弱
  *内存消耗加大

1.实体类：

package com.yx.zzg.pojo;

import java.util.Date;

public class User {

    private String id;

    private String username;

    private String password;

    private Date createTime;

    private Date endTime;

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public Date getCreateTime() {
        return createTime;
    }

    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }

    public Date getEndTime() {
        return endTime;
    }

    public void setEndTime(Date endTime) {
        this.endTime = endTime;
    }
}

2.映射文件：

<?xml version="1.0"?>
<!DOCTYPE hibernate-mapping PUBLIC
    "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
    "http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd">
<hibernate-mapping package="com.yx.zzg.pojo">
    <class name="User" table="t_user">
        <id name="id">
            <!-- 指定主键生成策略 -->
            <generator class="uuid" />
        </id>
        <property name="username" unique-key="true" />
        <property name="password" />
        <property name="createTime" />
        <property name="endTime" />
    </class>

</hibernate-mapping>

3.提供一个过滤器：

package com.yx.zzg.servelt;

import java.io.IOException;

import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;

import org.hibernate.Session;
import org.hibernate.Transaction;

import com.yx.zzg.util.HibernateUtil;

public class OpenSessionInView implements Filter {

    public void destroy() {

    }

    public void doFilter(ServletRequest request, ServletResponse response,
            FilterChain filter) throws IOException, ServletException {
        Transaction tx = null;
        Session session = null;
        try {
            session = HibernateUtil.getThreadLocalSession();
            tx = session.beginTransaction();
            filter.doFilter(request, response);
            tx.commit();
        } catch (Exception e) {
            if (tx != null) {
                tx.rollback();
                throw new RuntimeException(e.getMessage(),e);
            }
        } finally {
            HibernateUtil.colseSession();
        }
    }

    public void init(FilterConfig arg0) throws ServletException {

    }

}

4.web.xml中配置过滤器

<filter>
        <filter-name>OpenSessionInView</filter-name>
        <filter-class>com.yx.zzg.servelt.OpenSessionInView</filter-class>
    </filter>
    <filter-mapping>
        <filter-name>OpenSessionInView</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>

5.HibernateUtil类：

package com.yx.zzg.util;

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;

public class HibernateUtil {

    private static SessionFactory sessionFactory;

    //创建一个ThreadLocal对象
    private static ThreadLocal threadSession = new ThreadLocal();

    private HibernateUtil() {

    }

    static {
        Configuration cfg = new Configuration().configure();
        sessionFactory = cfg.buildSessionFactory();
    }

    /**
     * 从当前线程中获取session，如果没有，则得到session，并将此session放入当前线程中
     * @return
     */
    public static Session getThreadLocalSession() {
        Session session = (Session) threadSession.get();
        if (session == null) {
            session = getSession();
            threadSession.set(session);
        }
        return session;
    }

    /**
     * 关闭session，并将当前线程中的session设置为null
     */
    public static void colseSession() {
        Session session = (Session) threadSession.get();
        if (session != null) {
            session.close();
            threadSession.set(null);
        }
    }

    public static Session getSession() {
        return sessionFactory.openSession();
    }

}

6.数据层方法：

public User findUserById(String id) {
    User user = (User) HibernateUtil.getThreadLocalSession().load(
            User.class, id);
    return user;
}