如何用C#实现数据库连接的重试逻辑？代码示例是什么？-C#.Net教程-PHP中文网

如何用C#实现数据库连接的重试逻辑？代码示例是什么？

煙雲

发布： 2025-10-12 08:27:02

原创

612人浏览过

使用循环和Polly实现C#数据库重试，1.通过for循环结合延迟与最大重试次数应对连接故障；2.采用指数退避策略提升重试效率；3.推荐Polly库实现异步重试与日志记录；4.需合理设置重试上限并及时释放连接。

如何用c#实现数据库连接的重试逻辑？代码示例是什么？

在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;
        });
    }
}

登录后复制