.NET绿叶社区!
返回

Polly重试回退熔断策略组合示例

2020-08-02 Polly 策略组合 熔断 降级 106 0

Polly重试回退熔断策略组合示例

假设服务A是一个集群(2个节点),首先调用其中一个节点的服务,如果失败或者超时,则用轮询的方式进行重试调用。

重试多次仍然失败,则直接返回一个替代数据(服务降级),之后一段时间,服务被熔断。再熔断时间内,所有对该服务的调用都以替代数据返回。

熔断时间过后,尝试再次调用,如果成功,则关闭熔断器,服务通道打通。否则,继续熔断这个服务一段时间。

要用到几个策略?超时策略,重试策略,断路器策略,回退策略(降级),策略组合。

实现代码如下

namespace ConsulTest
{
    public class PolicyBuilder
    {
        public static ISyncPolicy CreatePolly() {
            // 超时1秒
            var timeoutPolicy = Policy.Timeout(1, (context, timespan, task) => {
                Console.WriteLine("执行超时,抛出TimeoutRejectedException异常");
            });
            // 重试2次
            var retryProlicy = Policy.Handle<Exception>().WaitAndRetry(2,
                retryAttempt => TimeSpan.FromSeconds(2),
                (exception, timespan, retryCount, context) => {
                    Console.WriteLine($"{DateTime.Now} = 重试 {retryCount} 次 - 抛出{exception.GetType()}");
                });
            // 连续发生两次故障,就熔断3秒
            var circuitBreakerPolicy = Policy.Handle<Exception>().CircuitBreaker(
                // 熔断前允许出现几次错误
                2,
                // 熔断时间
                TimeSpan.FromSeconds(3),
                // 熔断时触发
                onBreak: (ex, breakDelay) =>
                {
                    Console.WriteLine($"{DateTime.Now} - 断路器:开启状态(熔断时触发)");
                },
                // 熔断回恢复时触发
                onReset:()=> {
                    Console.WriteLine($"{DateTime.Now} - 断路器:关闭状态(熔断恢复时触发)");
                },
                // 熔断时间到了之后触发,尝试放行少量(1次)的请求
                onHalfOpen:()=> {
                    Console.WriteLine($"{DateTime.Now} - 断路器:半开启状态(熔断时间到了之后触发)");
                });
            // 回退策略,降级
            var fallbackPolicy = Policy.Handle<Exception>().Fallback(() => {
                Console.WriteLine("这是一个Fallback");
            }, exception => {
                Console.WriteLine($"Fallback异常:{exception.GetType()}");
            });
            // 策略从右到左依次进行调用
            return Policy.Wrap(fallbackPolicy, circuitBreakerPolicy, retryProlicy, timeoutPolicy);
        }
    }
}

测试代码如下,服务注册和服务发现代码可以参考

.NET Core Consul服务注册

.NET Core Consul服务发现

Polly瞬态故障处理熔断降级用法

namespace ConsulTest
{
    public class ConsulBasic
    {
        public static void Run() {
            var serviceProvider = new ConsulServiceProvider(new Uri("http://192.168.31.175:8500"));
            var aspNetCoreService = serviceProvider.CreateServiceBuilder(builder => {
                builder.ServiceName = "AspNetCore";
                builder.LoadBalancer = TypeLoadBalancer.RoundRobinLoad;//可选RandomLoad
                builder.UriScheme = Uri.UriSchemeHttp;
            });
            var httpClient = new HttpClient();
            var policy = PolicyBuilder.CreatePolly();
            for (int i = 0; i < 100; i++)
            {
                Console.WriteLine($"----------第{i}次请求-----------");
                policy.Execute(() => {
                    try
                    {
                        var uri = aspNetCoreService.BuildAsync("/Health").Result;
                        Console.WriteLine($"{DateTime.Now} - 正在调用:{uri}");
                        var content = httpClient.GetStringAsync(uri).Result;
                        Console.WriteLine($"返回结果:{content}");
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine("调用异常:"+ex.GetType());
                        // 如果你要在策略里捕捉异常,如果这个异常还是你定义的故障,一定要把这个异常抛出来
                        throw ex;
                    }
                });
                Task.Delay(500).Wait();
            }
            Console.ReadLine();
        }
    }
}

我关闭两个服务,并且运行程序,结果如下

Polly重试回退熔断策略组合示例

可以看到

首先判断调用是否超时,如果超时就会触发异常,发生超时故障,然后就触发重试策略

如果重试两次中只要成功一次,就直接返回调用结果

如果重试两次都失败,第三次再次失败,就会发生故障

重试之后是断路器策略,所以这个故障会被断路器接收,当断路器收到两次故障,就会触发熔断,也就是说断路器开启

断路器开启的3秒内,任何故障或者操作,都会通过断路器到达回退策略,触发降级操作

3秒后,断路器进入到半开启状态,操作可以正常执行

接下来我开启一个服务,运行结果如下

Polly重试回退熔断策略组合示例

在断路器半开启状态时,调用服务成功了,于是断路器被关闭了。

点赞 收藏

顶部