Polly 断路器已处理和未处理的异常

我想使用 Polly 来实现断路器模式。

在文档中，有一个半开状态描述 https://github.com/App-vNext/Polly/wiki/Circuit-Breaker#half-open，上面写着：

• 如果收到已处理的异常，则会重新引发该异常，并且电路会立即转换回打开状态，并在配置的时间跨度内再次保持打开状态。
• 如果收到未处理的异常，电路将保持半开路状态。

我不确定我是否理解已处理异常和未处理异常之间的区别。我们正在描述一种情况，其中某个操作由策略运行并引发异常。

当他们说异常已处理时，他们的意思是在哪里处理异常？因为正如我们所说，该操作将其抛出，所以这是否意味着它未处理？

让我完全不明白半开状态什么时候保持半开状态，什么时候过渡到开状态。

当您定义断路器策略时，您可以定义断路器应考虑哪种类型的异常CB 实施 https://github.com/App-vNext/Polly/blob/52968c25f2e13e2708898174c15aafc9cb915020/src/Polly/CircuitBreaker/AsyncCircuitBreakerEngine.cs。换句话说，您可以列出那些应被视为执行失败并应计入连续失败计数的异常。

您可以使用以下组合来定义例外列表Handle<T> and Or<T>方法调用。

让我们通过一个简单的例子来仔细研究这个概念：

var retry = Policy
    .Handle<ArgumentException>()
    .Or<NotSupportedException>()
    .WaitAndRetry(5, _ => TimeSpan.FromSeconds(1),
        onRetry: (exception, delay, context) => Console.WriteLine($"{"Retry",-10}{delay,-10:ss\\.fff}: {exception.GetType().Name}"));

var circuitBreaker = Policy
    .Handle<ArgumentException>()
    .CircuitBreaker(2, TimeSpan.FromSeconds(1),
        onBreak: (ex, @break) => Console.WriteLine($"{"Break",-10}{@break,-10:ss\\.fff}: {ex.GetType().Name}"),
        onReset: () => Console.WriteLine($"{"Reset",-10}"),
        onHalfOpen: () => Console.WriteLine($"{"HalfOpen",-10}"));

• The circuit breaker policy considers all ArgumentExceptions (including ArgumentNullException and ArgumentOutOfRangeException) as handled exception.
  • 这意味着，如果被调用的委托抛出这三个异常之一，那么它将增加连续失败计数，如果达到阈值，那么它将中断。
• The retry policy is triggered in case of ArgumentException and in case of NotSupportedException as well.
  • 如果抛出其中任何一个，那么它将休眠一秒钟，然后尝试重新执行同一个委托。

因此，从断路器的角度来看，如果NotSupportedException被抛出而不是不会被考虑 >> 因此名称为未处理。

这就是我们的示例方法的实现方式，它将抛出一个ArgumentException or a NotSupportedException:

private static int count = 0;
private const int threshold = 3;
static void SampleCall()
{
    count++;
    if (count >= threshold) throw new NotSupportedException();
    throw new ArgumentException("Nothing");
}

政策的使用：

var strategy = Policy.Wrap(retry, circuitBreaker);

try
{
    strategy.Execute(SampleCall);
    Console.WriteLine("Succeeded");
}
catch (NotSupportedException)
{
    Console.WriteLine("Failed");
}

输出时threshold设置为 3

Retry     01.000    : ArgumentException
Break     01.000    : ArgumentException
Retry     01.000    : ArgumentException
HalfOpen
Retry     01.000    : NotSupportedException
Retry     01.000    : NotSupportedException
Retry     01.000    : NotSupportedException
Failed

CB 自身转移至HalfOpen然后说明SampleCall仅抛出NotSupportedExceptions。这不是由 CB 处理的，这就是它保留在HalfOpen state.

输出时threshold设置为 2

Retry     01.000    : ArgumentException
Retry     01.000    : NotSupportedException
Retry     01.000    : NotSupportedException
Retry     01.000    : NotSupportedException
Retry     01.000    : NotSupportedException
Failed

CB没有破发，因为没有连续两次破发ArgumentException。但重试确实触发了，因为它还处理NotSupportedException.

输出时threshold设置为 4

Retry     01.000    : ArgumentException
Break     01.000    : ArgumentException
Retry     01.000    : ArgumentException
HalfOpen
Break     01.000    : ArgumentException
Retry     01.000    : ArgumentException
HalfOpen
Retry     01.000    : NotSupportedException
Retry     01.000    : NotSupportedException
Failed

因为SampleCall确实扔了ArgumentException当 CB 处于HalfOpen状态这就是为什么 CB 认为已处理异常并将其自身从HalfOpen to Open.