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

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

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

标签： app ai win microsoft nas .net connection reset