Polly CircuitBreaker - 动态中断持续时间

Question

在 Polly 上修改 Duration Break 的正确方法是什么？ 我知道他们在文档中提到实施（PolicyRegistry）。 有这方面的例子吗？ 我在一个 WinService 中实现 Polly CircuitBreaker。

Answer 1

Circuit Breaker 并非设计为在每次中断时使用不同的睡眠持续时间。

In case of Retry you have the ability to provide a function，称为sleepDurationProvider，由策略调用以确定实际的睡眠持续时间，然后再发出下一次尝试。

所以，简而言之by design it is not supported。我将向您展示一种解决方法，但我确实不建议使用它。我会在示例代码之后提供一个推理。

---

为了简单起见，让我们有以下方法：

static int Probe()
{
    Console.WriteLine("Probe has been called");
    throw new NotSupportedException();
}

• 它打印出该方法已被调用然后立即失败的事实。
• 恕我直言：不是一个真正有用的功能：D

让我们定义一个辅助方法，每次调用时都会增加时间段（>> sleep duration）：

static IEnumerable<TimeSpan> GetSleepDuration()
{
    for (int i = 1; i < 10; i++)
    {
        yield return TimeSpan.FromSeconds(i);
    }
}

• 这会（或多或少）替换 Retry 的 sleepDurationProvider。

现在是时候定义我们的断路器政策了：

var sleepDurationProvider = GetSleepDuration().GetEnumerator();
sleepDurationProvider.MoveNext();

var cb = Policy<int>
    .Handle<NotSupportedException>()
    .CircuitBreaker(1, TimeSpan.FromSeconds(0),
    onBreak: (_, __) => {
        Console.WriteLine(sleepDurationProvider.Current.TotalSeconds);
        Thread.Sleep((int)sleepDurationProvider.Current.TotalMilliseconds);
        sleepDurationProvider.MoveNext();
    },
    onReset: () => { },
    onHalfOpen: () => Console.WriteLine("CB half opens"));

• 我们得到了GetSleepDuration 的迭代器
• 我们将连续失败计数设置为 1，因此在每次 Probe 调用之后，CB 都会中断
• 我们将durationOfBreak 设置为零，因为我们将在onBreak 内等待
• 我们打印出睡眠持续时间然后我们睡觉，最后我们增加下一次休息的睡眠持续时间

为了简化我们的测试，让我们定义一个重试策略：

var retry = Policy<int>
    .Handle<NotSupportedException>()
    .WaitAndRetryForever(_ => TimeSpan.FromSeconds(0),
    onRetry: (_, __) => Console.WriteLine("Retry is triggered"));

• 它处理Probe的异常
• 它会永远重试，并在每次重试调用之间等待 0 秒

让我们连接策略并运行测试：

Policy.Wrap(retry, cb).Execute(() => Probe());

输出将是：

Probe has been called
1
Retry is triggered
CB half opens
Probe has been called
2
Retry is triggered
CB half opens
Probe has been called
3
Retry is triggered
CB half opens
Probe has been called
4
Retry is triggered
CB half opens
Probe has been called
5
Retry is triggered
CB half opens
Probe has been called
6
Retry is triggered
CB half opens
Probe has been called
7
Retry is triggered
CB half opens
Probe has been called
8
Retry is triggered
CB half opens
Probe has been called
9
Retry is triggered
CB half opens
Probe has been called
9
...

1. Probe 已被调用但失败
2. CB 从Open 转换到Broken
3. onBreak 已被调用，会阻塞执行 1 秒
4. PolicyWrap 将问题升级到重试
5. 重试等待 0 秒并发出新的尝试
6. CB 从Broken 转换到Hal-Open
7. Probe 已被调用但失败
8. ...

---

这个解决方案的最大问题是阻塞。不幸的是，onBreak 没有异步版本。 （重试确实有onRetryAsync，你可以使用Task.Delay代替Thread.Sleep）

第二个问题是它依赖于current implementation。如果例如 onBreak 在不同的线程上执行并且立即抛出异常，则此解决方案将不起作用。