NServiceBus: реализация NhibernateMessageModule - PullRequest
Новая
       12

NServiceBus: реализация NhibernateMessageModule

0 голосов
/ 03 апреля 2012

Я использую NserviceBus 2.5 и столкнулся с проблемой NSB кеширования сессий Nhibernate.Я провел некоторое время в Интернете и обнаружил, что класс, реализующий интерфейс IMessageModule, является способом решения этой проблемы.Я также видел реализацию такого в https://github.com/NServiceBus/NServiceBus/blob/v2.5/src/impl/SagaPersisters/NHibernateSagaPersister/NServiceBus.SagaPersisters.NHibernate/NHibernateMessageModule.cs

MyEndPoint определен как 

public class EndpointConfig : IConfigureThisEndpoint, AsA_Server, IWantCustomLogging, IWantCustomInitialization
{
    public void Init()
    {
        var location = Path.GetDirectoryName(Assembly.GetExecutingAssembly().GetName().CodeBase);

        var windsorContainer = IoCBootstrapper.InitializeForSession(Path.Combine(location, "MyDll.config")); //This line creates Windsor container without Nhibernate Session I have not written real dll.config name  but my code contains


        ISessionFactory sessionFactory = MessageSessionFactory.ConfigureSessionFactory();
        windsorContainer.Kernel.AddComponentInstance<ISessionFactory>(sessionFactory);
        windsorContainer.Register(Component.For(typeof(NHibernateMessageModule)).LifeStyle.Singleton);
        windsorContainer.Register(Component.For(typeof(MessageHandler)).LifeStyle.Transient);


        NServiceBus.Configure.With(AllAssemblies.Except("XYZ.dll"))
            .CastleWindsorBuilder(windsorContainer)
            .XmlSerializer()
            .MsmqTransport()
            .UnicastBus()
            .LoadMessageHandlers();

        SetLoggingLibrary.Log4Net(log4net.Config.XmlConfigurator.Configure);
    }


}

Я определил следующий класс для создания открытого класса SessionFactory MessageSessionFactory {protected static ISessionFactory sessionFactory;приватный статический ILog log = LogManager.GetLogger (typeof (MessageSessionFactory)); 

    public static ISessionFactory ConfigureSessionFactory()
    {
        try
        {
            if (sessionFactory != null) return sessionFactory;

            string connectionString = System.Configuration.ConfigurationManager
                              .ConnectionStrings["SessionFactoryCS"].ToString();
            NHibernate.Cfg.Configuration nHibernateConfiguration =
                                                  new NHibernate.Cfg.Configuration();
            nHibernateConfiguration.SetProperty(
              NHibernate.Cfg.Environment.ProxyFactoryFactoryClass,
              typeof(NHibernate.ByteCode.Castle.ProxyFactoryFactory).AssemblyQualifiedName);
            nHibernateConfiguration.SetProperty(
              NHibernate.Cfg.Environment.Dialect,
              typeof(NHibernate.Dialect.MsSql2005Dialect).AssemblyQualifiedName);
            nHibernateConfiguration.SetProperty(
              NHibernate.Cfg.Environment.ConnectionString, connectionString);
            nHibernateConfiguration.SetProperty(
              NHibernate.Cfg.Environment.FormatSql, "true");
            nHibernateConfiguration.SetProperty(NHibernate.Cfg.Environment.CurrentSessionContextClass,
                                              typeof(NHibernate.Context.ThreadStaticSessionContext).AssemblyQualifiedName);
            nHibernateConfiguration.AddAssembly(Assembly.GetCallingAssembly());

            sessionFactory = nHibernateConfiguration
                                                    .BuildSessionFactory();
            return sessionFactory;
        }
        catch (TypeInitializationException ex)
        {
            throw new Exception("TO DO :Enter message");
        }
    }




}

Когда бы я ни пытался запустить службу, я вижу сообщения, как в HandleEndMessage NHibernate.HibernateException: не настроен текущий контекст сеанса.в NHibernate.Context.CurrentSessionContext.GetCurrentSessionContext (фабрика ISessionFactory) в NHibernate.Context.CurrentSessionContext.HasBind (фабрика ISessionFactory)

Если я здесь улавливаю исключение, то эта ошибка переходит к HandleError

*кто-нибудь скажет мне, где я могу ошибаться?

1 Ответ

0 голосов
/ 04 апреля 2012

это сообщение означает, что вы не настроили nhibernate, чтобы сообщить ему, как использовать контекстные сеансы. функция контекстных сеансов nhibernate означает, что nhibernate будет управлять отслеживанием текущего сеанса для вас, и вам нужно только беспокоиться о привязке и откреплении текущего сеанса к / из контекста и всякий раз, когда вы запрашиваете фабрику сеанса для текущего сеанса в этом контекст, вы получите тот же. модуль сообщений, который написал andreas, использует эту функцию (и вы должны это делать в своих обработчиках, если именно так вы управляете своими сеансами - это означает, что если у вас есть зависимость в ваших классах обработчиков от ISessionFactory и вы получаете сеансы оттуда, вы должны использовать ISessionFactory.GetCurrentSession () вместо ISessionFactory.OpenSesion ()).

Чтобы исправить возникшую проблему, вы должны указать NHibernate, как управлять контекстом сеанса. Есть несколько встроенных опций. тот, кого Андреас рекомендует в своем блоге, - ThreadStatic. это нормально в вашем случае, так как кажется, что вы подключаетесь только к одной базе данных и используете одну фабрику сеансов. обратите внимание, что этот контекстный класс поддерживает только одну фабрику сеансов, поэтому он не будет работать, если вы имеете дело с более чем одним. «Статический поток» означает, что каждый поток будет иметь свой собственный контекст сеанса - вы получите один и тот же сеанс, если вы находитесь в одном потоке. это прекрасно работает с nservicebus, так как обработчик будет полностью выполняться в потоке, а модуль сообщений будет следить за тем, чтобы вы получали новый сеанс с каждым сообщением и не использовали тот же, что и в предыдущем сообщении, обработанном этим потоком.

чтобы настроить nhibernate для этого, вам нужно установить свойство current_session_context_class равным thread_static. если вы настраиваете nhibernate напрямую, вы знаете, как вы это делаете. если вы используете свободный nhibernate, вам потребуется метод FluentConfiguration.ExposeConfiguration, чтобы сделать это: 

Fluently.Configure()
  // whatever else you are doing
  .ExposeConfiguration(
     c => c.SetProperty("current_session_context_class", "thread_static")
    );

вот пост Андреаса об этом: http://andreasohlund.net/2010/02/03/nhibernate-session-management-in-nservicebus/

...