C#怎么使用Polly实现重试和熔断 Polly弹性框架使用教程

1次阅读

Polly 是 .net 中主流弹性容错库,支持直观配置重试、熔断及组合策略。通过 Policy.WrapAsync 组合重试与熔断,配合指数退避、jitter、日志回调和 PolicyRegistry 等特性实现高可用。

C#怎么使用Polly实现重试和熔断 Polly弹性框架使用教程

Polly 是 .NET 生态中最主流的弹性与容错库,用它实现重试(Retry)和熔断(Circuit Breaker)非常直观,不需要自己写状态管理或指数退避逻辑。核心是把“可能失败的操作”包装进策略(Policy),再用 ExecuteExecuteAsync 调用即可。

快速上手:安装与基础重试

先通过 NuGet 安装:
PM> Install-Package Polly

最简单的重试策略:失败时最多重试 3 次,每次立即重试:

var retryPolicy = Policy     .Handle<HttpRequestException>() // 捕获指定异常     .RetryAsync(3); // 重试 3 次(共执行 4 次)  await retryPolicy.ExecuteAsync(async () => {     using var client = new HttpClient();     return await client.GetStringAsync("https://api.example.com/data"); });

带退避策略的重试(推荐生产使用)

连续重试容易压垮下游,应加入延迟。Polly 支持线性、指数等退避方式:

  • 指数退避(Exponential Backoff):延迟随重试次数翻倍增长,最常用
  • 自定义退避函数:可加入 jitter(随机抖动)防雪崩

示例(带 jitter 的指数退避):

var jitteredBackoff = Policy     .Handle<HttpRequestException>()     .WaitAndRetryAsync(         retryCount: 3,         sleepDurationProvider: retryAttempt =>              TimeSpan.FromSeconds(Math.Pow(2, retryAttempt))                  + TimeSpan.FromMilliseconds(new Random().Next(0, 100))     );

熔断器:自动暂停请求,保护系统

当错误率过高时,熔断器会进入 Open 状态,直接拒绝请求,避免雪崩。一段时间后进入 Half-Open 尝试恢复。

C#怎么使用Polly实现重试和熔断 Polly弹性框架使用教程

刺鸟创客

一款专业高效稳定的AI内容创作平台

C#怎么使用Polly实现重试和熔断 Polly弹性框架使用教程 110

查看详情 C#怎么使用Polly实现重试和熔断 Polly弹性框架使用教程

配置示例(连续 5 次失败就熔断,60 秒后尝试半开):

var circuitBreaker = Policy     .Handle<HttpRequestException>()     .CircuitBreakerAsync(         exceptionsAllowedBeforeBreaking: 5,         durationOfBreak: TimeSpan.FromSeconds(60)     );

注意:熔断策略不能单独使用,通常要和重试组合——比如先重试,再触发熔断:

var resilientPolicy = Policy.WrapAsync(retryPolicy, circuitBreaker); await resilientPolicy.ExecuteAsync(FetchDataAsync);

组合策略 + 上下文监控(进阶实用技巧)

真实项目中建议加上日志和指标:

  • onRetry / onBreak 回调记录行为
  • 结合 ExecutionContext 传递请求 ID,方便追踪
  • PolicyRegistry 统一管理多个策略,按名称复用

例如加日志的重试:

Policy     .Handle<HttpRequestException>()     .RetryAsync(         retryCount: 3,         onRetry: (outcome, timespan, retryCount, context) =>         {             Console.WriteLine($"第 {retryCount} 次重试,等待 {timespan.TotalMilliseconds}ms");         }     );

基本上就这些。Polly 的设计很干净,策略即对象,可组合、可复用、可测试。不复杂但容易忽略的是:别忘了异步方法要用 Async 后缀策略,同步场景用非 Async 版本;还有,熔断器的状态是实例级的,线程共享同一个策略实例才能真正起作用。

text=ZqhQzanResources