NHibernate中Session的处理 线程不安全

NHibernate中Session是线程不安全的，而且每次数据库操作 请求创建Session时对性能有些影响。在Windows应用中可以通过 [ThreadStatic]特性很简单的就可以实现线程安全，而在Web中可以通过将Session与用于请求HttpContext绑定实现线程安全，并且用户当前请求时只有一个Session。代码如下：

ISessionManage.cs

using System;
using NHibernate;

namespace Commercial.Jwsoft.Framework.Persistence.SessionManage
{
    /// <summary>
    /// 功能：主要用于封装第三方类库操作数据库的Session类,现主要用于封装NHibernate中的Session
    /// </summary>
    public interface ISessionManage
    {
        /// <summary>
        /// 获取Session的一个实例
        /// </summary>
        /// <returns>返回实现NHibernate.ISession接口的类</returns>
        ISession Get();

/// <summary>
        /// 设置Session的一个实例
        /// </summary>
        /// <param name="session">实现NHibernate.ISession接口的类</param>
        void Set(ISession session);
    }
}

－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

WebNHSession.cs

using System;
using System.Web;
using NHibernate;

namespace Commercial.Jwsoft.Framework.Persistence.SessionManage
{
    /// <summary>
    /// 功能：此类用于Web应用，NHibernate提供的Session有两个缺陷：
    ///       一方面是线程不安全的，另一方面每次数据库操作创建一个Session对程序性能有影响。
    ///       因此通过将Session绑定到HttpContext上，这样每个用户具有唯一的一个Session，而且
    ///       在用户的请求结束后关闭Session并自己释放掉。
    /// </summary>
    public class WebNHSession : ISessionManage
    {
        public WebNHSession()
        {

}

/// <summary>
        /// 获取存储到HttpContext中的实现NHibernate.ISession接口的类实例
        /// </summary>
        /// <returns>实现NHibernate.ISession接口的类实例，当用户之前没有调用Set方法会返回Null</returns>
        public ISession Get()
        {
            return (ISession)HttpContext.Current.Items[SessionConfigManage.SessionSourceItemName];
        }

/// <summary>
        /// 存储实现NHibernate.ISession接口的类实例到HttpContext中
        /// </summary>
        /// <param name="session">实现NHibernate.ISession接口的类实例</param>
        public void Set(ISession session)
        {
            if (session != null)
            {
                HttpContext.Current.Items.Add(SessionConfigManage.SessionSourceItemName, session);
            }
            else
            {
                HttpContext.Current.Items.Remove(SessionConfigManage.SessionSourceItemName);
            }
        }
    }
}
－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

WinFormNHSession.cs

using System;
using NHibernate;

namespace Commercial.Jwsoft.Framework.Persistence.SessionManage
{
    /// <summary>
    /// 功能：此类用于Windows应用，NHibernate提供的Session有两个缺陷：
    ///       一方面是线程不安全的，另一方面每次数据库操作创建一个Session对程序性能有影响。
    ///       因此通过线程变量获取一个NHibernate Session的多个线程安全的实例，而且线程变量使用后即释放掉。
    /// </summary>
    public class WinFormNHSession : ISessionManage
    {
        [ThreadStatic]
        private static ISession _threadSession = null;

public WinFormNHSession()
        {
        }

/// <summary>
        /// 获取存储到线程变量中的实现NHibernate.ISession接口的类实例
        /// </summary>
        /// <returns>实现NHibernate.ISession接口的线程安全的类实例，当用户之前没有调用Set方法会返回Null</returns>
        public ISession Get()
        {
            if (_threadSession != null)
            {
                if (_threadSession.IsConnected)
                {
                    _threadSession.Reconnect();
                }
            }
            return _threadSession;
        }

/// <summary>
        /// 存储实现NHibernate.ISession接口的类实例到线程变量中
        /// </summary>
        /// <param name="session">实现NHibernate.ISession接口的类实例</param>
        public void Set(ISession session)
        {
            if (_threadSession.IsConnected)
            {
                session.Disconnect();
            }
            _threadSession = session;
        }
    }
}

SessionFactory.cs

using System;
using System.Runtime.Remoting;
using NHibernate;

namespace Commercial.Jwsoft.Framework.Persistence.SessionManage
{
    /// <summary>
    /// 功能：管理多个实现ISessionManage接口的类工厂，根据读取的要加载的类名称信息，进行动态的创建Session
    /// </summary>
    public class SessionFactory
    {
        private static ISession session = null;
        private static ISessionManage sessionManage = null;
       
