使用Castle.Windsor实现UnitOfWork

Question

简单的问题.

如何将UnitOfWork与Castle.Windsor,nHibernate和ASP.NET MVC一起使用？

现在为扩展细节.在我理解UnitOfWork模式的过程中,我很难遇到任何使用直接示例的东西Castle.Windsor,特别是在需要安装的方式方面.

到目前为止,这是我的理解.

IUnitOfWork

• 该IUnitOfWork接口用于声明模式
• 的UnitOfWork类必须Commit和Rollback交易,以及暴露一个Session.

所以说,这是我的IUnitOfWork.(我正在使用Fluent nHibernate)

public interface IUnitOfWork : IDisposable
{
    ISession Session { get; private set; }
    void Rollback();
    void Commit();
}

所以这是我的Castle.WindsorContainer Bootstrapper(ASP.NET MVC)

public class WindsorContainerFactory
{
    private static Castle.Windsor.IWindsorContainer container;
    private static readonly object SyncObject = new object();

    public static Castle.Windsor.IWindsorContainer Current()
    {
        if (container == null)
        {
            lock (SyncObject)
            {
                if (container == null)
                {
                    container = new Castle.Windsor.WindsorContainer();

                    container.Install(new Installers.SessionInstaller());
                    container.Install(new Installers.RepositoryInstaller());
                    container.Install(new Installers.ProviderInstaller());
                    container.Install(new Installers.ControllerInstaller());
                }
            }

        }

        return container;
    }
}

所以现在,在我的Global.asax文件中,我有以下内容......

    protected void Application_Start()
    {
        AreaRegistration.RegisterAllAreas();

        RegisterGlobalFilters(GlobalFilters.Filters);
        RegisterRoutes(RouteTable.Routes);

        // Register the Windsor Container
        ControllerBuilder.Current
            .SetControllerFactory(new Containers.WindsorControllerFactory());
    }

知识库

现在我知道我需要将其传递ISession给我的存储库.那么,让我假设IMembershipRepository.

class MembershipRepository : IMembershipRepository
{
   private readonly ISession session;
   public MembershipRepository(ISession session)
   {
      this.session = session;
   }

   public Member RetrieveMember(string email)
   {
      return session.Query<Member>().SingleOrDefault( i => i.Email == email );
   }
}

所以我很困惑,现在.使用这种方法,ISession不会被正确销毁,UnitOfWork永远不会被使用.

我被告知UnitOfWork需要进入Web请求级别 - 但我找不到任何解释如何实际解决这个问题.我不使用ServiceLocator任何一种(当我尝试时,我被告知这也是不好的做法......).

困惑 - 如何UnitOfWork创建？

一般来说,我只是不明白这一点.我的想法是我会开始UnitOfWork进入 Repository构造函数 - 但如果它必须进入Web请求,我不理解这两者的关系.

进一步代码

这是额外的澄清代码,因为我似乎习惯于从不为我的问题提供正确的信息.

安装程序

public class ControllerInstaller : IWindsorInstaller
{
    public void Install(IWindsorContainer container, IConfigurationStore store)
    {
        container.Register(
            AllTypes.FromThisAssembly()
            .BasedOn<IController>()
            .Configure(c => c.LifeStyle.Transient));
    }
}

public class ProviderInstaller : IWindsorInstaller
{
    public void Install(IWindsorContainer container, IConfigurationStore store)
    {
        container.Register(
            Component
            .For<Membership.IFormsAuthenticationProvider>()
            .ImplementedBy<Membership.FormsAuthenticationProvider>()
            .LifeStyle.Singleton
        );
    }
}

public class RepositoryInstaller : IWindsorInstaller
{
    public void Install(IWindsorContainer container, IConfigurationStore store)
    {
        container.Register(
            Component
            .For<Membership.IMembershipRepository>()
            .ImplementedBy<Membership.MembershipRepository>()
            .LifeStyle.Transient
        );

        container.Register(
            Component
            .For<Characters.ICharacterRepository>()
            .ImplementedBy<Characters.CharacterRepository>()
            .LifeStyle.Transient
        );
    }
}

