DB ConnectionState =打开但上下文.SaveChanges抛出“连接断开”;例外

在我的服务中，我有一个后台线程，它尽最大努力保存特定实体类型的对象流。代码大致如下:

        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检查时，它的评估结果为true。因此，当上下文报告其DB连接打开时，我们处于这样一种状态，但我们不能对该上下文运行查询。重新启动服务可以消除这个问题(以及在调试器中使用AllowRun变量来强制重新创建上下文)。所以问题是，既然我不能信任上下文的连接状态，我如何验证我可以对数据库运行查询?

还有，是否有一种干净的方法来确定连接是否处于"健康"状态?我的意思是，EntityException本身并不是一个指示，我应该重置连接，只有当它的InnerException是InvalidOperationException与一些特定的消息，那么是的，是时候重置它了。但是，现在我猜会有其他情况，当ConnectionState表明一切都很好，但我不能查询DB。我能否主动抓住它们，而不是等到它们开始咬我?

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

SELECT 
    DB_NAME(dbid) as DBName, 
    COUNT(dbid) as NumberOfConnections,
    loginame as LoginName
FROM
    sys.sysprocesses
WHERE 
    dbid > 0
GROUP BY 
    dbid, loginame

while (AllowRun)
    {
        try
        {
            while (pendingLogs.Count > 0)
            {
                using (DbContext context = GetNewDbContext())
                {
                    while (AllowRun && context.GetConnection().State == ConnectionState.Open)
                    {
                        TEntity entity = null;
                        try
                        {
                            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
        }
    }