`
newleague
  • 浏览: 1469904 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类

数据库持久层——浅谈hibernate中的Session

 
阅读更多

大多数情况下,Session 管理的目标聚焦于通过合理的设计,避免Session 的频繁创建

和销毁,从而避免大量的内存开销和频繁的JVM垃圾回收,保证系统高效平滑运行。

在各种Session 管理方案中, ThreadLocal 模式得到了大量使用。ThreadLocal 

Java中一种较为特殊的线程绑定机制。通过ThreadLocal存取的数据,总是与当前线程相关,

也就是说,JVM 为每个运行的线程,绑定了私有的本地实例存取空间,从而为多线程环境常出现的并发访问问题提供了一种隔离机制。

首先,我们需要知道,SessionFactory负责创建SessionSessionFactory是线程

安全的,多个并发线程可以同时访问一个SessionFactory 并从中获取Session 实例。而

Session并非线程安全,也就是说,如果多个线程同时使用一个Session实例进行数据存取,

则将会导致Session 数据存取逻辑混乱。下面是一个典型的Servlet,我们试图通过一个类

变量session实现Session的重用,以避免每次操作都要重新创建:

public class TestServlet extends HttpServlet {

private Session session;

public void doGet( HttpServletRequest request,

HttpServletResponse response)

throws ServletException, IOException {

session = getSession();

doSomething();

session.flush();

}

public void doSomething(){

......//基于session的存取操作

}

}

代码看上去正确无误,甚至在我们单机测试的时候可能也不会发生什么问题,但这样的代

码一旦编译部署到实际运行环境中,接踵而来的莫名其妙的错误很可能会使得我们摸不找头脑。

问题出在哪里?

首先,Servlet 运行是多线程的,而应用服务器并不会为每个线程都创建一个Servlet

实例,也就是说,TestServlet在应用服务器中只有一个实例(在Tomcat中是这样,其他的

应用服务器可能有不同的实现),而这个实例会被许多个线程并发调用,doGet 方法也将被不

同的线程反复调用,可想而知,每次调用doGet 方法,这个唯一的TestServlet 实例的

session 变量都会被重置,线程的运行过程中,其他的线程如果也被执行,那么session

的引用将发生改变,之后线程再调用session,可能此时的session 与其之前所用的

session就不再一致,显然,错误也就不期而至。

ThreadLocal的出现,使得这个问题迎刃而解。

我们对上面的例子进行一些小小的修改:

public class TestServlet extends HttpServlet {

private ThreadLocal localSession = new ThreadLocal();

public void doGet( HttpServletRequest request,

HttpServletResponse response)

throws ServletException, IOException {

localSession.set(getSession());

doSomething();

session.flush();

}

public void doSomething(){

Session session = (Session)localSession.get();

......//基于session的存取操作

}

}

可以看到,localSession 是一个ThreadLocal 类型的对象,在doGet 方法中,我们

通过其set 方法将获取的session 实例保存,而在doSomething 方法中,通过get 方法取

session实例。

这也就是ThreadLocal的独特之处,它会为每个线程维护一个私有的变量空间。实际上,

其实现原理是在JVM 中维护一个Map,这个Mapkey 就是当前的线程对象,而value则是

线程通过ThreadLocal.set方法保存的对象实例。当线程调用ThreadLocal.get方法时,

ThreadLocal会根据当前线程对象的引用,取出Map中对应的对象返回。

这样,ThreadLocal通过以各个线程对象的引用作为区分,从而将不同线程的变量隔离开

来。

回到上面的例子,通过应用ThreadLocal 机制,线程session 实例只能为线程A

所用,同样,其他线程的session实例也各自从属于自己的线程。这样,我们就实现了线程安

全的Session共享机制。

Hibernate官方开发手册的示例中,提供了一个通过ThreadLocal维护Session的好

榜样:

public class HibernateUtil {

private static final SessionFactory sessionFactory;

static {

try {

// Create the SessionFactory

sessionFactory = new

Configuration().configure().buildSessionFactory();

} catch (HibernateException ex) {

throw new RuntimeException(

"Configuration problem: " + ex.getMessage(),

ex

);

}

}

public static final ThreadLocal session = new ThreadLocal();

public static Session currentSession() throws HibernateException

{

Session s = (Session) session.get();

// Open a new Session, if this Thread has none yet

if (s == null) {

s = sessionFactory.openSession();

session.set(s);

}

return s;

}

public static void closeSession() throws HibernateException {

Session s = (Session) session.get();

session.set(null);

if (s != null)

s.close();

}

}

在代码中,只要借助上面这个工具类获取Session 实例,我们就可以实现线程范围内的

Session 共享,从而避免了在线程中频繁的创建和销毁Session 实例。不过注意在线程结束

时关闭Session

同时值得一提的是,新版本的Hibernate在处理Session的时候已经内置了延迟加载机

制,只有在真正发生数据库操作的时候,才会从数据库连接池获取数据库连接,我们不必过于担

Session的共享会导致整个线程生命周期内数据库连接被持续占用。

上面的HibernateUtil类可以应用在任何类型的Java程序中。特别的,对于Web程序

而言,我们可以借助Servlet2.3规范中新引入的Filter机制,轻松实现线程生命周期内的

Session管理(关于Filter的具体描述,请参考Servlet2.3规范)。

Filter的生命周期贯穿了其所覆盖的ServletJSP也可以看作是一种特殊的Servlet

及其底层对象。FilterServlet被调用之前执行,在Servlet调用结束之后结束。因此,

Filter 中管理Session 对于Web 程序而言就显得水到渠成。下面是一个通过Filter 

Session管理的典型案例:

public class PersistenceFilter implements Filter

{

protected static ThreadLocal hibernateHolder = new ThreadLocal();

public void doFilter(ServletRequest request, ServletResponse

response, FilterChain chain)

throws IOException, ServletException

{

hibernateHolder.set(getSession());

try

{

……

chain.doFilter(request, response);

……

}

finally

{

Session sess = (Session)hibernateHolder.get();

if (sess != null)

{

hibernateHolder.set(null);

try

{

sess.close();

}

catch (HibernateException ex) {

throw new ServletException(ex);

}

}

}

}

……

}

通过在doFilter中获取和关闭Session,并在周期内运行的所有对象(Filter链中其

余的Filter,及其覆盖的Servlet 和其他对象)对此Session 实例进行重用,保证了一个

Http Request处理过程中只占用一个Session,提高了整体性能表现。

在实际设计中,Session的重用做到线程级别一般已经足够,企图通过HttpSession

现用户级的Session重用反而可能导致其他的问题。凡事不能过火,Session重用也一样。

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics