1

我第一次尝试实施断路器，但它不起作用。后备政策有效，但我似乎无法达到断路器。我已经在不同的版本中尝试过这个，包括断路器的重试策略，但这似乎并不重要。我确定这是我错过的基本内容。

这是用于测试目的的代码的简化版本：

var timeoutPolicy = Policy
            .TimeoutAsync(
                _settings.TimeoutWhenCallingApi,
                TimeoutStrategy.Pessimistic
            );

        var circuitBreaker = Policy
            .Handle<TimeoutRejectedException>()
            .CircuitBreakerAsync(
                _settings.ConsecutiveExceptionsAllowedBeforeBreaking,
                _settings.DurationOfBreak
            )
            .WrapAsync(timeoutPolicy);

        policy = Policy
            .Handle<Exception>()
            .FallbackAsync(
                async cancellationToken => { Console.WriteLine("fallback triggered"); })
            .WrapAsync(circuitBreaker);

        await policy.ExecuteAsync(() => Task.Delay(-1));
4

1 回答 1

4

以下代码示例构建的超时、断路器和回退策略与您问题中发布的原始代码基本相同。

using Polly; 
using System;
using System.Threading.Tasks;

public class Program
{
    public static async void Main() {

    var timeoutPolicy = Policy
        .TimeoutAsync(
            TimeSpan.FromMilliseconds(10), // _settings.TimeoutWhenCallingApi,
            Polly.Timeout.TimeoutStrategy.Pessimistic
        );

    var circuitBreaker = Policy
        .Handle<Polly.Timeout.TimeoutRejectedException>()
        .CircuitBreakerAsync(
            1, // _settings.ConsecutiveExceptionsAllowedBeforeBreaking,
            TimeSpan.FromSeconds(30) // _settings.DurationOfBreak
        );
    var circuitBreakerWrappingTimeout = circuitBreaker
        .WrapAsync(timeoutPolicy);

    var policy = Policy
        .Handle<Exception>()
        .FallbackAsync(
            async cancellationToken => { Console.WriteLine("fallback triggered"); })
        .WrapAsync(circuitBreakerWrappingTimeout);

    Console.WriteLine("Circuit state before execution: " + circuitBreaker.CircuitState);
    
    await policy.ExecuteAsync(() => Task.Delay(-1));
    
    Console.WriteLine("Circuit state after execution: " + circuitBreaker.CircuitState);
    }
}

可以使用此 dotnetfiddle 示例运行代码：https ://dotnetfiddle.net/m9O3cg

（dotnetfiddle 示例更改为非异步 main 只是因为 dotnetfiddle 并不总是完成await的async Main()方法，所以输出并不总是完成async Main()）

输出是：

Circuit state before execution: Closed
fallback triggered
Circuit state after execution: Open

这表明断路器政策正在达成/参与您的执行。

  • 执行的委托被超时策略超时，抛出TimeoutRejectedException
  • 断路器策略捕捉到它并计算TimeoutRejectedException它经历的连续 s 的数量： 1. 这足以断开，因此断路器转换为打开状态。
  • 断路器重新投掷TimeoutRejectedException（它只是一个测量和分断装置）
  • 回退策略捕获TimeoutRejectedException并输出回退。
  • 最终线路输出电路状态表明断路器受到（因此参与）呼叫的影响。

由于电路开路，policy在 30 秒内的另一次执行durationOfBreak将失败并显示 。BrokenCircuitException

于 2017-12-22T17:00:04.403 回答