        static SessionFactory()
        {
            Init();
        }

/// <summary>
        /// 获取实现NHibernate.ISession接口的Session实例
        /// </summary>
        /// <returns>返回实现NHibernate.ISession接口的类实例</returns>
        public static ISession GetSession()
        {
                      session = sessionManage.Get();
          
            if (session == null)
            {
                session = NHibernateSession.GetNHibernateSession();
                sessionManage.Set(session);
            }

return session;
        }

private static void Init()
        {
            System.Reflection.Assembly ass = System.Reflection.Assembly.Load(SessionConfigManage.AssemblyName);
            sessionManage = (ISessionManage)ass.CreateInstance(SessionConfigManage.SessionSourceItemName);
        }
    }
}
－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

NHibernateSession.cs

using System;
using System.Data;
using System.Collections.Generic;
using System.Text;
using NHibernate;
using NHibernate.Cfg;

namespace Commercial.Jwsoft.Framework.Persistence.SessionManage
{
    /// <summary>
    /// 功能：加载嵌入资源(Xml配置文件),打开一个SessionFactory,获取NHibernate的Session实例
    /// </summary>
    public class NHibernateSession
    {
        private static Configuration cfg = null;
        private static ISessionFactory sessionFactory = null;

static NHibernateSession()
        {
            cfg = new Configuration().Configure();
            sessionFactory = cfg.BuildSessionFactory();
        }

/// <summary>
        /// 获取NHibernate的Session实例
        /// </summary>
        /// <returns></returns>
        public static ISession GetNHibernateSession()
        {
            return sessionFactory.OpenSession();
        }
    }
}
－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

SessionConfigManage.cs

using System;
using System.Collections.Generic;
using System.Text;
using System.Configuration;

namespace Commercial.Jwsoft.Framework.Persistence.SessionManage
{
    /// <summary>
    /// 功能：根据类库的应用环境不同(Windows应用还是Web应用)，动态创建类实例
    /// 日期：2006-08-24
    /// 作者：郭少宏
    /// </summary>
    public class SessionConfigManage
    {
        private const string SESSION_ITEM_NAME = "SessionItemName";
        private static object _locker = new object();
        private static string _sessionItemName = string.Empty;
        private static string _assemblyName = string.Empty;

static SessionConfigManage()
        {
            string configString = ConfigurationManager.AppSettings[SESSION_ITEM_NAME];
            string[] arr = configString.Split(‘,‘);
            _sessionItemName = arr[0];
            _assemblyName = arr[1];
        }
        /// <summary>
        /// 获取配置文件中名为SESSION_ITEM_NAME配置节的信息，记录的要加载的SessionManage的类全称
        /// </summary>
        /// <returns>实现ISessionManage接口的类的名称</returns>
        public static string SessionSourceItemName
        {
            get
            {
                lock (_locker)
                {
                    return _sessionItemName;
                }
            }
        }

/// <summary>
        /// 获取配置文件中名为SESSION_ITEM_NAME配置节的信息，记录的要加载的SessionManage的类全称
        /// </summary>
        /// <returns>实现ISessionManage接口的类的程序集名称</returns>
        public static string AssemblyName
        {
            get
            {
                lock (_locker)
                {
                    return _assemblyName;
                }
            }
        }
    }
}

在Web.Config文件中的配置节如下：

<appSettings>
    <!---->
    <!--在Web应用中加载的获取Session的类名称-->
    <add key="SessionItemName" value="Commercial.Jwsoft.Framework.Persistence.SessionManage.WebNHSession,JWFramework"/>
    <!--在Windows应用中加载的获取Session的类名称-->
    <!--<add key="SessionItemName" value="Commercial.Jwsoft.Framework.Persistence.SessionManage.WinFormNHSession,JWFramework"/>-->
  </appSettings>

在Global.asax中添加如下代码：

/// <summary>
    /// 当用户断开请求时用来关闭用户请求的Session的连接
    /// </summary>
    /// <param name="sender"></param>
    /// <param name="e"></param>
  void Session_End(object sender, EventArgs e)
    {
        NHibernate.ISession session = Commercial.Jwsoft.Framework.Persistence.SessionManage.SessionFactory.GetSession();
        if (session != null)
        {
            session.Close();
        }

}

时间： 2024-10-12 11:07:27

NHibernate中Session的处理 线程不安全的相关文章

NHibernate中Session与ASP.NET MVC中Action的综合使用

