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

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

用 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 扩展:

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+ 默认开启)

基本上就这些。Dapper 轻量,Polly 灵活,两者结合不复杂但容易忽略边界场景。真正让重试“弹”起来的,不是策略多炫,而是对错误类型的精准识别和对业务语义的尊重。

相关推荐