Polly 重试策略

Posted rajesh

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Polly 重试策略相关的知识,希望对你有一定的参考价值。

工作原理

技术图片

Retry

基本重试:

public static void Retry()
{
    var random = new Random();

    // Policy<> 泛型定义返回值类型, 如若不需要返回值, 可直接使用 Policy
    var obj = Policy<object>

        // Handle<> 可指定需要处理的异常类型
        .Handle<Exception>()

        //也可以使用重载对Exception 进行再次过滤
        //.Handle<Exception>(e => e is NotSupportedException)                

        .Retry(3, (res, i, c) =>
               {
                   //当委托的代码块执行失败时会进入此 Action, 
                   //这里可以对抛出的异常进行日志或其他处理
                   Console.WriteLine($"retry {i}th times, ex: {res.Exception?.Message}");
               })
        .Execute(() =>
                 {
                      var val = random.Next(0, 100);
                    switch (val % 3)
                    {
                        case 0:
                            return "Success";
                        default:
                            throw new Exception($"random val: {val}");
                    }
                 });
    Console.WriteLine(obj);
}

输出:

重试一次成功:

技术图片

重试两次成功:

技术图片

重试三次均失败:

技术图片

可以看到,再超过重试次数的时候, 若程序还是异常,则抛出异常。

RetryForever

成功前一直重试:

public static void RetryForever()
{
    var random = new Random();

    // Policy<> 泛型定义返回值类型, 如若不需要返回值, 可直接使用 Policy
    var obj = Policy<object>

        // Handle<> 可指定需要处理的异常类型
        .Handle<Exception>()

        //也可以使用重载对Exception 进行再次过滤
        //.Handle<Exception>(e => e is NotSupportedException)                

        .RetryForever((res, i, c) =>
                      {
                          //当委托的代码块执行失败时会进入此 Action, 
                          //这里可以对抛出的异常进行日志或其他处理
                          Console.WriteLine($"retry {i}th times, ex: {res.Exception?.Message}");
                      })
        .Execute(() =>
                 {
                     var val = random.Next(0, 100);
                     switch (val % 999)
                     {
                         case 0:
                             return $"Success, val: {val}";
                         default:
                             throw new Exception($"random val: {val}");
                     }
                 });

    Console.WriteLine(obj);
}

输出:

技术图片

case 0: 这个分支去掉, 任务将变为不可能成功,会发现一直输出重试。

WaitAndRetry

程序异常后做短暂延迟再次重试:

.WaitAndRetry(5, 
                
                // 设置 Sleep Duration Provider 来提供延迟时间
                retryTimes => TimeSpan.FromSeconds(Math.Pow(2, retryTimes)),

                (res, delay, times, context) =>
                {
                    //当委托的代码块执行失败时会进入此 Action, 
                    //这里可以对抛出的异常进行日志或其他处理
                    Console.WriteLine($"retry {times}th times, sleep: {delay.TotalSeconds}s, ex: {res.Exception?.Message}");
                })

可以看到我们在 WaitAndRetry 方法中提供了延迟方式: retryTimes => TimeSpan.FromSeconds(Math.Pow(2, retryTimes)),, 这是一种比较典型的延迟方式,叫做 指数退避。

输出:

技术图片

WaitAndRetryForever

.WaitAndRetryForever(

                // 设置 Sleep Duration Provider 来提供延迟时间
                (retryTimes, res, context) => TimeSpan.FromSeconds(Math.Pow(2, retryTimes)),

                (res, times, delay, context) =>
                {
                    //当委托的代码块执行失败时会进入此 Action, 
                    //这里可以对抛出的异常进行日志或其他处理
                    Console.WriteLine($"retry {times}th times, sleep: {delay.TotalSeconds}s, ex: {res.Exception?.Message}");
                })

仅仅与 WaitAndRetrySleepDurationProvider 的参数有点不同

小结

此篇大体概括了 Polly 重试的几种方式, 当然 Polly Retry 还有很多重载, 但作用都是围绕 程序异常时进行自我调整再重试 为中心。

以上是关于Polly 重试策略的主要内容,如果未能解决你的问题,请参考以下文章

使用最小起订量测试 Polly 重试策略

Polly 重试策略

Polly的多种弹性策略介绍和简单使用

Polly

微服务之Polly熔断策略

Polly 同步重试