如何在多线程控制台应用程序中使用 Sharp Architecture 设置 NHibernate？答案

【问题标题】：How to setup NHibernate with Sharp Architecture in a multi-threaded console application?如何在多线程控制台应用程序中使用 Sharp Architecture 设置 NHibernate？
【发布时间】：2011-11-04 05:37:56
【问题描述】：

我对这些技术还是很陌生。这里真正的问题是如何在控制台应用程序中管理每个线程的会话。目前，如果我将它作为单个线程运行，那么一切都很好。一旦我切换到多线程模型，我就会开始看到会话级别的争用（因为 Session 对象在设计上不是安全的）KeyNotFound 异常（以及其他）开始被抛出。

在网络应用中，你会做这样的事情：

    /// <summary>
    /// Due to issues on IIS7, the NHibernate initialization cannot reside in Init() but
    /// must only be called once.  Consequently, we invoke a thread-safe singleton class to
    /// ensure it's only initialized once.
    /// </summary>
    protected void Application_BeginRequest(object sender, EventArgs e)
    {
        NHibernateInitializer.Instance().InitializeNHibernateOnce(
            () => InitializeNHibernateSession());
    }

    /// <summary>
    /// If you need to communicate to multiple databases, you'd add a line to this method to
    /// initialize the other database as well.
    /// </summary>
    private void InitializeNHibernateSession()
    {            

        var path = ConfigurationManager.AppSettings["NHibernateConfig"];
        NHibernateSession.Init(
            webSessionStorage,
            new string[] { Server.MapPath("~/bin/foo.Data.dll") },
            new AutoPersistenceModelGenerator().Generate(),
            Server.MapPath("~/App_Configuration/" + path ));
    }

// sample of my console app... very simple
static void Main(string[] args)
{
  InitializeNHibernateSession();
  while(true)
  {
    Task.Factory.StartNew(() => SomeAwesomeLongRunningPieceOfWork());
  }
}

这实质上是在 global.asax 中的每个线程（网络请求）执行一次初始化。

关于如何在控制台应用程序中设置此（会话管理）的任何想法？

【问题讨论】：

大概是在控制台应用程序中您自己管理线程？当然，您创建的线程具有可以调用初始化方法的入口点，与 Application_BeginRequest 相同。如果我们有更多关于您如何在控制台应用程序中管理线程的信息将会很有帮助:)
@MattDavey - 我将更新 OP 以反映我的设置。

标签： c# .net nhibernate console-application sharp-architecture

【解决方案1】：

这对我有用：

// Three threads:
for (int i = 0; i < 3; i++)
{
   Thread curThread = new Thread(StartThread);
   curThread.Start();
}

private void StartThread()
{
      NHibernateInitializer.Instance().InitializeNHibernateOnce(InitializeNHibernateSession);
      SomeAwesomeLongRunningPieceOfWork();            
}

private void InitializeNHibernateSession()
{
   var path = ConfigurationManager.AppSettings["NHibernateConfig"];

   NHibernateSession.Init(
      new ThreadSessionStorage(),
      new string[] { "foo.Data.dll" },
      new AutoPersistenceModelGenerator().Generate(),
      "./App_Configuration/" + path);
}

关键是这个类，我从中得到的：

http://groups.google.com/group/sharp-architecture/browse_thread/thread/ce3d9c34bc2da629?fwc=1 http://groups.google.com/group/sharp-architecture/browse_thread/thread/51794671c91bc5e9/386efc30d4c0bf16#386efc30d4c0bf16

public class ThreadSessionStorage : ISessionStorage
{
    [ThreadStatic]
    private static ISession _session;
    public ISession Session
    {
        get
        {
            return _session;
        }
        set
        {
            _session = value;
        }
    }

    public ISession GetSessionForKey(string factoryKey)
    {
        return Session;
    }

    public void SetSessionForKey(string factoryKey, ISession session)
    {
        Session = session;
    }

    public IEnumerable<ISession> GetAllSessions()
    {
        return new List<ISession>() { Session };
    }
}

而且效果很好。

【讨论】：