Polly 不会抛出一些异常？ 示例http://google.com:81示例https://httpstat.us/500

如何解决Polly 不会抛出一些异常？ 示例http://google.com:81示例https://httpstat.us/500

我将 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/
内部 TimeoutRejectedException

（注意它抛出）这是可以的。因为 Polly 在这个无效的 URL 超时后抛出。

但是如果我将 http://google.com:81/ 更改为“内部服务器错误”网址：（返回 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
下班后

（注意“下班后”）

问题：

为什么 Polly 在超时时抛出，但不在另一个条件下抛出？ 我明确写道：.OrResult(msg => httpStatusCodesWorthretrying.Contains(msg.StatusCode)) 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

1. 初始请求已发出
2. 在 3 秒内未收到任何响应
3. 触发超时政策
4. TimeoutRejectedException 被抛出
5. 重试策略知道该异常，因此它会触发
6. 重试政策问题 3 秒惩罚
7. 重试策略发出新请求
8. 在 3 秒内未收到任何响应
9. ...
   n.重试策略知道该异常，但已达到最大重试次数
   n+1。重试会抛出它无法处理的异常，因此在这种情况下 TimeoutRejectedException

示例https://httpstat.us/500

1. 初始请求已发出
2. 在 3 秒内收到状态代码为 500 的响应
3. 重试策略知道该状态代码，因此它会触发
4. 重试政策问题 3 秒惩罚
5. 重试策略发出新请求
6. 在 3 秒内收到状态代码为 500 的响应
7. ...
   n.重试策略知道该状态码，但已达到最大重试次数
   n+1。重试返回它无法处理的响应，因此在这种情况下 500

因为缺少 EnsureSuccessStatusCode 方法调用，所以没有抛出异常。

正如您在第二个示例中看到的，根本没有触发 TimeoutPolicy。

,

这是预期的行为。委托调用会导致异常或返回值。当 Polly 重试完成后，它会传播上次的任何结果，无论是异常还是返回值。

在这种情况下，响应将具有 500 状态代码。