将 SharpArchitecture 的 NHibernateSession 与不同的线程结合使用

Question

我在 ASP.NET MVC 3 应用程序中使用 SharpArchitecture。一切都运转良好。

使用 SharpArchitecture 的 NHibernateInitializer 为每个请求初始化一个新会话，如下所示：

    protected void Application_BeginRequest(object sender, EventArgs e)
    {
        NHibernateInitializer.Instance().InitializeNHibernateOnce(InitializeNHibernateSession);
    }

    private void InitializeNHibernateSession(ISessionStorage sessionStorage)
    {
        NHibernateSession.ConfigurationCache = new NHibernateConfigurationFileCache(
            new[] { "App.Core" });
        NHibernateSession.Init(
            sessionStorage,
            new[] { Server.MapPath("~/bin/" + ApplicationSettings.Instance.NHibernateMappingAssembly) },
            new AutoPersistenceModelGenerator().Generate(),
            Server.MapPath("~/NHibernate.config"));

        NHibernateSession.AddConfiguration(ApplicationSettings.NHIBERNATE_OTHER_DB,
                                           new[] { Server.MapPath("~/bin/" + ApplicationSettings.Instance.NHibernateMappingAssembly) },
                                           new AutoPersistenceModelGenerator().Generate(),
                                           Server.MapPath("~/NHibernateForOtherDb.config"), null, null, null);
    }

正如您所看到的，我们还访问了多个数据库。一切都很好。

这是我遇到问题的地方。

我需要启动一个单独的线程来执行数据库轮询机制。我的意图是做这样的事情：

    protected void Application_Start()
    {
            ....
            ThreadingManager.Instance.ExecuteAction(() =>
            {
                // initialize another NHibernateSession within SharpArchitecture somehow
                NHibernateInitializer.Instance().InitializeNHibernateOnce(InitializeNHibernateSession);

                var service = container.Resolve<IDatabaseSynchronizationService>();
                service.SynchronizeRepositories();
            });
}

通过我的 SynchronizationService，一些存储库被调用。显然，当他们尝试访问会话时，会抛出异常，因为会话为空。

这是我的问题。我如何利用 SharpArchitecture 的 NHibernateSession 并以某种方式将它或它的副本在我的轮询线程中旋转？我希望这可以完成，而不必绕过使用 SharpArchitecture 使用的内置 SessionManagers 和 SessionFactories。

Answer 1

我假设 sessionStorage 是一个 SharpArch.Web.NHibernate.WebSessionStorage 对象，对吗？如果是这样，那么问题不在于 NHibernate Session 为 null，而可能是在您的线程上，HttpContext.Current 为 null，并且 WebSessionStorage 对象依赖 HttpContext.Current 来完成其工作（请参阅 这段代码，特别是第 37 行，当从线程调用时，上下文为 null，因此会发生 null 异常）。

我认为解决方案是编写一个不同的 SessionStorage 对象来检查 HttpContext.Current 是否为 null，如果是，则使用线程本地存储来存储 NHibernate Session（此解决方案来自于另一篇 StackOverflow 文章讨论了同样的事情：在Web应用程序Application_Start方法中初始化NServiceBus时出现NullReferenceException）

编辑

也许是这样的：

public class HybridWebSessionStorage : ISessionStorage
{

    static ThreadLocal<SimpleSessionStorage> threadLocalSessionStorage;

    public HybridWebSessionStorage( HttpApplication app )
    {
        app.EndRequest += Application_EndRequest;
    }

    public ISession GetSessionForKey( string factoryKey )
    {
        SimpleSessionStorage storage = GetSimpleSessionStorage();
        return storage.GetSessionForKey( factoryKey );
    }

    public void SetSessionForKey( string factoryKey, ISession session )
    {
        SimpleSessionStorage storage = GetSimpleSessionStorage();
        storage.SetSessionForKey( factoryKey, session );
    }

    public System.Collections.Generic.IEnumerable<ISession> GetAllSessions()
    {
        SimpleSessionStorage storage = GetSimpleSessionStorage();
        return storage.GetAllSessions();
    }

    private SimpleSessionStorage GetSimpleSessionStorage()
    {
        HttpContext context = HttpContext.Current;
        SimpleSessionStorage storage;
        if ( context != null )
        {
            storage = context.Items[ HttpContextSessionStorageKey ] as SimpleSessionStorage;
            if ( storage == null )
            {
                storage = new SimpleSessionStorage();
                context.Items[ HttpContextSessionStorageKey ] = storage;
            }
        }
        else
        {
            if ( threadLocalSessionStorage == null )
                threadLocalSessionStorage = new ThreadLocal<SimpleSessionStorage>( () => new SimpleSessionStorage() );
            storage = threadLocalSessionStorage.Value;
        }
        return storage;
    }

    private static readonly string HttpContextSessionStorageKey = "HttpContextSessionStorageKey";

    private void Application_EndRequest( object sender, EventArgs e )
    {
        NHibernateSession.CloseAllSessions();

        HttpContext context = HttpContext.Current;
        context.Items.Remove( HttpContextSessionStorageKey );
    }
}

注意：当你完成你的操作时，你必须确保调用 NHibernateSession.CloseAllSessions()不过，请在线程上工作，因为当线程完成时，Application_EndRequest 不会被触发。