连接复原和重试逻辑Connection resiliency and retry logic

连接复原和重试逻辑Connection resiliency and retry logic

备注

仅限 EF6 及更高版本 - 此页面中讨论的功能、API 等已引入实体框架 6。如果使用的是早期版本，则部分或全部信息不适用。

由于后端故障和网络不稳定，连接到数据库服务器的应用程序始终容易遭受连接中断。然而，在基于 LAN 的环境中，对于专用数据库服务器，这些错误很少发生，但通常不需要使用额外的逻辑来处理这些故障。随着基于云的数据库服务器（如 Microsoft Azure SQL 数据库）的增长以及通过不太可靠的网络进行的连接，现在更常见的连接中断。这可能是因为云数据库使用防御性技术来确保服务的公平，如连接限制，或导致间歇超时和其他暂时性错误的网络不稳定。

连接复原是指 EF 自动重试任何由于这些连接中断而失败的命令的功能。

执行策略Execution Strategies

连接重试由 IDbExecutionStrategy 接口的实现来处理。 IDbExecutionStrategy 的实现将负责接受一个操作，如果发生异常，则确定重试是否合适，如果是，则重试。 EF 附带四个执行策略：

DefaultExecutionStrategy：此执行策略不会重试任何操作，它是 sql server 以外的数据库的默认值。
DefaultSqlExecutionStrategy：这是默认情况下使用的内部执行策略。不过，这种策略根本不会重试，它将包装任何可能会暂时性的异常，以通知用户他们可能想要启用连接复原。
DbExecutionStrategy：此类适用于其他执行策略（包括你自己的自定义）的基类。它实现了一个指数重试策略，其中，初始重试会出现零延迟，延迟将以指数方式递增，直到达到最大重试计数。此类有一个抽象 ShouldRetryOn 方法，可在派生执行策略中实现该方法，以控制应重试哪些异常。
SqlAzureExecutionStrategy：此执行策略继承自 DbExecutionStrategy，并将在使用 Azure SQL 数据库时已知可能会暂时性的异常重试。

备注

执行策略2和4包含在 EF 附带的 Sql Server 提供程序中，后者位于 EntityFramework 程序集中，旨在与 SQL Server 配合使用。

启用执行策略Enabling an Execution Strategy

告诉 EF 使用执行策略的最简单方法是使用DbConfiguration类的 SetExecutionStrategy 方法：

public class MyConfiguration : DbConfiguration
{
    public MyConfiguration()
    {
        SetExecutionStrategy("System.Data.SqlClient", () => new SqlAzureExecutionStrategy());
    }
}

此代码告知 EF 在连接到 SQL Server 时使用 SqlAzureExecutionStrategy。

配置执行策略Configuring the Execution Strategy

SqlAzureExecutionStrategy 的构造函数可以接受两个参数： MaxRetryCount 和 MaxDelay。 MaxRetry count 是策略将重试的最大次数。 MaxDelay 是一个 TimeSpan，表示执行策略将使用的重试之间的最大延迟。

若要将最大重试次数设置为1，最大延迟为30秒，请执行以下操作：

public class MyConfiguration : DbConfiguration
{
    public MyConfiguration()
    {
        SetExecutionStrategy(
            "System.Data.SqlClient",
            () => new SqlAzureExecutionStrategy(1, TimeSpan.FromSeconds(30)));
    }
}

第一次发生暂时性故障时，SqlAzureExecutionStrategy 会立即重试，但会在每次重试之间延迟更长的时间，直到超过最大重试限制或总时间达到最大延迟。

执行策略只会重试有限数量的异常，这些异常通常是暂时性的，你仍需要处理其他错误，并捕获 RetryLimitExceeded 异常，以防错误不是暂时性的，或者需要太长时间才能解决自动.

使用重试执行策略时，有一些已知的限制：

不支持流式处理查询Streaming queries are not supported

默认情况下，EF6 和更高版本将缓冲查询结果，而不是流式传输。如果希望流式传输结果，可以使用 AsStreaming 方法将 LINQ to Entities 查询更改为流式处理。

using (var db = new BloggingContext())
{
    var query = (from b in db.Blogs
                orderby b.Url
                select b).AsStreaming();
    }
}

注册重试执行策略时，不支持流式处理。存在此限制的原因是，连接可能会在返回的结果中下降。出现这种情况时，EF 需要重新运行整个查询，但无法可靠地了解已返回的结果（数据自初始查询发送以来可能已更改，结果可能会以不同的顺序返回，结果可能不具有唯一标识符，等等）。

不支持用户启动的事务User initiated transactions are not supported

配置导致重试的执行策略时，对事务的使用存在一些限制。

默认情况下，EF 将在事务中执行任何数据库更新。不需要执行任何操作来启用此功能，EF 始终会自动执行此操作。

例如，在以下代码中，将在事务中自动执行。如果在插入新的一个站点后，SaveChanges 会失败，则会回滚该事务，并且不会将更改应用到数据库。上下文还会处于状态，该状态允许再次调用 SaveChanges 以重试应用更改。

using (var db = new BloggingContext())
{
    db.Blogs.Add(new Site { Url = "http://msdn.com/data/ef" });
    db.Blogs.Add(new Site { Url = "http://blogs.msdn.com/adonet" });
    db.SaveChanges();
}

如果不使用重试执行策略，则可以在单个事务中包装多个操作。例如，下面的代码将两个 SaveChanges 调用包装在一个事务中。如果任一操作的任何部分失败，则不会应用任何更改。

using (var db = new BloggingContext())
{
    using (var trn = db.Database.BeginTransaction())
    {
        db.Blogs.Add(new Site { Url = "http://msdn.com/data/ef" });
        db.Blogs.Add(new Site { Url = "http://blogs.msdn.com/adonet" });
        db.SaveChanges();
        db.Blogs.Add(new Site { Url = "http://twitter.com/efmagicunicorns" });
        db.SaveChanges();
        trn.Commit();
    }
}

使用重试执行策略时不支持此操作，因为 EF 不知道任何以前的操作以及如何重试。例如，如果第二个 SaveChanges 失败，则 EF 不再具有重试第一个 SaveChanges 调用所需的信息。

解决方案：手动调用执行策略Solution: Manually Call Execution Strategy

解决方案是手动使用执行策略，并为其分配要运行的整个逻辑集，以便在其中一个操作失败的情况下可以重试所有操作。当派生自 DbExecutionStrategy 的执行策略正在运行时，它将挂起 SaveChanges 中使用的隐式执行策略。

请注意，应在代码块内构造要重试的所有上下文。这可确保每次重试都从干净的状态开始。

var executionStrategy = new SqlAzureExecutionStrategy();
executionStrategy.Execute(
    () =>
    {
        using (var db = new BloggingContext())
        {
            using (var trn = db.Database.BeginTransaction())
            {
                db.Blogs.Add(new Blog { Url = "http://msdn.com/data/ef" });
                db.Blogs.Add(new Blog { Url = "http://blogs.msdn.com/adonet" });
                db.SaveChanges();
                db.Blogs.Add(new Blog { Url = "http://twitter.com/efmagicunicorns" });
                db.SaveChanges();
                trn.Commit();
            }
        }
    });