本文共 2540 字，大约阅读时间需要 8 分钟。

使用ThreadLocal创建线程安全的Session

在Hibernate中，Session并不是线程安全的。多个线程共享同一个Session会导致数据存取的混乱。为了解决这个问题，可以使用ThreadLocal来为每个线程提供独立的Session。

1. ThreadLocal的基本原理

ThreadLocal是一种线程局部变量，它为每个线程提供一个独立的值副本。每个线程都能独立地修改自己的副本，而不会影响其他线程。ThreadLocal的实现通常使用一个Map来存储每个线程的值。

2. 在HibernateUtil类中实现ThreadLocal Session

首先，我们需要在HibernateUtil类中定义一个ThreadLocal变量来保存Session：

private static ThreadLocal
   
     sessionLocal = new ThreadLocal<>();
   

然后，在获取Session时，检查ThreadLocal中是否有Session，如果没有则创建一个，并将其放入ThreadLocal中：

public static Session getSession() {
    Session session = sessionLocal.get();
    if (session == null || !session.isOpen()) {
        session = sessionFactory.openSession();
        sessionLocal.set(session);
    }
    return session;
}

在开始一个新的事务时，使用ThreadLocal管理Transaction：

public void startTransaction() {
    Transaction trans = transLocal.get();
    if (trans != null) {
        trans.begin();
    } else {
        trans = getSession().getTransaction();
        transLocal.set(trans);
        trans.begin();
    }
}

在提交或回滚事务时，确保释放Transaction，并更新ThreadLocal的状态：

public void commitTransaction() {
    Transaction trans = transLocal.get();
    if (trans != null && !trans.wasCommitted()) {
        trans.commit();
        transLocal.set(null);
    }
}
public void rollbackTransaction() {
    Transaction trans = transLocal.get();
    if (trans != null && !trans.wasRolledBack()) {
        trans.rollback();
        transLocal.set(null);
    }
}

3. 使用OpenSessionInViewFilter过滤器

为了确保Session在请求结束后被正确关闭，可以在web.xml中添加OpenSessionInViewFilter过滤器：

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

4. getCurrentSession()与openSession()的区别

• getCurrentSession()方法会将Session绑定到当前线程，并在事务提交或回滚后自动关闭Session。
• openSession()方法不会绑定Session到线程，Session需要手动关闭。

5. 在Hibernate.cfg.xml中添加配置

在Hibernate.cfg.xml中添加以下配置：

   
    thread
   

这样可以确保Session在线程上下文中正确管理。

优缺点分析

• 优点：使用ThreadLocal避免了频繁创建和销毁Session，同时实现了多线程数据隔离。
• 缺点：在高并发环境下，可能会增加系统负担，尤其是在Session管理和事务处理上需要额外的开销。

总结

通过使用ThreadLocal和OpenSessionInViewFilter，可以有效地在多线程环境下管理Hibernate Session，避免数据存取的混乱。这种方法确保了每个线程都有独立的Session和Transaction，从而提高了系统的并发性能和数据安全性。

转载地址：http://qpmbz.baihongyu.com/