c# – DB ConnectionState = Open但context.SaveChanges抛出“连接中断”异常

2023年11月18日 233次阅读

在我的服务中,我有一个后台线程,它尽最大努力保存某个实体类型的对象流.代码大致如下：

        while (AllowRun)
        {
            try
            {
                using (DbContext context = GetNewDbContext())
                {
                    while (AllowRun && context.GetConnection().State == ConnectionState.Open)
                    {
                        TEntity entity = null;
                        try
                        {
                            while (pendingLogs.Count > 0)
                            {
                                lock (pendingLogs)
                                {
                                    entity = null;
                                    if (pendingLogs.Count > 0)
                                    {
                                        entity = pendingLogs[0];
                                        pendingLogs.RemoveAt(0);
                                    }
                                }

                                if (entity != null)
                                {
                                    context.Entities.Add(entity);
                                }
                            }
                            context.SaveChanges();
                        }
                        catch (Exception e)
                        {
                            // (1)
                            // Log exception and continue execution
                        }
                    }
                }
            }
            catch (Exception e)
            {
               // Log context initialization failure and continue execution
            }
        }

(这主要是实际的代码,我省略了几个不相关的部分,试图将弹出的对象保留在内存中,直到我们能够在(1)块捕获异常时再次将内容保存到DB)

所以,基本上,有一个无限循环,试图从一些列表中读取项目并将它们保存到Db.如果我们检测到与DB的连接由于某种原因失败,它只是尝试重新打开并继续.问题是有时候(我到目前为止还没弄清楚如何重现它),上面的代码在调用context.SaveChanges()时开始产生以下异常(在(1)块中捕获)：

System.Data.EntityException: An error occurred while starting a transaction on the provider connection. See the inner exception for details. ---> 
System.InvalidOperationException: The requested operation cannot be completed because the connection has been broken.

记录错误,但是当执行返回到context.GetConnection().State == ConnectionState.Open check时,它的计算结果为true.因此,当上下文报告其数据库连接已打开时,我们处于一种状态,但我们无法针对该上下文运行查询.重新启动服务可以解决问题(以及在调试器中弄乱AllowRun变量以强制重新创建上下文).所以问题是因为我不能信任上下文的连接状态,我如何验证我可以对DB运行查询？

还有,有一种干净的方法可以确定连接是否处于“健康”状态？我的意思是,EntityException本身并不表示我应该重置连接,只有当它的InnerException是带有一些特定Message的InvalidOperationException时,是的,是时候重置它了.但是,现在我想在ConnectionState指示一切正常时会有其他情况,但我无法查询数据库.我可以主动抓住这些,而不是等到它开始咬我？

最佳答案 日志频率是多少？

如果此循环花费的时间超过连接超时,则在savechanges执行时连接关闭.

while (pendingLogs.Count > 0)
{
     lock (pendingLogs)
     {
          entity = null;
          if (pendingLogs.Count > 0)
          {
             entity = pendingLogs[0];
             pendingLogs.RemoveAt(0);
          }
     }

     if (entity != null)
     {
          context.Entities.Add(entity);
     }
}
context.SaveChanges();
点赞