Polly 重试（开发人员如何使用）

安装 Polly

您可以通过以下命令在 NuGet 程序包管理器控制台中安装 Polly：

Install-Package Polly

或通过 .NET CLI：

dotnet add package Polly

添加 Polly 使用语句

在您的 C# 文件中，包含 Polly 命名空间：

using Polly;

using Polly;

指数退避

指数退避是一种流行的重试策略，其中请求和重试之间的延迟指数增加。 Polly 提供了一种使用 WaitAndRetry() 实现指数退避的便捷方法。

var retryPolicy = Policy
    .Handle<HttpRequestException>()
    .WaitAndRetry(
        retryCount: 3, // Max retry attempts
        sleepDurationProvider: attempt => TimeSpan.FromSeconds(Math.Pow(2, attempt)), // Exponential delay
        onRetry: (exception, timeSpan, retryCount, context) =>
        {
            Console.WriteLine($"Retry {retryCount} due to {exception.Message}");
        });

var retryPolicy = Policy
    .Handle<HttpRequestException>()
    .WaitAndRetry(
        retryCount: 3, // Max retry attempts
        sleepDurationProvider: attempt => TimeSpan.FromSeconds(Math.Pow(2, attempt)), // Exponential delay
        onRetry: (exception, timeSpan, retryCount, context) =>
        {
            Console.WriteLine($"Retry {retryCount} due to {exception.Message}");
        });

与断路器重试

将重试与断路器结合使用可以通过防止服务持续失败时重复重试来进一步增强弹性。 Polly 允许您轻松结合重试和断路器策略。

// Define a circuit breaker policy
var circuitBreakerPolicy = Policy
    .Handle<HttpRequestException>()
    .CircuitBreaker(
        exceptionsAllowedBeforeBreaking: 3, // Number of exceptions before breaking
        durationOfBreak: TimeSpan.FromSeconds(30), // Time circuit stays open
        onBreak: (ex, breakDelay) =>
        {
            Console.WriteLine($"Circuit broken due to {ex.Message}. Retry after {breakDelay.TotalSeconds} seconds.");
        },
        onReset: () =>
        {
            Console.WriteLine("Circuit reset.");
        });

// Define a retry policy
var retryPolicy = Policy
    .Handle<HttpRequestException>()
    .WaitAndRetry(
        retryCount: 3, // Max retry attempts
        sleepDurationProvider: attempt => TimeSpan.FromSeconds(2), // Fixed retry delay
        onRetry: (exception, timeSpan, retryCount, context) =>
        {
            Console.WriteLine($"Retry {retryCount} due to {exception.Message}");
        });

// Combine both policies into a single policy wrap
var policyWrap = Policy.Wrap(circuitBreakerPolicy, retryPolicy);

// Define a circuit breaker policy
var circuitBreakerPolicy = Policy
    .Handle<HttpRequestException>()
    .CircuitBreaker(
        exceptionsAllowedBeforeBreaking: 3, // Number of exceptions before breaking
        durationOfBreak: TimeSpan.FromSeconds(30), // Time circuit stays open
        onBreak: (ex, breakDelay) =>
        {
            Console.WriteLine($"Circuit broken due to {ex.Message}. Retry after {breakDelay.TotalSeconds} seconds.");
        },
        onReset: () =>
        {
            Console.WriteLine("Circuit reset.");
        });

// Define a retry policy
var retryPolicy = Policy
    .Handle<HttpRequestException>()
    .WaitAndRetry(
        retryCount: 3, // Max retry attempts
        sleepDurationProvider: attempt => TimeSpan.FromSeconds(2), // Fixed retry delay
        onRetry: (exception, timeSpan, retryCount, context) =>
        {
            Console.WriteLine($"Retry {retryCount} due to {exception.Message}");
        });

// Combine both policies into a single policy wrap
var policyWrap = Policy.Wrap(circuitBreakerPolicy, retryPolicy);

在此示例中：

• CircuitBreaker() 定义断路器策略，该策略在 3 次异常后中断并保持开放 30 秒。
• Policy.Wrap() 将断路器和重试策略合并为一个策略。

与 IronPDF 结合的 Polly 重试

当使用 IronPDF 时，可能会遇到需要从外部资源获取数据或在生成 PDF 之前执行复杂操作的场景。

在这些情况下，您可能会遇到瞬时故障或临时问题，这可能导致 PDF 生成失败。 为了优雅地处理这些瞬时故障，您可以将 Polly 重试与 IronPDF 结合使用。

安装 IronPDF 和 Polly

在开始之前，确保在您的项目中安装 IronPDF NuGet 包。

