在软件开发中，处理故障和异常是确保应用程序可靠性和稳定性的关键部分。对于使用C#和.NET框架的开发者来说，Polly是一个强大的库，它提供了一系列故障处理策略，如重试、熔断、超时等，帮助开发者编写更加鲁棒和可靠的应用程序。本文将详细介绍Polly的基本用法，并通过C#示例代码来展示如何在实际项目中应用这些策略。

一、Polly简介

Polly是一个针对.NET应用程序的库，提供了一系列经过优化的故障处理策略。通过Polly，开发者可以更容易地实现重试、断路器、超时和熔断机制等，从而在面对网络错误、数据库连接失败等常见故障时，保证应用程序的稳健性。Polly通过将复杂的重试逻辑封装成一组可重用的策略，极大地简化了故障处理和重试机制的实现过程。

二、Polly的安装

要在C#项目中使用Polly，首先需要将其安装到项目中。这通常通过NuGet包管理器来完成。以下是在Visual Studio中安装Polly的步骤：

右键点击项目，选择“Manage NuGet Packages...”。
在搜索框中输入“Polly”。
找到Polly包，点击“Install”进行安装。

安装完成后，就可以在你的代码中引入Polly命名空间了。

三、Polly的基本策略

Polly提供了多种策略来处理不同类型的故障，主要包括以下几种：

重试策略（Retry）：当操作失败时，根据定义的重试策略自动重试操作。
熔断策略（Circuit Breaker）：在检测到故障时，暂时停止对服务的请求，并在一段时间后尝试恢复。
超时策略（Timeout）：在操作超出指定时间后，自动取消请求并抛出超时异常。
舱壁隔离策略（Bulkhead Isolation）：通过限制并发执行的操作数来隔离资源，防止资源耗尽。
回退策略（Fallback）：当操作失败时，提供一个备用的操作或结果。

接下来，我们将通过C#示例代码来详细展示这些策略的用法。

四、重试策略示例

重试策略是Polly中最常用的策略之一，它允许开发者在操作失败时自动重试。以下是一个使用Polly实现重试策略的基本示例：

using System;
using Polly;
using Polly.Retry;

class Program
{
    static async Task Main(string[] args)
    {
        // 创建一个重试策略
        var retryPolicy = Policy
            .Handle<Exception>() // 指定要捕获的异常类型，这里捕获所有异常
            .WaitAndRetryAsync( // 定义重试策略
                retryCount: 3, // 重试次数
                sleepDurationProvider: retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt)), // 指数退避策略
                onRetry: (outcome, timespan, retryAttempt, context) =>
                {
                    Console.WriteLine($"请求失败，将在 {timespan} 后重试，重试次数：{retryAttempt}");
                }
            );

        // 使用重试策略执行可能会失败的操作
        try
        {
            await retryPolicy.ExecuteAsync(async () =>
            {
                using (var client = new HttpClient())
                {
                    Console.WriteLine("尝试请求外部服务...");
                    var response = await client.GetAsync("https://some.external.service/api");
                    response.EnsureSuccessStatusCode();
                    var content = await response.Content.ReadAsStringAsync();
                    Console.WriteLine($"响应内容：{content}");
                }
            });
        }
        catch (Exception ex)
        {
            Console.WriteLine($"请求失败，最终异常：{ex.Message}");
        }
    }
}

在这个示例中，我们定义了一个在发生异常时最多重试3次的重试策略，每次重试之间的等待时间采用指数退避策略。然后，我们使用这个策略来执行一个可能会失败的HTTP请求。如果请求失败，Polly将自动根据定义的重试策略来重试请求，并在每次重试前打印出等待时间和重试次数。

五、熔断策略示例

熔断策略是一种防止故障扩散的策略，它允许开发者在检测到服务故障时暂时停止对该服务的请求，并在一段时间后尝试恢复。以下是一个使用Polly实现熔断策略的示例：

using System;
using System.Threading.Tasks;
using Polly;

