Dapper怎么结合 Polly 实现数据库重试策略 Dapper弹性连接教程

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

Dapper怎么结合 Polly 实现数据库重试策略 Dapper弹性连接教程

2025-12-13

浏览次数：次

返回列表

Dapper 结合 Polly 可实现数据库操作的弹性重试，需精准识别瞬态异常（如 SQL 错误码 -2、40613 等）、封装扩展方法统一应用策略，并规避非幂等操作重复执行等风险。

dapper怎么结合 polly 实现数据库重试策略 dapper弹性连接教程

用 Dapper 执行数据库操作时，网络抖动、连接超时或 SQL Server 临时不可用都可能导致查询失败。Polly 是一个成熟的 .NET 弹性库，配合 Dapper 可以轻松实现重试、熔断等策略——关键不是“能不能”，而是“怎么配得稳、不误伤、不掩盖问题”。

1. 安装必要 NuGet 包

确保项目中已引用：

Dapper（>= 2.0.123）
Polly（>= 8.4.0，推荐用 Polly.Core，轻量且支持 .NET 6+）
Microsoft.Data.SqlClient（>= 5.1.0，支持连接弹性内置重试，但仅限连接建立阶段；Dapper 的命令执行仍需手动加 Polly）

2. 定义重试策略（聚焦常见数据库异常）

不要对所有异常重试。只针对可恢复的瞬态错误，比如：

SQL Server 错误码：–2（连接超时）、40613（数据库已暂停）、40197/40501（服务繁忙）
网络异常：SqlException 中的 InnerException 是 Win32Exception 或 TimeoutException
连接被意外关闭（InvalidOperationException 提示 “The connection was closed”）

示例策略（最多重试 3 次，指数退避）：

var retryPolicy = Policy
  .Handle<SqlException>(ex =>
    ex.Number is -2 or 40613 or 40197 or 40501 ||
    ex.InnerException is TimeoutException or Win32Exception)
  .Or<InvalidOperationException>(ex => ex.Message.Contains("closed", StringComparison.OrdinalIgnoreCase))
  .WaitAndRetryAsync(
    retryCount: 3,
    sleepDurationProvider: attempt => TimeSpan.FromMilliseconds(Math.Pow(2, attempt) * 100),
    onRetry: (outcome, timespan, retryCount, context) =>
      Log.Warning("DB command failed (attempt {RetryCount}), retrying in {Delay}ms", retryCount, timespan.TotalMilliseconds)
  );

3. 将 Polly 注入 Dapper 执行流程（推荐封装扩展方法）

避免每个 QueryAsync 或 ExecuteAsync 都写重复策略调用。封装一个带重试的 Dapper 扩展：

捏Ta

捏Ta 是一个专注于角色故事智能创作的AI漫画生成平台

322 查看详情捏Ta

public static class DapperRetryExtensions
{
  public static async Task<IEnumerable<T>> QueryWithRetryAsync<T>(
    this IDbConnection connection,
    string sql,
    object? param = null,
    IDbTransaction? transaction = null,
    int? commandTimeout = null,
    CancellationToken cancellationToken = default) where T : class
  {
    return await retryPolicy.ExecuteAsync(async ct =>
    {
      return await connection.QueryAsync<T>(sql, param, transaction, commandTimeout, ct);
    }, cancellationToken);
  }
<p>// 同理可封装 ExecuteWithRetryAsync、QuerySingleWithRetryAsync 等
}

使用时就像原生 Dapper 一样自然：

using var conn = new SqlConnection(connectionString);
var users = await conn.QueryWithRetryAsync<User>("SELECT * FROM Users WHERE Active = 1");

4. 注意事项与避坑点

重试不是万能解药，几个关键细节必须处理好：

非幂等操作慎用重试：比如 INSERT INTO Orders 直接重试可能造成重复下单。解决方案：加唯一约束 + 捕获冲突异常（如 SQL Server 的错误码 2627），或改用带业务幂等键的存储过程
事务内重试要整体重试：不要只重试某一条语句。把整个事务逻辑包进 ExecuteAsync，并在重试前确保连接重新打开、事务重新开启
别忽略日志上下文：在 onRetry 中记录 SQL 片段（脱敏）、参数哈希、当前连接字符串 Hash，方便排查是哪个查询在反复失败
连接字符串本身要启用基础连接重试：在连接字符串里加上 Connect Timeout=30;Connection Timeout=30;Connection Reset=false;，并确认 SqlConnection 的 OpenAsync 已由底层驱动自动重试（SQL Server 2019+ 默认开启）