加载实体时的 nhibernate 竞争条件

我的网络应用程序中存在休眠竞争条件问题。

我知道在使用旧版本的 log4net 时会发生这种情况（应该在 1.2.10 中修复），尽管我也经历过这种情况。因此，我们暂时禁用了 log4net，因为竞争条件会导致 IIS 崩溃，并且在生产中发生这种情况是不可接受的。加载实体时会发生这种情况（请参阅下面的堆栈跟踪）。除此之外，RavenDB中似乎也出现了类似的问题，请参阅此link https://groups.google.com/forum/?fromgroups=#!topic/ravendb/lxb_hn74ewg，以及这里没有 NHibernate 的示例link http://www.syncfusion.com/support/forums/grid-windows/76832.

堆栈跟踪：

Server Error in '/' Application.
Probable I/O race condition detected while copying memory. The I/O package is not thread safe by default. In multithreaded applications, a stream must be accessed in a thread-safe way, such as a thread-safe wrapper returned by TextReader's or TextWriter's Synchronized methods. This also applies to classes like StreamWriter and StreamReader.
Description: An unhandled exception occurred during the execution of the current web request. Please review the stack trace for more information about the error and where it originated in the code.

Exception Details: System.IndexOutOfRangeException: Probable I/O race condition detected while copying memory. The I/O package is not thread safe by default. In multithreaded applications, a stream must be accessed in a thread-safe way, such as a thread-safe wrapper returned by TextReader's or TextWriter's Synchronized methods. This also applies to classes like StreamWriter and StreamReader.

Source Error:


