在C#中实现数据库连接重试逻辑，主要是为了应对短暂的网络波动或数据库服务暂时不可用的情况。可以通过循环尝试连接，并结合延迟和最大重试次数来控制行为。下面是一个使用 ADO.NET 连接 SQL Server 并实现重试机制的示例。
使用循环和延迟实现重试
以下代码展示了如何在连接失败时自动重试指定次数，每次重试之间加入一定的延迟：
using System;
using System.Data.SqlClient;
using System.Threading;
class DatabaseHelper
{
private static readonly int MaxRetries = 3;
private static readonly int DelayMs = 2000; // 2秒延迟
public static SqlConnection GetConnectionWithRetry(string connectionString)
{
for (int attempt = 1; attempt <= MaxRetries; attempt++)
{
try
{
var connection = new SqlConnection(connectionString);
connection.Open();
Console.WriteLine("数据库连接成功。");
return connection; // 成功则返回连接
}
catch (SqlException ex)
{
Console.WriteLine($"第 {attempt} 次连接失败: {ex.Message}");
if (attempt == MaxRetries)
{
Console.WriteLine("已达到最大重试次数，无法连接数据库。");
throw; // 最后一次失败，抛出异常
}
Thread.Sleep(DelayMs); // 等待后再重试
}
catch (Exception ex)
{
Console.WriteLine($"非数据库异常: {ex.Message}");
throw; // 非预期异常立即抛出
}
}
return null; // 不会执行到这里
}
}
使用 Polly 库实现更优雅的重试策略
Polly 是一个流行的 .NET 弹性处理库，支持重试、熔断、超时等策略。使用它可以让重试逻辑更简洁且功能更强。
首先通过 NuGet 安装 Polly：
Install-Package Polly然后使用 Polly 实现异步重试：
using Polly;
using System;
using System.Data.SqlClient;
using System.Threading.Tasks;
class DatabaseHelperWithPolly
{
private static readonly int MaxRetries = 3;
public static async Task<SqlConnection> GetConnectionWithPollyAsync(string connectionString)
{
var policy = Policy<SqlConnection>
.Handle<SqlException>()
.Or<InvalidOperationException>()
.WaitAndRetryAsync(
MaxRetries,
retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt)), // 指数退避
(result, timeSpan, context) =>
{
Console.WriteLine($"连接失败，{timeSpan.TotalSeconds} 秒后重试...");
});
return await policy.ExecuteAsync(async () =>
{
var connection = new SqlConnection(connectionString);
await connection.OpenAsync();
Console.WriteLine("数据库连接成功。");
return connection;
});
}
}
使用建议
在实际项目中：
推荐使用 Polly，它让重试逻辑更清晰，支持同步/异步、指数退避、日志记录等高级功能。 避免无限重试，设置合理的最大重试次数和等待间隔。 注意及时释放数据库连接（配合 using 语句）。 记录重试日志有助于排查问题。 基本上就这些。根据项目复杂度选择手动重试或使用 Polly 更合适。
