为什么在使用Polly的后续重试中HttpClient会继续失败？

Question

我有几种方法需要某种互联网连接。如果连接失败，我想在失败之前重试该方法一段时间。由于应用程序可以在等待成功响应的同时继续运行，我希望异步执行此操作。

我使用Polly (5.3.1)来实现异步重试逻辑，利用Tasks。

我在禁用Wi-Fi的情况下启动进程并在重试窗口中启用进程来模拟断开连接。我期待在再次启用我的连接后，重试时方法会成功，我所看到的是该方法继续抛出HttpRequestException，就好像连接已关闭，直到重试完成，然后抛出给调用者。
如果我以正常启用Wi-Fi的方式启动该方法，它将立即成功。

// Get the HTML of a web page 'async' 
public async Task<string> GetHtmlAsync(string url) 
{ 
    using (var client = new HttpClient()) 
    using (var response = await client.GetAsync(url)) 
    { 
     response.EnsureSuccessStatusCode(); 
     using (var content = response.Content) 
     { 
      return await content.ReadAsStringAsync(); 
     } 
    } 
} 

// Wrapper for Polly to create an async retry policy 
public async Task<TResult> RetryAsync<TResult, TException>(Task<TResult> task, int retries, int seconds) where TException : Exception 
{ 
    return await Policy 
       .Handle<TException>() 
       .WaitAndRetryAsync(retries, wait => TimeSpan.FromSeconds(seconds)) 
       .ExecuteAsync(async() => await task); 
} 

// Call the method, it will retry 12 times with a gap of 5 seconds between tries 
var html = await RetryAsync<string, HttpRequestException>(GetHtmlAsync("https://www.google.co.uk"), 12, 5); 

为什么该方法继续即使失败，虽然我的连接已启用，并在随后的重试工作？

Answer 1

它随后失败，因为您没有重新执行任何操作。 Task代表异步执行的未来结果。订阅它只会给你结果，它不会重新运行代码。

想象它就像一个已经开始的鸡蛋计时器，你可以传递它，每个人都可以看到它是否完成，但如果它已经完成，他们会立即看到它。就你而言，由于第一次失败，它立即失败后续检查。

你需要的是重试调用：

public async Task<string> GetHtmlAsync(string url) 
{ 
    using (var client = new HttpClient()) 
    using (var response = await client.GetAsync(url)) 
    { 
     response.EnsureSuccessStatusCode(); 
     using (var content = response.Content) 
     { 
      return await content.ReadAsStringAsync(); 
     } 
    } 
} 

// Wrapper for Polly to create an async retry policy 
public async Task<TResult> RetryAsync<TResult, TException>(
    Func<Task<TResult>> taskInitiator, int retries, int seconds) where TException : Exception 
{ 
    return await Policy 
       .Handle<TException>() 
       .WaitAndRetryAsync(retries, wait => TimeSpan.FromSeconds(seconds)) 
       .ExecuteAsync(async() => await taskInitiator()); 
} 

// Call the method, it will retry 12 times with a gap of 5 seconds between tries 
var html = await RetryAsync<string, HttpRequestException>(
    () => GetHtmlAsync("https://www.google.co.uk"), 12, 5);