NHibernate的基本特征是完成面向对象的程序设计语言到关系数据库的映射,在NHibernate中使用持久化对象PO(Persistent Object)完成持久化操作,对PO的操作必须在Session管理下才能同步到数据库, 但是这里的Session并非指HttpSession,可以理解为基于ADO.NET的Connnection,Session是NHibernate运作的中心,对象的生命周期.事务的管理.数据库的存取都与Session息息相关,首先,我们需要知道, SessionFact

Hibernate中Session与本地线程绑定

------------------siwuxie095 Hibernate 中 Session 与本地线程绑定 1.Session 类似于 JDBC 的连接 Connection 2.Session 对象是单线程对象,只能自己使用,不能共用 将 Session 与本地线程绑定,保证 Session 对象绝对是一个单线程对象 3.Hibernate 帮助我们实现了 Session 与本地线程绑定(底层是 ThreadLocal) 4.获取与本地线程绑定的 Session (1)在 Hiberna

NHibernate中session.update()及session.merge()的区别

今天的工作中遇到一个奇怪的问题,如下: "a different object with the same identifier value was already associated with the session: 19519146" 该异常的上下文如下: 1:在net.tcp绑定的wcf远程调用时产生: 2:通过UI调用方法不会产生该异常. 分析该问题: 由异常信息可以看出,该问题是由于在session.update对一组实体进行更新后,试图将新的实体associate到se

NHibernate中的API

本篇文章介绍的是NHibernate的各种API及其作用. 下图描述了NHibernate的API在分层架构中的作用,下面将进行详细说明. NHibernate的接口大致分为四类:1.  被应用程序调用进行基本数据操作(增.删.改.查)的接口.这些接口是应用程序的业务逻辑层和控制层与NHibernate的主要交互点.ISession, ITransaction, IQuery和ICriteria属于此类.2. 被应用程序用来配置NHibernate的接口.Configuration就属此类.3.

hibernate中session线程安全的实现

在hibernate中session是使用ThreadLocal实现线程安全的. ThreadLocal并不是一个Thread,而是一个线程副本,ThreadLocal为每个使用该变量的线程提供一个变量副本,线程修改自己的变量副本不会影响其他线程的变量副本 ThreadLocal有四个方法: set():设置当前线程的局部变量的值 get():获取当前线程的局部变量的值 remove():将当前线程局部变量的值删除,此方法不必显示的调用,因为局部变量自有垃圾回收器去清理 initialValue

NHibernate中的线程安全与线程不安全问题

作者 : Dolphin 原文地址:http://blog.csdn.net/qingdujun/article/details/27107519 数据库审计(简称DBAudit)能够实时记录网络上的数据库活动,对数据库操作进行细粒度审计的合规性管理,对数据库遭受到的风险行为进行告警,对攻击行为进行阻断.它通过对用户访问数据库行为的记录.分析和汇报,用来帮助用户事后生成合规报告.事故追根溯源,同时加强内外部数据库网络行为记录,提高数据资产安全. 审计通常是很费时间空间的.审计功能一般主要用于安全

hibernate中session的获取使用以及其他注意事项

hibernate中session的获取使用以及其他注意事项 前言:工作时,在同时使用Hibernate的getSession().getHibernateTemplate()获取Session后进行数据查询时不是出现了"session is close"异常就是出现其他异常问题,痛定思痛,决定收集并整理相关资料,方便今后的使用. 一.session的获取 在hibernate中的Session对象通过SessionFactory来管理,可以通过使用openSession ().get

Tomcat中session详解（源码阅读）

Tomcat中的session是通过一个manager来管理的,其中Session接口默认实现类有StandardSession,管理器的默认实现是StandardManager. 我们平时在servlet中使用的session也就是HashMap中的一个session对象,同时session除了在内存存储,同时还提供了持久化方法,tomcat中持久化有两种,一种是保存为文件,另一种则是保存到数据库. 这一节首先来看一下默认的StandardSession和StandardManager. pu

01-08-01【Nhibernate (版本3.3.1.4000) 出入江湖】NHibernate中的三种状态

以下属于不明来源资料: 引入 在程序运行过程中使用对象的方式对数据库进行操作,这必然会产生一系列的持久化类的实例对象.这些对象可能是刚刚创建并准备存储的,也可能是从数据库中查询的,为了区分这些对象,根据对象和当前会话的关联状态,我们可以把对象分为三种: 瞬时对象:对象刚刚建立.该对象在数据库中没有记录,也不在ISession缓存中.如果该对象是自动生成主键,则该对象的对象标识符为空. 持久化对象:对象已经通过NHibernate进行了持久化,数据库中已经存在对应的记录.如果该对象是自动生成主键,