確保NHibernate SessionFactory只創建一次

Question

我寫了一個NHibernateSessionFactory類，它包含一個靜態的Nhibernate ISessionFactory。這用於確保我們只有一個會話工廠，並且第一次調用OpenSession（）時，我創建了實際的SessionFactory - 下次我使用它並在其上打開一個會話。代碼如下所示：

public class NhibernateSessionFactory : INhibernateSessionFactory 
{ 
    private static ISessionFactory _sessionFactory; 

    public ISession OpenSession() 
    { 
     if (_sessionFactory == null) 
     { 
      var cfg = Fluently.Configure(). 
       Database(SQLiteConfiguration.Standard.ShowSql().UsingFile("Foo.db")). 
       Mappings(m => m.FluentMappings.AddFromAssemblyOf<MappingsPersistenceModel>()); 
      _sessionFactory = cfg.BuildSessionFactory(); 
      BuildSchema(cfg); 
     } 
     return _sessionFactory.OpenSession(); 
    } 

    private static void BuildSchema(FluentConfiguration configuration) 
    { 
     var sessionSource = new SessionSource(configuration); 
     var session = sessionSource.CreateSession(); 
     sessionSource.BuildSchema(session);    
    } 
} 

現在我遇到了問題。我的應用程序分爲客戶端和服務器端。 Nhibernate的東西在服務器端。在啓動時，我的客戶端和服務器都希望通過一些使用NhibernateSessionFactory的服務來訪問數據庫。結果是在請求來自客戶端之前是否創建_sessionFactory的爭用條件。如果不是，它會失敗..

我想我需要在NhibernateSessionFactory某種排隊或等待機制，但我不知道該怎麼做。任何人都有過同樣的問題？什麼是最好的解決方案？

Answer 1

sessionFactory必須是線程安全的單例。

Java中的一種常見模式是在靜態初始化器中構建sessionFactory。見HibernateUtil。你可以在C＃中做同樣的事情。

還有其他patterns來實現單例，包括使用鎖定或同步部分。如果我正確地理解了這個問題，那麼應該解決你的問題。

static readonly object factorylock = new object(); 

public ISession OpenSession() 
{ 
    lock (factorylock) 
    { 
     if (_sessionFactory == null) 
     { 
      var cfg = Fluently.Configure(). 
       Database(SQLiteConfiguration.Standard.ShowSql().UsingFile("Foo.db")). 
       Mappings(m => m.FluentMappings.AddFromAssemblyOf<MappingsPersistenceModel>()); 
      _sessionFactory = cfg.BuildSessionFactory(); 
      BuildSchema(cfg); 
     } 
    } 
    return _sessionFactory.OpenSession(); 
} 

Answer 2

我在創建SessionFactory時使用Mutex解決了這個問題。這看起來是否合理：

public class NhibernateSessionFactory : INhibernateSessionFactory 
{ 
    private static ISessionFactory _sessionFactory; 
    private static Mutex _mutex = new Mutex(); // <-- Added 

    public ISession OpenSession() 
    { 
     if (_sessionFactory == null) 
     { 
      _mutex.WaitOne();    // <-- Added 
      if (_sessionFactory == null) // <-- Added 
      {        // <-- Added 
       var cfg = Fluently.Configure(). 
        Database(SQLiteConfiguration.Standard.ShowSql().UsingFile("Foo.db")). 
        Mappings(m => m.FluentMappings.AddFromAssemblyOf<MappingsPersistenceModel>()); 
       _sessionFactory = cfg.BuildSessionFactory(); 
       BuildSchema(cfg); 
      }        // <-- Added 
      _mutex.ReleaseMutex();   // <-- Added 

     } 
     return _sessionFactory.OpenSession(); 
    } 

    private static void BuildSchema(FluentConfiguration configuration) 
    { 
     var sessionSource = new SessionSource(configuration); 
     var session = sessionSource.CreateSession(); 
     sessionSource.BuildSchema(session);    
    } 
} 

似乎工作就像一個魅力。但是，我應該使用鎖嗎？