问题 加载实体时的nhibernate竞争条件


我的webapp中存在nhibernate竞争条件的问题。

我知道在使用旧版本的log4net时会发生这种情况（应该在1.2.10中修复），尽管我也经历过这种情况。因此我们暂时禁用了log4net，因为竞争条件导致IIS崩溃，并且在生产中发生这种情况是不可接受的。这在加载实体时发生（请参阅下面的stacktrace）。除此之外，RavenDB中似乎也出现了类似的问题，请参阅此内容 链接，这里没有NHibernate的例子 链接。

堆栈跟踪：

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，但这很难重现），并且fluentNhibernate用于我的映射。

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块中打开和关闭命令会话。

根据stacktrace，问题出现在StreamWriter - > System.Buffer中，System.IO.SyncTextWriter再次调用它，它应该是System.IO.TextWriter的线程安全包装器。

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

以我在DynamicPage中的方式打开和关闭会话是否安全？

由于这显然难以复制，所以关于如何做到这一点的任何想法也是受欢迎的。

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

但是没有确定的方法来测试它是否能解决问题。


4044
2017-09-28 11:05


起源
我对这篇SO文章感兴趣。在堆栈跟踪中，您有： - SessionInit.GetCurrentUser(ISession session) in j:\dev\app\app_wwwroot\App_Code\SessionInit.cs:107   SessionInit.cs代码中有什么？ - Nick Ryan
尼克，我添加了SessionInit.GetCurrentUser（）的代码。查看更新。 - Stamppot
我在NHibernate的同一个地方偶尔也会遇到这个问题 - 你是否设法确定如何修复？ - David Duffett
不，我不知道从哪里开始创建测试用例，或者是什么导致它。你有一个代码片段来显示它发生的位置吗？是在请求的开头还是随机的某个地方？对我来说，它总是在SessionInit中触发，它创建当前用户。这是在其他页面继承的处理程序或页面中完成的，因此在请求的早期。 - Stamppot

答案:

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

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)); 
}

细节：在我们的例子中，“可能的竞争条件......”错误与负载有关。在生产服务器上，偶尔会出现此异常，每次都会导致工作进程崩溃。最后，我们通过运行一个脚本，在短时间内使用很多请求充斥webapp，我们发现了如何重现它。当与NHibernate / StringTemplate / log4net源代码相关联时，异常堆栈跟踪指向使用Console.Out / Error方法记录各种情况。看起来像是出现这种错误的奇怪地方---不是这些方法 被认为是线程安全的？ 但是，在我们应用上述解决方法之后，问题立即消失并且从那时起就没有返回。不幸的是，其他优先事项使我们无法深入挖掘---但无论问题的根本原因是什么，它都没有以任何其他方式表现出来。


12
2018-05-01 06:51


awk，谢谢你的“修复”。如果它让错误消失，我很高兴。 - Stamppot
顺便说一句，你每次运行脚本时都可以重现它吗？有关它的任何细节，如多少请求多长时间等？如果可能的话，脚本本身也会很好。 - Stamppot
@APW：我们最近将log4net升级到1.2.12时出现了这个问题。不知道为什么写入Console Out会这样做。您的修复程序将全局禁用控制台日志记录，这将最终解决问题。您可以做的另一个（不太全局）的事情是确保在NHibernate的情况下，“show_sql”配置选项设置为false。 show_sql写道 直 控制台输出，完全独立于log4net。我认为这是引起OP所遇问题的具体案例。 - Jonathan W

@APW提供的解决方案的问题是默认情况下，StreamWriter是 不是线程安全的。在这里查看： https://msdn.microsoft.com/en-us/library/system.io.streamwriter(v=vs.110).aspx

通过将“new StreamWriter”传递给Console.Set *，您将传递非线程安全实例。所以我认为再次看到类似错误是时间问题。

正确的方式将使用 TextWriter.Synchronized 包装不安全的Stream.Null的方法。

using System.IO;
...
var nullStream = TextWriter.Synchronized(TextWriter.Null);
Console.SetOut(nullStream);
Console.SetError(nullStream);

UPD：请忽略这一点。我发现Console.SetOut将任何流包装到TextWriter.Synchronized（...）中。 证明。


0
2017-12-23 14:55



热门问题

不使用eval / new函数的JavaScript模板库 当涉及内部类时，Java继承如何工作 .NET Windows服务的奇怪问题 在.ipa或.app下查找App ID 快速入门XSLT参考[关闭] 如何找出Android应用程序中未使用的资源 Ruby中并发的同步方法[重复] 将std :: chrono :: system_clock :: time_point转换为struct timeval并返回 Google Drive API V3（javascript）更新文件内容 Bootstrap 3.0 - 将元素推到底部 受密码保护的.NET ClickOnce部署？ 如何用postgresql安装wordpress coq Set或Type如何成为命题 硒滚动元素进入（中心）视图 在Spring Transaction JUnit测试中自动装配Hibernate会话的正确方法 Git的Dockerfile策略 如何在FOS_PICKFOLDER中使用IFileDialog，同时仍在对话框中显示文件名 在Firefox扩展中复制Google Chrome浏览器操作弹出效果 CakePHP找到MAX 芹菜 - 完成任务的召唤功能 从使用fmemopen创建的流中读取宽字符 .NET是否为每个程序集创建一个字符串实习池？ DefaultModelBinder不绑定嵌套模型 Navigator.MediaDevices.getUserMedia（）使用了哪些相机通信标准？ 选择命名空间名称时应该知道什么？ cout Swagger Codegen CLI Java客户端 - 如何正确使用它 一个很好的哈希函数用于采访整数，字符串？ Maven 3 ciManagement配置的目的是什么？ 如何通过语言文化获取代码页？
licensed under cc by-sa 3.0 with attribution.
隐私政策 往来