Polly 不会抛出一些异常?
Polly won't throw on some exceptions?
我将 Polly 与 .net Core 结合使用。我的 ConfigureServices
是:
private static void ConfigureServices()
{
var collection = new ServiceCollection();
var timeoutPolicy = Policy.TimeoutAsync<HttpResponseMessage>(3);
collection.AddHttpClient<INetworkService, NetworkService>(s=>
{
s.BaseAddress = new Uri("http://google.com:81"); //this is a deliberate timeout url
})
.AddPolicyHandler((a,b)=>GetRetryPolicy(b))
.AddPolicyHandler(timeoutPolicy); ;
...
}
这是GetRetryPolicy
函数:
private static IAsyncPolicy<HttpResponseMessage> GetRetryPolicy(HttpRequestMessage req)
{
return HttpPolicyExtensions
.HandleTransientHttpError()
.OrResult(msg => httpStatusCodesWorthRetrying.Contains(msg.StatusCode)) // see below
.Or<TimeoutRejectedException>()
.Or<TaskCanceledException>()
.Or<OperationCanceledException>()
.WaitAndRetryAsync(3, retryAttempt =>
{
return TimeSpan.FromSeconds(3);
}, onRetry: (response, delay, retryCount, context) =>
{
Console.WriteLine($"______PollyAttempt_____ retryCount:{retryCount}__FOR_BaseUrl_{req.RequestUri.ToString()}");
});
}
这些是我想重试的 httpcodes :
static HttpStatusCode[] httpStatusCodesWorthRetrying = {
HttpStatusCode.RequestTimeout, // 408
HttpStatusCode.InternalServerError, // 500
HttpStatusCode.BadGateway, // 502
HttpStatusCode.ServiceUnavailable, // 503
HttpStatusCode.GatewayTimeout // 504
};
好的。这是实际的调用:
public async Task Work()
{
try
{
HttpResponseMessage response = await _httpClient.GetAsync("");
Console.WriteLine("After work");
}
catch (TimeoutRejectedException ex)
{
Console.WriteLine("inside TimeoutRejectedException");
}
catch (Exception ex)
{
Console.WriteLine("inside catch main http");
}
}
输出为:
_PollyAttempt retryCount:1__FOR_BaseUrl_http://google.com:81/
_PollyAttempt retryCount:2__FOR_BaseUrl_http://google.com:81/
_PollyAttempt retryCount:3__FOR_BaseUrl_http://google.com:81/
inside TimeoutRejectedException
(注意它抛出)没关系。因为 Polly 在这个无效 URL 超时后抛出。
但是如果我将 http://google.com:81/
更改为“内部服务器错误”url : (this return 500)
https://run.mocky.io/v3/9f1b4c18-2cf0-4303-9136-bb67d54d0148
然后它不抛出但继续:
_PollyAttempt retryCount:1__FOR_BaseUrl_https://run.mocky.io/v3/9f1b4c18-2cf0-4303-9136-bb67d54d0148
_PollyAttempt retryCount:2__FOR_BaseUrl_https://run.mocky.io/v3/9f1b4c18-2cf0-4303-9136-bb67d54d0148
_PollyAttempt retryCount:3__FOR_BaseUrl_https://run.mocky.io/v3/9f1b4c18-2cf0-4303-9136-bb67d54d0148
After work
(注意最后“下班后”)
问题:
为什么 Polly 在超时时抛出异常,而在其他情况下不抛出异常?
我明确地写道:.OrResult(msg => httpStatusCodesWorthRetrying.Contains(msg.StatusCode))
500就是其中之一。
这是预期的行为。委托调用会导致异常或 return 值。当 Polly 重试完成后,它会传播最后的结果,无论是异常还是 return 值。
在这种情况下,响应将具有 500 状态代码。
正如@StephenCleary 所说,这就是 Polly 的工作原理。
首先让我与您分享您的代码的清理版本
然后我会给你一些关于观察到的行为的解释。
ConfigureServices
var timeoutPolicy = Policy.TimeoutAsync<HttpResponseMessage>(3,
onTimeoutAsync: (_, __, ___) => {
Console.WriteLine("Timeout has occured");
return Task.CompletedTask;
});
services.AddHttpClient<INetworkService, NetworkService>(
client => client.BaseAddress = new Uri("https://httpstat.us/500"))
.AddPolicyHandler((_, request) => Policy.WrapAsync(GetRetryPolicy(request), timeoutPolicy));
GetRetryPolicy
private static IAsyncPolicy<HttpResponseMessage> GetRetryPolicy(HttpRequestMessage req)
=> HttpPolicyExtensions
.HandleTransientHttpError()
.Or<TimeoutRejectedException>()
.Or<OperationCanceledException>()
.WaitAndRetryAsync(3,
_ => TimeSpan.FromSeconds(3),
onRetry: (_, __, retryCount, ___) =>
Console.WriteLine($"POLLY retryCount:{retryCount} baseUrl: {req.RequestUri}"));
示例http://google.com:81
- 初始请求已发出
- 3 秒内未收到任何响应
- 触发超时策略
TimeoutRejectedException
被抛出
- 重试策略知道该异常,因此触发
- 重试策略问题 3 秒惩罚
- 重试策略发出新请求
- 3 秒内未收到任何响应
- ...
名词重试策略知道该异常,但已达到最大重试次数
n+1。重试会抛出它无法处理的异常,因此在这种情况下 TimeoutRejectedException
示例https://httpstat.us/500
- 初始请求已发出
- 在 3 秒内收到状态代码为 500 的响应
- 重试策略知道该状态码,因此触发
- 重试策略问题 3 秒惩罚
- 重试策略发出新请求
- 已在 3 秒内收到状态代码为 500 的响应
- ...
名词重试策略知道该状态代码,但已达到最大重试次数
n+1。使用无法处理的响应重试 returns,因此在本例中为 500
因为缺少 EnsureSuccessStatusCode
方法调用,所以没有抛出异常。
正如您在第二个示例中看到的,根本没有触发 TimeoutPolicy。
我将 Polly 与 .net Core 结合使用。我的 ConfigureServices
是:
private static void ConfigureServices()
{
var collection = new ServiceCollection();
var timeoutPolicy = Policy.TimeoutAsync<HttpResponseMessage>(3);
collection.AddHttpClient<INetworkService, NetworkService>(s=>
{
s.BaseAddress = new Uri("http://google.com:81"); //this is a deliberate timeout url
})
.AddPolicyHandler((a,b)=>GetRetryPolicy(b))
.AddPolicyHandler(timeoutPolicy); ;
...
}
这是GetRetryPolicy
函数:
private static IAsyncPolicy<HttpResponseMessage> GetRetryPolicy(HttpRequestMessage req)
{
return HttpPolicyExtensions
.HandleTransientHttpError()
.OrResult(msg => httpStatusCodesWorthRetrying.Contains(msg.StatusCode)) // see below
.Or<TimeoutRejectedException>()
.Or<TaskCanceledException>()
.Or<OperationCanceledException>()
.WaitAndRetryAsync(3, retryAttempt =>
{
return TimeSpan.FromSeconds(3);
}, onRetry: (response, delay, retryCount, context) =>
{
Console.WriteLine($"______PollyAttempt_____ retryCount:{retryCount}__FOR_BaseUrl_{req.RequestUri.ToString()}");
});
}
这些是我想重试的 httpcodes :
static HttpStatusCode[] httpStatusCodesWorthRetrying = {
HttpStatusCode.RequestTimeout, // 408
HttpStatusCode.InternalServerError, // 500
HttpStatusCode.BadGateway, // 502
HttpStatusCode.ServiceUnavailable, // 503
HttpStatusCode.GatewayTimeout // 504
};
好的。这是实际的调用:
public async Task Work()
{
try
{
HttpResponseMessage response = await _httpClient.GetAsync("");
Console.WriteLine("After work");
}
catch (TimeoutRejectedException ex)
{
Console.WriteLine("inside TimeoutRejectedException");
}
catch (Exception ex)
{
Console.WriteLine("inside catch main http");
}
}
输出为:
_PollyAttempt retryCount:1__FOR_BaseUrl_http://google.com:81/
_PollyAttempt retryCount:2__FOR_BaseUrl_http://google.com:81/
_PollyAttempt retryCount:3__FOR_BaseUrl_http://google.com:81/
inside TimeoutRejectedException
(注意它抛出)没关系。因为 Polly 在这个无效 URL 超时后抛出。
但是如果我将 http://google.com:81/
更改为“内部服务器错误”url : (this return 500)
https://run.mocky.io/v3/9f1b4c18-2cf0-4303-9136-bb67d54d0148
然后它不抛出但继续:
_PollyAttempt retryCount:1__FOR_BaseUrl_https://run.mocky.io/v3/9f1b4c18-2cf0-4303-9136-bb67d54d0148
_PollyAttempt retryCount:2__FOR_BaseUrl_https://run.mocky.io/v3/9f1b4c18-2cf0-4303-9136-bb67d54d0148
_PollyAttempt retryCount:3__FOR_BaseUrl_https://run.mocky.io/v3/9f1b4c18-2cf0-4303-9136-bb67d54d0148
After work
(注意最后“下班后”)
问题:
为什么 Polly 在超时时抛出异常,而在其他情况下不抛出异常?
我明确地写道:.OrResult(msg => httpStatusCodesWorthRetrying.Contains(msg.StatusCode))
500就是其中之一。
这是预期的行为。委托调用会导致异常或 return 值。当 Polly 重试完成后,它会传播最后的结果,无论是异常还是 return 值。
在这种情况下,响应将具有 500 状态代码。
正如@StephenCleary 所说,这就是 Polly 的工作原理。
首先让我与您分享您的代码的清理版本
然后我会给你一些关于观察到的行为的解释。
ConfigureServices
var timeoutPolicy = Policy.TimeoutAsync<HttpResponseMessage>(3,
onTimeoutAsync: (_, __, ___) => {
Console.WriteLine("Timeout has occured");
return Task.CompletedTask;
});
services.AddHttpClient<INetworkService, NetworkService>(
client => client.BaseAddress = new Uri("https://httpstat.us/500"))
.AddPolicyHandler((_, request) => Policy.WrapAsync(GetRetryPolicy(request), timeoutPolicy));
GetRetryPolicy
private static IAsyncPolicy<HttpResponseMessage> GetRetryPolicy(HttpRequestMessage req)
=> HttpPolicyExtensions
.HandleTransientHttpError()
.Or<TimeoutRejectedException>()
.Or<OperationCanceledException>()
.WaitAndRetryAsync(3,
_ => TimeSpan.FromSeconds(3),
onRetry: (_, __, retryCount, ___) =>
Console.WriteLine($"POLLY retryCount:{retryCount} baseUrl: {req.RequestUri}"));
示例http://google.com:81
- 初始请求已发出
- 3 秒内未收到任何响应
- 触发超时策略
TimeoutRejectedException
被抛出- 重试策略知道该异常,因此触发
- 重试策略问题 3 秒惩罚
- 重试策略发出新请求
- 3 秒内未收到任何响应
- ...
名词重试策略知道该异常,但已达到最大重试次数
n+1。重试会抛出它无法处理的异常,因此在这种情况下TimeoutRejectedException
示例https://httpstat.us/500
- 初始请求已发出
- 在 3 秒内收到状态代码为 500 的响应
- 重试策略知道该状态码,因此触发
- 重试策略问题 3 秒惩罚
- 重试策略发出新请求
- 已在 3 秒内收到状态代码为 500 的响应
- ...
名词重试策略知道该状态代码,但已达到最大重试次数
n+1。使用无法处理的响应重试 returns,因此在本例中为 500
因为缺少 EnsureSuccessStatusCode
方法调用,所以没有抛出异常。
正如您在第二个示例中看到的,根本没有触发 TimeoutPolicy。