时间戳

首页 > 解决方案 > 用于函数重试的 C# Polly WaitAndRetry 策略

c# - 用于函数重试的 C# Polly WaitAndRetry 策略

问题描述

我对 C# 编码非常陌生，我只想知道如何为我的函数设置 polly WaitAndRetry 如果它失败了。以下是我的步骤

  1. 我使用 NuGet 包安装了包 Install-Package Polly
  2. 在我的代码中使用 polly添加。
  3. 下面是我的代码
public async Task<string> ConfigInsert(config model)
{
    try
    {
        SendToDatabase(model);

        await Policy.Handle<Exception>()
            .RetryAsync(NUMBER_OF_RETRIES)
            .ExecuteAsync(async () =>
                await SendToDatabase(model))
            .ConfigureAwait(false);
    } 
    Catch(Exception e)
    {
        _log.write("error occurred");
    }
        
    public async Task<string> SendToDataBase(config model)
    {
        var ss = DataBase.PostCallAsync(model)
            .GetAwaiter()
            .GetResult();
        return ss;
    }
}

但是这个电话一直在不停地调用，没有任何延迟。我尝试在 catch 调用中使用 WaitAndRetryAsync 但它不起作用。WaitAndRetryAsync 仅接受 HTTP 休止消息。我想在 try-catch 中实现 ait 和重试选项

标签： c#polly

解决方案

你说你想要 WaitAndRetry 但你不使用那个函数......而且它不仅适用于 HttpResponse。请阅读文档。

下面的代码应该给你一个良好的开端：

class Program
{
    static async Task Main(string[] args)
    {
        // define the policy using WaitAndRetry (try 3 times, waiting an increasing numer of seconds if exception is thrown)
        var policy = Policy
          .Handle<Exception>()
          .WaitAndRetryAsync(new[]
          {
            TimeSpan.FromSeconds(1),
            TimeSpan.FromSeconds(2),
            TimeSpan.FromSeconds(3)
          });

        // execute the policy
        await policy.ExecuteAsync(async () => await SendToDatabase());

    }

    static async Task SendToDatabase()
    {
        Console.WriteLine("trying to send to database");
        await Task.Delay(100);
        throw new Exception("it failed!");
    }
}

推荐阅读