NHibernate的Session管理的详细介绍

代码下载

看过hibernate文档的人应该看到在“第 1 章 在Tomcat中快速上手”，可以看到代码中使用ThreadLocal作为Session的存放容器。

publicstaticfinalThreadLocalsession=newThreadLocal();

查看JDK的文档，这个东东作用是给每个线程提供单独的静态变量，在一个线程内部共享，而不同的线程间不共享。

在hibernate中Session 是“单线程”的，即多个线程访问一个Session 会出问题。所以在最普遍的做法是一个操作就创建一个新的Session。Session对应着一个数据库的连接，而且Session内部提供了缓存（一级缓存）的机制。这样做意味这更多的数据库连接次数和缓存资源的浪费。

hibernate中使用使用ThreadLocal的目的就是让Session在一个线程内共享，尽可能的较少连接数据库的次数和尽可能的使用到一级缓存。

对于NHibernate是否有实现的办法呢。我们找到了ThreadStaticAttribute ，它指示静态字段的值对于每个线程都是唯一的。用法如下

[ThreadStatic]
staticintvalue;

似乎这样就可以了。在WinFrom,控制台应用程序和类库等中的确是没有问题了。但在Asp.Net中问题可不这么简单。在Java里Jsp作为Servlet来运行，是单线程的。而Asp.Net就不一样了，他用到了多个线程，造成的情况是：＂当有多个线程的时候，ThreadStaticAttribute的变量被第一个线程初始化后，其它的线程访问到的都是null，而每个HttpRequest则可能有多个线程为其服务，因而有人称ThreadStatic is evil。＂（此段引用在ASP.NET中使用NHibernate - 风满袖 - 博客园）。所以我们好的做法是使用HttpContext.Current.Items来共享session。使用HttpModule来处理之。在“在ASP.NET中使用NHibernate - 风满袖 - 博客园”里已经做了讲解。

我的想法是做一个统一的ISession提供者，只需要简单的配置即可用在不同的应用程序里。

储存ISession类需要实现的接口。

/**//**//**//*
*修改日期：2005-10-05
*修改人：DDL
*修改原因：
**/
usingNHibernate;

namespaceIndex.Data.NHibernateSessionStorage
...{
/**//**//**////<summary>
///储存一个ISession
///</summary>
publicinterfaceISessionStorage
...{
/**//**//**////<summary>
///获得ISession
///</summary>
///<returns></returns>
ISessionGet();

/**//**//**////<summary>
///保存ISession
///</summary>
///<paramname="value"></param>
voidSet(ISessionvalue);
}
}

非Asp.Net程序使用的ISession提供者

/**//**//**//*
*修改日期：2005-10-10
*修改人：DDL
*修改原因：
**/

usingSystem;
usingNHibernate;

namespaceIndex.Data.NHibernateSessionStorage
...{
/**//**//**////<summary>
///保存一个Session在一个thread-static的类成员中。
///</summary>
publicclassThreadSessionSource:ISessionStorage
...{
[ThreadStatic]
privatestaticISessionm_Session;

/**//**//**////<summary>
///获得Session
///</summary>
///<returns></returns>
publicISessionGet()
...{
if(m_Session!=null)
...{
if(!m_Session.IsConnected)
...{
m_Session.Reconnect();
}
}
returnm_Session;
}

/**//**//**////<summary>
///保存Session
///</summary>
///<paramname="value"></param>
publicvoidSet(ISessionvalue)
...{
if(value.IsConnected)
...{
value.Disconnect();
}
m_Session=value;
}
}
}

Asp.Net程序使用的ISession提供者

/**//*
*修改日期：2005-10-05
*修改人：DDL
*修改原因：
**/

usingNHibernate;
usingSystem.Web;
usingIndex.Data.NHibernateSessionStorage.CFG;

namespaceIndex.Data.NHibernateSessionStorage
...{
/**//**//**////<summary>
///储存一个ISession<seecref="HttpContext.Items"/>集合.
///</summary>
publicclassHttpSessionSource:ISessionStorage
...{
/**//**//**////<summary>
///获得ISession
///</summary>
///<returns>获得的ISession</returns>
publicISessionGet()
...{
return(ISession)HttpContext.Current.Items[Config.HttpSessionSourceItemName];
}

/**//**//**////<summary>
///保存ISession
///</summary>
///<paramname="value">需要保存的ISession</param>
publicvoidSet(ISessionvalue)
...{
if(value!=null)
...{
HttpContext.Current.Items.Add(Config.HttpSessionSourceItemName,value);
}
else
...{
HttpContext.Current.Items.Remove(Config.HttpSessionSourceItemName);
}
}
}
}

通过读取配置文件让工厂提供不同的ISession提供者

/**//*
*修改日期：2005-10-05
*修改人：DDL
*修改原因：
**/

usingSystem;
usingIndex.Data.NHibernateSessionStorage.CFG;

namespaceIndex.Data.NHibernateSessionStorage
...{
/**//**//**////<summary>
///产生ISessionStorage的工厂
///</summary>
publicclassISessionStorageFactory
...{
/**//**//**////<summary>
///获得ISessionStorage
///</summary>
///<returns></returns>
publicstaticISessionStorageGetSessionStorage()
...{
if(Config.SessionSourceType=="http")//使用
...{
returnnewHttpSessionSource();
}
elseif(Config.SessionSourceType=="threadStatic")
...{
returnnewThreadSessionSource();