我有一个数字序列,使用异步方法处理。我正在模拟一个可能失败的远程服务调用。如果失败,我希望重试,直到调用成功。
问题是,对于我正在尝试的代码,每次在异步方法中抛出异常时,序列似乎永远挂起。
你可以用这个简单的代码片段来测试它(它在LINQPad中测试过)
Random rnd = new Random();
void Main()
{
var numbers = Enumerable.Range(1, 10).ToObservable();
var processed = numbers.SelectMany(n => Process(n).ToObservable().Retry());
processed.Subscribe( f => Console.WriteLine(f));
}
public async Task<int> Process(int n)
{
if (rnd.Next(2) == 1)
{
throw new InvalidOperationException();
}
await Task.Delay(2000);
return n*10;
}
它应该处理每个元素,重试那些失败的元素。相反,它永远不会结束,我不知道为什么。
我怎样才能做我想做的事?
编辑:(感谢@CharlesNRice和@JonSkeet提供的线索!):
这很管用!
Random rnd = new Random();
void Main()
{
var numbers = Enumerable.Range(1, 10).ToObservable();
var processed = numbers.SelectMany(n => RetryTask(() => MyTask(n)).ToObservable());
processed.Subscribe(f => Console.WriteLine(f));
}
private async Task<int> MyTask(int n)
{
if (rnd.Next(2) == 1)
{
throw new InvalidOperationException();
}
await System.Threading.Tasks.Task.Delay(2000);
return n * 10;
}
async Task<T> RetryTask<T>(Func<Task<T>> myTask, int? retryCount = null)
{
while (true)
{
try
{
return await myTask();
}
catch (Exception)
{
Debug.WriteLine("Retrying...");
if (retryCount.HasValue)
{
if (retryCount == 0)
{
throw;
}
retryCount--;
}
}
}
}
在这种情况下,滚动自己的Retry
是过分的。您可以通过简单地将方法调用封装在Defer
块中来实现同样的目的,并且在重试发生时它将被重新执行。
var numbers = Enumerable.Range(1, 10).ToObservable();
var processed = numbers.SelectMany(n =>
//Defer call passed method every time it is subscribed to,
//Allowing the Retry to work correctly.
Observable.Defer(() =>
Process(n).ToObservable()).Retry()
);
processed.Subscribe( f => Console.WriteLine(f));
您正在重试同一个处于故障状态的Task。重试将重新订阅到可观察源。重试的来源是ToObservable()。它不会像任务工厂一样生成新任务,而且由于任务出现故障,它会继续重试出现故障的任务,永远不会成功。
您可以查看如何制作自己的重试包装器的答案https://stackoverflow.com/a/6090049/1798889