public class SessionInstaller : Castle.MicroKernel.Registration.IWindsorInstaller
{
    private static ISessionFactory factory;
    private static readonly object SyncObject = new object();

    public void Install(Castle.Windsor.IWindsorContainer container, IConfigurationStore store)
    {
        container.Register(
            Component.For<ISessionFactory>()
                .UsingFactoryMethod(SessionFactoryFactory)
                .LifeStyle.Singleton
            );

        container.Register(
            Component.For<ISession>()
            .UsingFactoryMethod(c => SessionFactoryFactory().OpenSession())
            .LifeStyle.Transient
        );
    }

    private static ISessionFactory SessionFactoryFactory()
    {
        if (factory == null)
            lock (SyncObject)
                if (factory == null)
                    factory = Persistence.SessionFactory.Map(System.Web.Configuration.WebConfigurationManager.ConnectionStrings["Remote"].ConnectionString);
        return factory;
    }
}

的UnitOfWork

这是我的UnitOfWork班级逐字.

public class UnitOfWork : IUnitOfWork
{
    private readonly ISessionFactory sessionFactory;
    private readonly ITransaction transaction;

    public UnitOfWork(ISessionFactory sessionFactory)
    {
        this.sessionFactory = sessionFactory;
        Session = this.sessionFactory.OpenSession();
        transaction = Session.BeginTransaction();
    }

    public ISession Session { get; private set; }

    public void Dispose()
    {
        Session.Close();
        Session = null;
    }

    public void Rollback()
    {
        if (transaction.IsActive)
            transaction.Rollback();
    }

    public void Commit()
    {
        if (transaction.IsActive)
            transaction.Commit();
    }
}

Answer 1

您的NH会议已经是一个工作单位http://nhforge.org/wikis/patternsandpractices/nhibernate-and-the-unit-of-work-pattern.aspx

所以我不确定为什么你需要进一步抽象出来.(如果有人读到这个答案知道为什么我会很高兴听到,我老实说从来没有听说过为什么你需要......)

我会实现一个简单的每个请求会话.我不知道你怎么会和温莎这样做,因为我从来没有使用它,但是使用StructureMap相当简单.

我将结构图工厂包装起来以保存我的会话工厂,并根据需要将会话注入存储库.

    public static class IoC
    {
        static IoC()
        {
            ObjectFactory.Initialize(x =>
            {
                x.UseDefaultStructureMapConfigFile = false;

                // NHibernate ISessionFactory
                x.ForSingletonOf<ISessionFactory>()
                 .Use(new SessionFactoryManager().CreateSessionFactory());

                // NHibernate ISession
                x.For().HybridHttpOrThreadLocalScoped()
                 .Use(s => s.GetInstance<ISessionFactory>().OpenSession());

                x.Scan(s => s.AssembliesFromApplicationBaseDirectory());
            });

            ObjectFactory.AssertConfigurationIsValid();
        }

        public static T Resolve<T>()
        {
            return ObjectFactory.GetInstance<T>();
        }

        public static void ReleaseAndDisposeAllHttpScopedObjects()
        {
            ObjectFactory.ReleaseAndDisposeAllHttpScopedObjects();
        }
    }

在Request_End上的global.asax文件中,我调用ReleaseAndDisposeAllHttpScopedObjects()方法.

        protected void Application_EndRequest(object sender, EventArgs e)
        {
            IoC.ReleaseAndDisposeAllHttpScopedObjects();
        }

因此,当我调用我的第一个存储库时会话被打开,并且当请求结束时它被处理掉了.存储库有一个构造函数,它接受ISession并将其分配给一个属性.然后我就像解决回购一样:

var productRepository = IoC.Resolve<IProductRepository>();

希望有所帮助.还有很多其他的方法,这对我有用.