代碼下載看過(guò)hibernate文檔的人應該看到在“
第 1 章 在Tomcat中快速上手”,可以看到代碼中使用ThreadLocal作為Session的存放容器。
public static final ThreadLocal session = new ThreadLocal();
查看
JDK的文檔,這個(gè)東東作用是給每個(gè)線(xiàn)程提供單獨的靜態(tài)變量,在一個(gè)線(xiàn)程內部共享,而不同的線(xiàn)程間不共享。
在hibernate中Session 是“單線(xiàn)程”的,即多個(gè)線(xiàn)程訪(fǎng)問(wèn)一個(gè)Session 會(huì )出問(wèn)題。所以在最普遍的做法是一個(gè)操作就創(chuàng )建一個(gè)新的Session。Session對應著(zhù)一個(gè)數據庫的連接,而且Session內部提供了緩存(一級緩存)的機制。這樣做意味這更多的數據庫連接次數和緩存資源的浪費。
hibernate中使用使用ThreadLocal的目的就是讓Session在一個(gè)線(xiàn)程內共享,盡可能的較少連接數據庫的次數和盡可能的使用到一級緩存。
對于NHibernate是否有實(shí)現的辦法呢。我們找到了
ThreadStaticAttribute ,它指示靜態(tài)字段的值對于每個(gè)線(xiàn)程都是唯一的。用法如下
[ThreadStatic]
static int value;
似乎這樣就可以了。在WinFrom,控制臺應用程序和類(lèi)庫等中的確是沒(méi)有問(wèn)題了。但在A(yíng)sp.Net中問(wèn)題可不這么簡(jiǎn)單。在Java里Jsp作為Servlet來(lái)運行,是單線(xiàn)程的。而Asp.Net就不一樣了,他用到了多個(gè)線(xiàn)程,造成的情況是:"當有多個(gè)線(xiàn)程的時(shí)候,ThreadStaticAttribute的變量被第一個(gè)線(xiàn)程初始化后,其它的線(xiàn)程訪(fǎng)問(wèn)到的都是null,而每個(gè)HttpRequest則可能有多個(gè)線(xiàn)程為其服務(wù),因而有人稱(chēng)ThreadStatic is evil。"(此段引用
在A(yíng)SP.NET中使用NHibernate - 風(fēng)滿(mǎn)袖 - 博客園)。所以我們好的做法是使用HttpContext.Current.Items來(lái)共享session。使用HttpModule來(lái)處理之。在“
在A(yíng)SP.NET中使用NHibernate - 風(fēng)滿(mǎn)袖 - 博客園”里已經(jīng)做了講解。
我的想法是做一個(gè)統一的ISession提供者,只需要簡(jiǎn)單的配置即可用在不同的應用程序里。
儲存ISession類(lèi)需要實(shí)現的接口。
/**//*
* 修改日期:2005-10-05
* 修改人:DDL
* 修改原因:
* */
using NHibernate;
namespace Index.Data.NHibernateSessionStorage
{
/**//// <summary>
///儲存一個(gè)ISession
/// </summary>
public interface ISessionStorage
{
/**//// <summary>
///獲得ISession
/// </summary>
/// <returns></returns>
ISession Get();
/**//// <summary>
/// 保存ISession
/// </summary>
/// <param name="value"></param>
void Set(ISession value);
}
} 非Asp.Net程序使用的ISession提供者
/**//*
* 修改日期:2005-10-10
* 修改人:DDL
* 修改原因:
* */
using System;
using NHibernate;
namespace Index.Data.NHibernateSessionStorage
{
/**//// <summary>
/// 保存一個(gè)Session在一個(gè)thread-static的類(lèi)成員中。
/// </summary>
public class ThreadSessionSource : ISessionStorage
{
[ThreadStatic]
private static ISession m_Session;
/**//// <summary>
///獲得Session
/// </summary>
/// <returns></returns>
public ISession Get()
{
if (m_Session != null)
{
if (!m_Session.IsConnected)
{
m_Session.Reconnect();
}
}
return m_Session;
}
/**//// <summary>
/// 保存Session
/// </summary>
/// <param name="value"></param>
public void Set(ISession value)
{
if (value.IsConnected)
{
value.Disconnect();
}
m_Session = value;
}
}
} Asp.Net程序使用的ISession提供者
/**//*
* 修改日期:2005-10-05
* 修改人:DDL
* 修改原因:
* */
using NHibernate;
using System.Web;
using Index.Data.NHibernateSessionStorage.CFG;
namespace Index.Data.NHibernateSessionStorage
{
/**//// <summary>
/// 儲存一個(gè)ISession <see cref="HttpContext.Items" /> 集合.
/// </summary>
public class HttpSessionSource : ISessionStorage
{
/**//// <summary>
/// 獲得ISession
/// </summary>
/// <returns>獲得的ISession</returns>
public ISession Get()
{
return (ISession)HttpContext.Current.Items[Config.HttpSessionSourceItemName];
}
/**//// <summary>
/// 保存ISession
/// </summary>
/// <param name="value">需要保存的ISession</param>
public void Set(ISession value)
{
if (value != null)
{
HttpContext.Current.Items.Add(Config.HttpSessionSourceItemName, value);
}
else
{
HttpContext.Current.Items.Remove(Config.HttpSessionSourceItemName);
}
}
}
}
通過(guò)讀取配置文件讓工廠(chǎng)提供不同的ISession提供者
/**//*
* 修改日期:2005-10-05
* 修改人:DDL
* 修改原因:
* */
using System;
using Index.Data.NHibernateSessionStorage.CFG;
namespace Index.Data.NHibernateSessionStorage
{
/**//// <summary>
/// 產(chǎn)生ISessionStorage的工廠(chǎng)
/// </summary>
public class ISessionStorageFactory
{
/**//// <summary>
/// 獲得ISessionStorage
/// </summary>
/// <returns></returns>
public static ISessionStorage GetSessionStorage()
{
if(Config.SessionSourceType=="http") //使用
{
return new HttpSessionSource();
}
else if(Config.SessionSourceType=="threadStatic")
{
return new ThreadSessionSource();
}
else
{
throw new NotSupportedException("不支持的SessionSourceType!" + Config.SessionSourceType);
}
}
}
}
配置類(lèi)
/**//*
* 修改日期:2005-10-05
* 修改人:DDL
* 修改原因:
* */
using System;
using System.Configuration;
namespace Index.Data.NHibernateSessionStorage.CFG
{
/**//// <summary>
/// 配置信息幫助類(lèi)
/// </summary>
public class Config
{
私有成員#region 私有成員
private static object m_Locker = new object();
private static string m_SessionSourceType=String.Empty;
private static string m_HttpSessionSourceItemName=String.Empty;
#endregion
屬性#region 屬性
/**//// <summary>
/// Session資源源類(lèi)型;http,threadStatic
/// </summary>
public static string SessionSourceType
{
get
{
lock( m_Locker )
{
if(m_SessionSourceType==String.Empty)
{
return ConfigurationManager.AppSettings["SessionSourceType"];
}
else
{
return m_SessionSourceType;
}
}
}
}
/**//// <summary>
/// HttpSessionSource存放HttpContext.Current.Items的鍵值名
/// </summary>
public static string HttpSessionSourceItemName
{
get
{
lock( m_Locker )
{
if(m_HttpSessionSourceItemName==String.Empty)
{
return ConfigurationManager.AppSettings["HttpSessionSourceItemName"];
}
else
{
return m_HttpSessionSourceItemName;
}
}
}
}
/**//// <summary>
/// 是否使用Session資源源
/// </summary>
public static bool UserSessionSource
{
get
{
lock (m_Locker)
{
return Convert.ToBoolean(ConfigurationManager.AppSettings["UserSessionSource"]);
}
}
}
#endregion
}
}
然后進(jìn)行其他的一些封裝操作
/**//*
* 修改日期:2005-10-05
* 修改人:DDL
* 修改原因:生成工廠(chǎng)類(lèi)
* */
using Index.Data.NHibernateSessionStorage.CFG;
using NHibernate;
using NHibernate.Cfg;
namespace Index.Data.NHibernateSessionStorage
{
/**//// <summary>
/// 用來(lái)生成ISession實(shí)例的工廠(chǎng)
/// </summary>
public static class NHibernateDatabaseFactory
{
私有靜態(tài)變量#region 私有靜態(tài)變量
private static object m_Locker = new object();
private static Configuration m_Configuration = null;
private static ISessionFactory m_SessionFactory = null;
private static ISessionStorage m_Sessionsource;
#endregion
靜態(tài)構造函數#region 靜態(tài)構造函數
static NHibernateDatabaseFactory()
{
m_Sessionsource = ISessionStorageFactory.GetSessionStorage();
}
#endregion
內部靜態(tài)變量#region 內部靜態(tài)變量
/**//// <summary>
/// NHibernate配置對象
/// </summary>
public static Configuration Configuration
{
get
{
lock (m_Locker)
{
if (m_Configuration == null)
{
CreateConfiguration();
}
return m_Configuration;
}
}
set { m_Configuration = value; }
}
/**//// <summary>
/// NHibernate的對象工廠(chǎng)
/// </summary>
internal static ISessionFactory SessionFactory
{
get
{
if (null == m_SessionFactory)
{
if (m_Configuration == null)
{
CreateConfiguration();
}
lock (m_Locker)
{
m_SessionFactory = Configuration.BuildSessionFactory();
}
}
return m_SessionFactory;
}
}
#endregion
公共方法#region 公共方法
/**//// <summary>
/// 建立ISessionFactory的實(shí)例
/// </summary>
/// <returns></returns>
public static ISession CreateSession()
{
if (Config.UserSessionSource) //如果使用保存的ISession
{
ISession s = m_Sessionsource.Get();
if (s == null)
{
s = SessionFactory.OpenSession();
m_Sessionsource.Set(s);
}
return s;
}
else //如果使用新ISession
{
return SessionFactory.OpenSession();
}
}
#endregion
私有方法#region 私有方法
private static void CreateConfiguration()
360docimg_501_ 360docimg_502_{
360docimg_503_ m_Configuration = new Configuration();
360docimg_504_ // Add interceptor, if you need to.
360docimg_505_ // _config.Interceptor = new Interceptor();
360docimg_506_ }
360docimg_507_
360docimg_508_ #endregion
360docimg_509_ }
360docimg_510_} 使用方法
非Asp.net應用配置
360docimg_511_ <appSettings>
360docimg_512_ <add key="SessionSourceType" value="threadStatic" />
360docimg_513_ <add key="HttpSessionSourceItemName" value="NHSession" />
360docimg_514_ <add key="UserSessionSource" value="true"/>
360docimg_515_ </appSettings>
Asp.net應用配置
360docimg_516_ <appSettings>
360docimg_517_ <add key="SessionSourceType" value="http"/>
360docimg_518_ <add key="HttpSessionSourceItemName" value="NHSession"/>
360docimg_519_ <add key="UserSessionSource" value="true"/>
360docimg_520_ </appSettings>
360docimg_521_
360docimg_522_ <httpModules>
360docimg_523_ <add type="Index.Data.NHibernateData.SessionStorage.NHSessionModule, Index.Data.NHibernate" name="NHSessionModule"/>
360docimg_524_ </httpModules>
然后在程序開(kāi)始的時(shí)候配置下
360docimg_525_ Index.Data.NHibernateData.SessionStorage.NHibernateFactory.Configuration.Configure(Server.MapPath("~") + "\\hibernate.cfg.xml");
360docimg_526_
對于A(yíng)sp.net我會(huì )把次段代碼寫(xiě)在Global.asax的Application_Start方法里。