C#Polly Async-await：等待用户确认后再重试

Question

我找到了Polly包，它被设置为在C#中处理try/catch重试。我目前的代码设置如下：

public class WebExceptionCatcher<T, R> where T : Task<R>
{      
    public async Task<R> runTask(Func<T> myTask)
    {
        Policy p = Policy.Handle<WebException>()
        .Or<MobileServiceInvalidOperationException>()
        .Or<HttpRequestException>()
        .RetryForeverAsync(onRetryAsync: async (e,i) => await RefreshAuthorization());

        return await p.ExecuteAsync<R>(myTask);
    }
}

我的refreshAuthorization()方法只是在主线程的当前页面上显示一个DisplayAlert:

private async Task RefreshAuthorization()
{
    bool loop = true;
    Device.BeginInvokeOnMainThread(async () =>
    {
        await DisplayAlert("Connection Lost", "Please re-connect to the internet and try again", "Retry");
        loop = false;
    });

    while (loop)
    {
        await Task.Delay(100); 
    }
}

当我调试这个并切断我的internet连接时。从不显示DisplayAlert。发生两件事之一：

null

更新：

在将对DisplayAlert的调用放到Device.BeginInvokeonMainThread方法中之后，我现在找到了绕过AggregateException的方法。然而，现在我又有了一个问题。

一旦我断开与internet的连接，displayalert就会像应该的那样弹出。程序在完成onretry函数之前等待我单击重试，以便retryforeVerAsync等待工作正常。问题是，如果我重新连接到互联网，然后点击重试，它会一次又一次地失败。因此，即使我连接到互联网，我也陷入了被要求重新连接的无限循环。似乎RetryForeVerAsync只是重新抛出旧的异常。

Task<TodoItem> t = App.MobileService.GetTable<TodoItem>().LookupAsync(id);
WebExceptionCatcher<Task<TodoItem>, TodoItem> catcher = new WebExceptionCatcher<Task<TodoItem>, TodoItem>();

TodoItem item = await catcher.runTask(() => t);

TodoItem item = await catcher.runTask(async () => await t);

Answer 1

您需要使用.RetryForeVerAsync(...)作为注释。然后，由于重试委托是异步的，因此还需要使用onRetryAsync:。因此：

.RetryForeVerAsync(onRetryAsync:async(e,i）=>await RefreshAuthorization())；

为了解释您看到的错误：在问题中的代码示例中，通过使用onretry:，您指定要使用同步onretry委托（返回void)，但随后为其分配异步委托。

使async-delegate-assigned-to-sync-param变为Async void；调用代码不/等不及了。由于不等待异步空号委托，因此执行的委托确实会不断重试。

System.AggregateException：未观察到任务的异常可能是由该异常引起的，也可能是由MyTask的签名不匹配引起的（在发布此答案时q中不可用）。

编辑以回应问题和进一步评论的更新：

我知道（作为Polly的作者/维护者），Polly每次循环时都会调用传递的func > ，并且只会重新抛出新执行func > 抛出的任何异常。请参见异步重试实现：它每次在重试循环中重新尝试用户委托。

您可以尝试对调用代码进行以下（临时的、诊断性的）修改，以查看refreshAuthorization()是否真的阻止调用策略代码继续执行，同时等待用户单击重试。

public class WebExceptionCatcher<T, R> where T : Task<R>
{      
    public async Task<R> runTask(Func<T> t)
    {
        int j = 0;
        Policy p = Policy.Handle<WebException>()
        .Or<MobileServiceInvalidOperationException>()
        .Or<HttpRequestException>()
        .RetryForeverAsync(onRetryAsync: async (e,i) => await RefreshAuthorization());

        return await p.ExecuteAsync<R>( async () => 
        {
            j++;
            if ((j % 5) == 0) Device.BeginInvokeOnMainThread(async () =>
            {
                 await DisplayAlert("Making retry "+ i, "whatever", "Ok");
            });
            await myTask;
        });
    }
}

如果refreshAuthorization())正确阻止，则在显示Making Retry5对话框之前，您需要将Connection Lost弹出窗口取消五次。

如果refreshAuthorization())没有阻止调用代码，则在重新连接之前，策略将继续在后台进行多次（失败）尝试，并首先取消Connection Lost对话框。如果这种情况成立，然后只取消Connection Lost弹出一次，则将看到弹出making retry 5、Make retry 10（等等）；可能更多），在下一个连接丢失弹出之前。

使用这个（临时的、诊断性的）修改还应该证明每次Polly都在重新执行您传递的委托。如果MyTask引发了相同的异常，那么MyTask可能会出现问题--我们可能需要对此有更多的了解，并进行更深入的研究。

更新以响应发起人的第二次更新，开始“以下是我如何调用runtask():”

所以：您一直在假设重试失败，但您构造的代码实际上不进行任何重试。

剩下的问题的来源是这两行：

Task<TodoItem> t = App.MobileService.GetTable<TodoItem>().LookupAsync(id);
TodoItem item = await catcher.runTask(() => t); // Or same effect: TodoItem item = await catcher.runTask(async () => await t);

无论Polly策略如何（如果您使用手工构建的while或for循环进行重试，则只调用app.mobileService.gettable ().lookupasync(id) 一次）。

Task<TodoItem> t = App.MobileService.GetTable<TodoItem>().LookupAsync(id);

为了从图片中去掉任务来说明问题，它有点像编写以下代码：

int i = 0;
int j = i++;
Func<int> myFunc = () => j;
for (k=0; k<5; k++) Console.Write(myFunc());

并希望它打印12345，而不是（它将打印J的值五次）11111。

为了让它工作，简单地说：

TodoItem item = await catcher.runTask(() => App.MobileService.GetTable<TodoItem>().LookupAsync(id));