C#中如何配置数据库的查询重试策略？处理临时故障？-C#.Net教程-PHP中文网

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

月夜之吻

发布： 2025-09-28 10:24:01

原创

556人浏览过

在C#应用中，为应对数据库访问时的临时性故障，需配置重试策略以提升系统稳定性。使用EF Core时，可借助SQL Server或Pomelo提供的内置重试机制，自动处理连接中断、超时等问题。对于更精细控制，推荐引入Polly库，实现基于条件的重试与指数退避策略，并结合IsTransient方法识别临时性错误。最佳实践中还应区分可恢复与不可恢复错误，避免无限重试，记录重试日志，并注意潜在的根本问题如连接池瓶颈或慢查询，确保重试机制不掩盖系统缺陷。

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

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 弹性库。

白瓜面试

白瓜面试 - AI面试助手,辅助笔试面试神器

查看详情

安装 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 与 IHttpClientFactory 结合使用，统一管理下游依赖的容错。

即使不涉及 HTTP，核心原则一致：