C#中如何配置数据库的查询重试策略？处理临时故障？

来源：这里教程网时间：2026-02-21 17:27:02 作者：

H3 理解临时性故障与重试的必要性

在C#应用中访问数据库时，网络抖动、数据库连接池繁忙或瞬时超时等都可能导致请求失败。这类问题通常具有“临时性”，稍后重试即可成功。为提升系统稳定性，配置合理的查询重试策略非常关键。

H3 使用 Entity Framework Core 配合 Pomelo 或 SQL Server 的内置重试机制

如果你使用的是 Entity Framework Core（EF Core），可以利用其内置的执行策略（Execution Strategy）来自动处理重试。

例如，在使用 SQL Server 时，可以在

Startup.cs

或

Program.cs

中配置：

services.AddDbContext<MyDbContext>(options =>
    options.UseSqlServer(
        Configuration.GetConnectionString("DefaultConnection"),
        sqlOptions =>
        {
            sqlOptions.EnableRetryOnFailure(
                maxRetryCount: 5,
                maxRetryDelay: TimeSpan.FromSeconds(30),
                errorNumbersToAdd: null);
        }));

对于 MySQL（通过 Pomelo.EntityFrameworkCore.MySql），也支持类似机制：

services.AddDbContext<MyDbContext>(options =>
    options.UseMySql(
        Configuration.GetConnectionString("DefaultConnection"),
        new MySqlServerVersion(new Version(8, 0, 25)),
        mySqlOptions =>
        {
            mySqlOptions.EnableRetryOnFailure(
                maxRetryCount: 5,
                maxRetryDelay: TimeSpan.FromSeconds(10),
                errorNumbersToAdd: null);
        }));

这些设置会自动对事务、查询和保存操作进行重试，适用于连接中断、超时等常见错误。

H3 手动实现重试逻辑：使用 Polly 库增强控制力

若需要更灵活的控制（比如针对特定异常、自定义退避策略），推荐使用 Polly 这个强大的 .NET 弹性库。

安装 NuGet 包：

Install-Package Polly
Install-Package Polly.Extensions.Http

然后在代码中定义基于条件的重试策略，例如：

using Polly;
using Polly.Retry;
// 创建一个最多重试3次，采用指数退避策略的策略
var retryPolicy = Policy
    .Handle<SqlException>(ex => IsTransient(ex)) // 判断是否是临时故障
    .Or<TimeoutException>()
    .WaitAndRetryAsync(
        3,
        retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt)), // 指数退避：2s, 4s, 8s
        (result, timeSpan, retryCount, context) =>
        {
            // 可选：记录日志
            Console.WriteLine($"重试 {retryCount} 次，原因: {result.Exception?.Message}");
        });
// 使用示例
await retryPolicy.ExecuteAsync(async () =>
{
    using var context = new MyDbContext();
    var data = await context.Users.ToListAsync();
});

其中

IsTransient

方法用于判断

SqlException

是否为临时性错误（如超时、死锁）：

private bool IsTransient(SqlException ex)
{
    var transientErrors = new[] { -2, 20, 201, 232, 1205, 1213, 1222, 4060, 40197, 40501, 40613 };
    return transientErrors.Contains(ex.Number);
}

H3 结合 IHttpClientFactory 和 EF Core 的最佳实践建议

虽然数据库调用通常是直接的 ADO.NET 或 EF Core 调用，但若你的服务通过 API 访问数据，也可以将 Polly 与