NHibernate的Session管理的详细介绍
NHibernate的Session管理的详细介绍
代码下载
看过hibernate文档的人应该看到在“第 1 章 在Tomcat中快速上手”,可以看到代码中使用ThreadLocal作为Session的存放容器。
查看JDK的文档,这个东东作用是给每个线程提供单独的静态变量,在一个线程内部共享,而不同的线程间不共享。
在hibernate中Session 是“单线程”的,即多个线程访问一个Session 会出问题。所以在最普遍的做法是一个操作就创建一个新的Session。Session对应着一个数据库的连接,而且Session内部提供了缓存(一级缓存)的机制。这样做意味这更多的数据库连接次数和缓存资源的浪费。
hibernate中使用使用ThreadLocal的目的就是让Session在一个线程内共享,尽可能的较少连接数据库的次数和尽可能的使用到一级缓存。
对于NHibernate是否有实现的办法呢。我们找到了ThreadStaticAttribute ,它指示静态字段的值对于每个线程都是唯一的。用法如下
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();