用 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 灵活,两者结合不复杂但容易忽略边界场景。真正让重试“弹”起来的,不是策略多炫,而是对错误类型的精准识别和对业务语义的尊重。