Line 105:
Line 106:                if(webUser.Id > 0) { // logged in
Line 107:                    _user = session.Get<User>(webUser.Id);
Line 108:                    if(_user == null) { // session exists, but no user in DB with this id
Line 109:                        new SessionInit().Remove();


Source File: \App_Code\SessionInit.cs    Line: 107

Stack Trace:


[IndexOutOfRangeException: Probable I/O race condition detected while copying memory. The I/O package is not thread safe by default. In multithreaded applications, a stream must be accessed in a thread-safe way, such as a thread-safe wrapper returned by TextReader's or TextWriter's Synchronized methods. This also applies to classes like StreamWriter and StreamReader.]
   System.Buffer.InternalBlockCopy(Array src, Int32 srcOffsetBytes, Array dst, Int32 dstOffsetBytes, Int32 byteCount) +0
   System.IO.StreamWriter.Write(Char[] buffer, Int32 index, Int32 count) +117
   System.IO.TextWriter.WriteLine(String value) +204
   System.IO.SyncTextWriter.WriteLine(String value) +63
   NHibernate.AdoNet.AbstractBatcher.ExecuteReader(IDbCommand cmd) +71
   NHibernate.Loader.Loader.GetResultSet(IDbCommand st, Boolean autoDiscoverTypes, Boolean callable, RowSelection selection, ISessionImplementor session) +580
   NHibernate.Loader.Loader.DoQuery(ISessionImplementor session, QueryParameters queryParameters, Boolean returnProxies) +275
   NHibernate.Loader.Loader.DoQueryAndInitializeNonLazyCollections(ISessionImplementor session, QueryParameters queryParameters, Boolean returnProxies) +205
   NHibernate.Loader.Loader.LoadEntity(ISessionImplementor session, Object id, IType identifierType, Object optionalObject, String optionalEntityName, Object optionalIdentifier, IEntityPersister persister) +590

[GenericADOException: could not load an entity: [app.Presentation.User#338][SQL: SELECT user0_.userID as userID24_0_, user0_.instituteID as institut2_24_0_, user0_.email as email24_0_, user0_.password as password24_0_, user0_.username as username24_0_, user0_.mod_remarks as mod6_24_0_, user0_.lastLogin as lastLogin24_0_, user0_.active as active24_0_, user0_.isAcademic as isAcademic24_0_, user0_.created as created24_0_, (select p.firstName from ej_profile p where p.userID = user0_.userID) as formula11_0_, (select p.lastName from ej_profile p where p.userID = user0_.userID) as formula12_0_, (select p.timeZone from ej_profile p where p.userID = user0_.userID) as formula13_0_ FROM ej_user user0_ WHERE user0_.userID=?]]
   NHibernate.Loader.Loader.LoadEntity(ISessionImplementor session, Object id, IType identifierType, Object optionalObject, String optionalEntityName, Object optionalIdentifier, IEntityPersister persister) +960
   NHibernate.Loader.Entity.AbstractEntityLoader.Load(ISessionImplementor session, Object id, Object optionalObject, Object optionalId) +76
   NHibernate.Loader.Entity.AbstractEntityLoader.Load(Object id, Object optionalObject, ISessionImplementor session) +32
   NHibernate.Event.Default.DefaultLoadEventListener.LoadFromDatasource(LoadEvent event, IEntityPersister persister, EntityKey keyToLoad, LoadType options) +173
   NHibernate.Event.Default.DefaultLoadEventListener.Load(LoadEvent event, IEntityPersister persister, EntityKey keyToLoad, LoadType options) +181
   NHibernate.Event.Default.DefaultLoadEventListener.OnLoad(LoadEvent event, LoadType loadType) +1019
   NHibernate.Impl.SessionImpl.FireLoad(LoadEvent event, LoadType loadType) +403
   NHibernate.Impl.SessionImpl.Get(String entityName, Object id) +469
   NHibernate.Impl.SessionImpl.Get(Type entityClass, Object id) +374
   NHibernate.Impl.SessionImpl.Get(Object id) +391
   SessionInit.GetCurrentUser(ISession session) in j:\dev\app\app_wwwroot\App_Code\SessionInit.cs:107
   DynamicPage.OnPreInit(EventArgs e) in j:\dev\app\app_wwwroot\App_Code\DynamicPage.cs:24
   MemberPage.OnPreInit(EventArgs e) in j:\dev\app\app_wwwroot\App_Code\MemberPage.cs:20
   members_stocks_Default.OnPreInit(EventArgs e) in j:\dev\app\app_wwwroot\members\Default.aspx.cs:28
   System.Web.UI.Page.PerformPreInit() +49
   System.Web.UI.Page.ProcessRequestMain(Boolean includeStagesBeforeAsyncPoint, Boolean includeStagesAfterAsyncPoint) +1716

用户的映射：

public class UserViewMapping : ClassMap<User>
{
    public UserViewMapping() {
        Table("ej_user");
        Id(s => s.Id, "userID").GeneratedBy.Native();
        Map(s => s.InstituteId, "instituteID");
        Map(s => s.Email, "email");
        Map(s => s.Password, "password");
        Map(s => s.Name, "username");
        Map(s => s.ModRemarks, "mod_remarks");
        Map(s => s.LastLogin, "lastLogin");
        Map(s => s.Active, "active");
        Map(s => s.IsAcademic, "isAcademic");
        Map(s => s.Created, "created");
        Map(s => s.FirstName).Formula("(select p.firstName from ej_profile p where p.userID = userID)");
        Map(s => s.LastName).Formula("(select p.lastName from ej_profile p where p.userID = userID)");
        Map(s => s.TimeZone).Formula("(select p.timeZone from ej_profile p where p.userID = userID)");
        HasMany<ProfileViewModel>(s => s.Profiles)
            .Table("ej_profile")
            .KeyColumn("userID")
            .Cascade.All()
            .Inverse();
}

一些细节：我使用两个会话来进行查询和命令（以及两个会话工厂），因为我使用了有点类似于 CQRS 的模式。一个会话用于读取对象，一个会话用于进行更改（这有助于我保持域模型简单，并查看模型和映射可能与命令模型不同）。

在我的开发环境（单用户）中加载用户视图模型时发生竞争条件，但我们确保这在生产中永远不会发生，因为它使 IIS 7 崩溃。此外，在生产中会有多个用户，所以可能会出现错误可能会更频繁地发生。

此外，我们还有很多使用 System.Data 和 MySql.Data.MySqlClient.MySqlDataAdapter 来读取/写入数据库的遗留代码。这能有影响吗？

我正在使用 NHibernate 3.1.0（将升级到 3.3.1GA，但这很难重现），并使用 fluenceNhibernate 进行映射。

sessionfactories 在 global.asax 中创建：

void Application_Start(object sender, EventArgs e)
{
    QuerySessionFactory.Create(connectionString);
    CommandSessionManager.Initialize(connString);
}

我的页面继承自打开和关闭查询会话的 DynamicPage：

public class DynamicPage : System.Web.UI.Page
{
    protected override void OnPreInit(EventArgs e)
    {
        Session = QuerySessionFactory.Instance.OpenSession();
    }

    protected override void OnUnload(EventArgs e) {
        base.OnUnload(e);
        Session.Close();
    }
}

在 SessionInit 中（从 httpcontext.session 读取 userID，并创建一个“webuser”，即具有一些简单信息（如 userId）的用户）。后来，我把锁放在周围并在事务中完成了用户获取请求，不确定它是否有用。

    public IUser GetCurrentUser(ISession session) {
        if(_user == null) { 
            var webUser = new SessionInit().Get;

            if(webUser.Id > 0) { // logged in
                lock(_lock) {
                    using(var tx = session.BeginTransaction()) {
                        _user = session.Get<User>(webUser.Id);
                        tx.Commit();
                    }
                }
                if(_user == null) { // session exists, but no user in DB with this id
                    new SessionInit().Remove();
                }
                ((User)_user)._currentUser = webUser;
            } else {
                if(webUser is CurrentUser && webUser.Id == 0) {
                    if(HttpContext.Current.Session != null) {
                        HttpContext.Current.Response.Cookies.Remove("ASPSESSID");
                        HttpContext.Current.Request.Cookies.Remove("ASPSESSID");
                        HttpContext.Current.Session.RemoveAll();
                        HttpContext.Current.Session.Abandon();
                    }

                    if(HttpContext.Current.Request.Url.Host.Contains("members"))
                        HttpContext.Current.Response.Redirect("/login");
                } else
                    if(webUser.Id == 0) {
                        var userId   = webUser.Id;
                        var userName = webUser.UserName;
                        var loginUrl = webUser.LoginUrl;
                        var clientIp = webUser.ClientIp;
                        var isAdmin  = webUser.IsAdmin();
                        return new eLab.Presentation.Visitor(userId, userName, loginUrl, clientIp, isAdmin, webUser.Theme); 
                    }
            }
            if (_user == null)
                return new eLab.Presentation.Visitor(webUser.Id, webUser.UserName, webUser.LoginUrl, webUser.ClientIp, false, webUser.Theme);
        }
        return _user;
}

需要时，命令会话在 using 块中打开和关闭。

根据堆栈跟踪，问题发生在 StreamWriter -> System.Buffer 中，它再次被 System.IO.SyncTextWriter 调用，而 System.IO.SyncTextWriter 应该是 System.IO.TextWriter 周围的线程安全包装器。

由于这种情况发生在 TextWriter 中，有没有办法解决这个问题，使用线程安全的 TextWriter？

像我在 DynamicPage 中那样打开和关闭会话是否安全？

由于这显然很难重现，因此也欢迎任何有关如何做到这一点的想法。

[更新] NHibernate Profiler 告诉我们，我们还在母版页中打开和关闭了一个会话（在 using 块中），因为需要检查当前用户的某些权限，所以每个请求打开两个会话。我已经重构了它，所以现在它不是在页面超类中打开会话，而是在 Application_BeginRequest 上的 global.asax 中打开会话，并在 Application_EndRequest 上再次关闭它，其中会话放置在 HttpContext.Current.Items 中。

但没有确定的方法来测试这是否可以解决问题。

Stamppot，感谢您将这个问题发布到 StackOverflow；如您所知，在网络上找不到太多有关此错误消息的其他信息。几个月前，我的团队在一个使用 NHibernate 和 log4net 的 Web 应用程序中遇到了类似的问题。 （StringTemplate 也可能参与其中。）我们通过将 Console.Out/Error 重定向到 Global.ascx.cs 中的 Application_Start() 事件处理程序中的空流（有效地禁用它们）来“修复”该问题：

protected void Application_Start(object sender, EventArgs e)
{
    Console.SetOut(new System.IO.StreamWriter(System.IO.Stream.Null));
    Console.SetError(new System.IO.StreamWriter(System.IO.Stream.Null)); 
}

详细信息：在我们的例子中，“可能的竞争条件...”错误与负载有关。在生产服务器上，这种异常会偶尔出现，每次都会导致工作进程崩溃。最终我们找到了如何重现它，方法是运行一个脚本，在短时间内用大量请求淹没 Web 应用程序。当与 NHibernate/StringTemplate/log4net 源代码相关时，异常堆栈跟踪指出在各种情况下使用 Console.Out/Error 方法进行日志记录。出现这样的错误似乎是一个奇怪的地方——这些方法不是吗？被认为是线程安全的？ https://stackoverflow.com/questions/1079980/calling-console-writeline-from-multiple-threads但是，在我们应用上述解决方法后，问题立即消失，并且此后再也没有出现过。不幸的是，其他优先事项使我们无法深入挖掘——但无论问题的根本原因是什么，它都没有以任何其他方式表现出来。