class Program
{
    static async Task Main(string[] args)
    {
        // 创建一个熔断策略
        var circuitBreakerPolicy = Policy
            .Handle<Exception>() // 指定要捕获的异常类型
            .CircuitBreakerAsync( // 定义熔断策略
                exceptionsAllowedBeforeBreaking: 5, // 在熔断前允许失败的次数
                durationOfBreak: TimeSpan.FromSeconds(30), // 熔断持续时间
                onBreak: (ex, breakDuration) =>
                {
                    Console.WriteLine($"熔断器已打开，持续时间：{breakDuration}");
                },
                onReset: () =>
                {
                    Console.WriteLine("熔断器已重置");
                },
                onHalfOpen: () =>
                {
                    Console.WriteLine("熔断器处于半开状态");
                }
            );

        // 模拟服务调用
        for (int i = 0; i < 10; i++)
        {
            try
            {
                await circuitBreakerPolicy.ExecuteAsync(() => Task.Run(() =>
                {
                    // 模拟服务失败
                    if (i < 5)
                    {
                        throw new Exception("服务失败");
                    }

                    // 模拟服务成功
                    Console.WriteLine($"服务调用成功，尝试次数：{i + 1}");
                }));
            }
            catch (Exception ex)
            {
                Console.WriteLine($"服务调用失败，异常：{ex.Message}");
            }

            await Task.Delay(1000); // 模拟请求间隔
        }
    }
}

在这个示例中，我们定义了一个熔断策略，它允许在连续失败5次后打开熔断器，持续时间为30秒。然后，我们模拟了10次服务调用，前5次调用都会失败并触发熔断策略，后5次调用由于熔断器处于打开状态，会直接返回异常信息。在熔断持续时间结束后，熔断器会进入半开状态，允许一次请求尝试恢复服务，如果请求成功，则熔断器重置，允许正常请求；如果请求失败，则熔断器再次打开。

六、超时策略示例

超时策略用于控制在等待操作完成时的最大时间。如果操作超过指定时间仍未完成，则超时策略将取消操作并抛出超时异常。以下是一个使用Polly实现超时策略的示例：

using System;
using System.Threading.Tasks;
using Polly;

class Program
{
    static async Task Main(string[] args)
    {
        // 创建一个超时策略
        var timeoutPolicy = Policy
            .TimeoutAsync<HttpResponseMessage>( // 指定超时策略的类型为HttpResponseMessage
                TimeSpan.FromSeconds(5), // 超时时间设置为5秒
                TimeoutStrategy.Pessimistic // 悲观策略，立即取消操作
            );

        // 使用超时策略执行可能会超时的操作
        try
        {
            await timeoutPolicy.ExecuteAsync(async (ct) =>
            {
                using (var client = new HttpClient())
                {
                    Console.WriteLine("尝试请求外部服务...");
                    var response = await client.GetAsync("https://some.slow.service/api", ct); // 传递CancellationToken
                    response.EnsureSuccessStatusCode();
                    var content = await response.Content.ReadAsStringAsync();
                    Console.WriteLine($"响应内容：{content}");
                }
            }, CancellationToken.None); // 在这里传递CancellationToken.None，但通常在超时策略中使用传入的CancellationToken
        }
        catch (TimeoutRejectedException ex)
        {
            Console.WriteLine($"请求超时，异常：{ex.Message}");
        }
        catch (Exception ex)
        {
            Console.WriteLine($"请求失败，异常：{ex.Message}");
        }
    }
}

在这个示例中，我们创建了一个超时策略，将超时时间设置为5秒，并采用悲观策略来立即取消超时的操作。然后，我们使用这个策略来执行一个可能会超时的HTTP请求。如果请求在5秒内未完成，Polly将抛出TimeoutRejectedException异常，表示请求已超时。

七、总结

Polly是一个强大的库，为.NET应用程序提供了丰富的故障处理策略，帮助开发者编写更加鲁棒和可靠的应用程序。通过本文的介绍和示例代码，读者应该能够掌握Polly的基本用法，并在实际项目中灵活应用这些策略来提高应用程序的可靠性和稳定性。

在实际开发中，根据应用程序的具体需求和业务场景，开发者可以选择合适的策略来应对不同类型的故障。例如，对于网络请求，可以使用重试策略来自动重试失败的请求；对于远程服务调用，可以使用熔断策略来防止故障扩散；对于需要快速响应的操作，可以使用超时策略来控制等待时间。通过合理组合这些策略，

ITPub博客

Polly的基本用法：构建稳健的C#应用程序