使用Polly重试

Question

这两个重试政策是否表示相同？

Policy
    .Handle<SomeExceptionType>()
    .WaitAndRetry(
        new[]
        {
            TimeSpan.FromMinutes(1),
            TimeSpan.FromMinutes(1),
            TimeSpan.FromMinutes(1)
        });

Policy
    .Handle<SomeExceptionType>()
    .WaitAndRetry(
        3,
        retryAttempt => TimeSpan.FromMinutes(1)
    );

Answer 1

是的，他们也这样做。

这两个代码都定义了一个策略，该策略最多将执行相同的操作：初始尝试 +另外三次尝试。

两个过载之间的主要区别是：

• 前者定义 static 方式的惩罚
  • 它可以预先定义不同尝试之间的延迟
• 后者定义了 dynamic 方式的惩罚
  • 它可以根据即将发生的重试

  来计算延迟

您的第二个替代方案可以这样定义：

Policy
    .Handle<SomeExceptionType>()
    .WaitAndRetry(
        3,
        _ => TimeSpan.FromMinutes(1)
    );

使用丢弃操作员，您可以明确地说明您在sleepduration provider 计算新延迟。

---

为了清楚起见，我使用了惩罚， delay 和 sleep 术语在这篇文章中可互换。

---

更新＃1

这是两个示例，您可以利用动态惩罚计算。

指数向后 +抖动，

而不是在每次尝试之间等待相同的时间，建议使用越来越大的延迟为下游系统提供自我光的空间。因此，例如：2、4、8 ...

jitter 只是一个小的随机数，可以避免所有客户都试图同时发送重试尝试。因此，它会及时散布/分散客户的重试尝试。

const int maxDelayInMilliseconds = 32 * 1000;
var jitterer = new Random();
Policy
  .Handle<HttpRequestException>()
  .WaitAndRetryForever(
      retryAttempt =>
      {
          var calculatedDelayInMilliseconds = Math.Pow(2, retryAttempt) * 1000;
          var jitterInMilliseconds = jitterer.Next(0, 1000);

          var actualDelay = Math.Min(calculatedDelayInMilliseconds + jitterInMilliseconds, maxDelayInMilliseconds);
          return TimeSpan.FromMilliseconds(actualDelay);
      }
  );

断路器意识到重试

如果您使用断路器以避免在自我修复时避免下游系统泛滥，则可以使您的重试知道这一点。

默认情况下，所有政策都是独立的，它们彼此之间没有意识。如果您在打开CB时进行重试尝试，则您将收到BROKENCIRCUITEXCEPTION（因此，它会缩短执行）。但是您可以根据CB的状态动态计算延迟，以便您可以跳过这些不必要的重试。

断路器定义

Policy<HttpResponseMessage>
    .HandleResult(res => res.StatusCode == HttpStatusCode.InternalServerError)
    .CircuitBreakerAsync(3, TimeSpan.FromSeconds(2),
       onBreak: (dr, ts, ctx) => { ctx[SleepDurationKey] = ts; },
       onReset: (ctx) => { ctx[SleepDurationKey] = null; });

重试定义

Policy<HttpResponseMessage>
    .HandleResult(res => res.StatusCode == HttpStatusCode.InternalServerError)
    .Or<BrokenCircuitException>()
    .WaitAndRetryAsync(4,
        sleepDurationProvider: (c, ctx) =>
        {
            if (ctx.ContainsKey(SleepDurationKey))
                return (TimeSpan)ctx[SleepDurationKey];
            return TimeSpan.FromMilliseconds(200);
        });

此高级用例详细描述在这里。