Install-Package IronPdf

使用 Polly 重试与 IronPDF

让我们看看一个使用 Polly 重试来处理使用 IronPDF 生成 PDF 时瞬时故障的示例。 在以下示例中，我们将模拟从外部 API 获取数据，然后基于该数据生成 PDF。 我们将使用 Polly Retry 在发生故障时执行数据获取操作。

using System;
using System.Net.Http;
using System.Threading.Tasks;
using IronPdf;
using Polly;

namespace IronPdfWithPollyRetry
{
    public class Program
    {
        public static async Task Main(string[] args)
        {
            // Define a retry policy with async capability
            var retryPolicy = Policy
                .Handle<HttpRequestException>() // Specify exception type to handle
                .WaitAndRetryAsync(
                    3, // Retry attempts
                    retryAttempt => TimeSpan.FromSeconds(2), // Calculated retry delay
                    (exception, timeSpan, retryCount, context) =>
                    {
                        Console.WriteLine("Retry " + retryCount + " due to " + exception.Message);
                    });

            // Execute the retry policy asynchronously
            var pdf = await retryPolicy.ExecuteAsync(async () =>
            {
                var data = await FetchDataFromExternalApiAsync(); // Fetch data from an external source
                return GeneratePdfFromData(data); // Generate PDF using fetched data
            });

            pdf.SaveAs("GeneratedDocument.pdf");
        }

        // Simulate fetching data from an external API
        static async Task<string> FetchDataFromExternalApiAsync()
        {
            await Task.Delay(100); // Simulate delay
            throw new HttpRequestException("Failed to fetch data from external API");
        }

        // Generate PDF using IronPDF based on the fetched data
        static PdfDocument GeneratePdfFromData(string data)
        {
            var htmlContent = "<html><body><h1>Data: " + data + "</h1></body></html>";
            var renderer = new ChromePdfRenderer();
            return renderer.RenderHtmlAsPdf(htmlContent);
        }
    }
}

using System;
using System.Net.Http;
using System.Threading.Tasks;
using IronPdf;
using Polly;

namespace IronPdfWithPollyRetry
{
    public class Program
    {
        public static async Task Main(string[] args)
        {
            // Define a retry policy with async capability
            var retryPolicy = Policy
                .Handle<HttpRequestException>() // Specify exception type to handle
                .WaitAndRetryAsync(
                    3, // Retry attempts
                    retryAttempt => TimeSpan.FromSeconds(2), // Calculated retry delay
                    (exception, timeSpan, retryCount, context) =>
                    {
                        Console.WriteLine("Retry " + retryCount + " due to " + exception.Message);
                    });

            // Execute the retry policy asynchronously
            var pdf = await retryPolicy.ExecuteAsync(async () =>
            {
                var data = await FetchDataFromExternalApiAsync(); // Fetch data from an external source
                return GeneratePdfFromData(data); // Generate PDF using fetched data
            });

            pdf.SaveAs("GeneratedDocument.pdf");
        }

        // Simulate fetching data from an external API
        static async Task<string> FetchDataFromExternalApiAsync()
        {
            await Task.Delay(100); // Simulate delay
            throw new HttpRequestException("Failed to fetch data from external API");
        }

        // Generate PDF using IronPDF based on the fetched data
        static PdfDocument GeneratePdfFromData(string data)
        {
            var htmlContent = "<html><body><h1>Data: " + data + "</h1></body></html>";
            var renderer = new ChromePdfRenderer();
            return renderer.RenderHtmlAsPdf(htmlContent);
        }
    }
}

此 C# 代码演示如何使用 Polly 库为 IronPDF 生成 PDF 文档实现重试策略。 Main 方法使用 Polly 的 WaitAndRetryAsync 方法初始化了一个重试策略。

此策略指定它应该处理 HttpRequestException 并在初始尝试和重试之间最多 3 次重试，每次之间有 2 秒的延迟。 如果发生重试失败，则打印一条消息到控制台指出重试尝试次数和异常消息。

在 Main 方法中，重试策略逻辑使用 retryPolicy.ExecuteAsync() 异步执行。 在此执行过程中，两个异步操作被链接在一起：FetchDataFromExternalApiAsync() 和 GeneratePdfFromData(data)。

如果 FetchDataFromExternalApiAsync() 失败（因为它被故意设置为通过模拟异常失败），重试策略将捕获 HttpRequestException，记录重试尝试，并重试操作。

FetchDataFromExternalApiAsync() 方法模拟从外部 API 获取数据，带有延迟和有意抛出的 HttpRequestException，以模拟失败请求。