波莉不会抛出一些异常吗？

Question

我正在使用 .net Core 的 Polly。我的 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()}");
        });
}

这些是我想要重试的HTTP状态码:

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 重试次数:1__FOR_BaseUrl_http://google.com:81/
_PollyAttempt 重试次数:2__FOR_BaseUrl_http://google.com:81/
_PollyAttempt 重试次数:3__FOR_BaseUrl_http://google.com:81/
超时拒绝异常内部

(注意它会抛出)这是可以的。因为Polly在超时后会抛出。

但是如果我将http://google.com:81/改成一个"服务器内部错误"的URL:(返回500)

https://run.mocky.io/v3/9f1b4c18-2cf0-4303-9136-bb67d54d0148

那么它就不会抛出而是继续执行：

_PollyAttempt 重试次数:1__FOR_BaseUrl_https://run.mocky.io/v3/9f1b4c18-2cf0-4303-9136-bb67d54d0148
_PollyAttempt 重试次数:2__FOR_BaseUrl_https://run.mocky.io/v3/9f1b4c18-2cf0-4303-9136-bb67d54d0148
_PollyAttempt 重试次数:3__FOR_BaseUrl_https://run.mocky.io/v3/9f1b4c18-2cf0-4303-9136-bb67d54d0148
工作后

(注意末尾的 "after work")

问题：

为什么 Polly 在超时时会抛出异常，但在其他情况下不会呢？ 我明确地写了：.OrResult(msg => httpStatusCodesWorthRetrying.Contains(msg.StatusCode)) 其中 500 是其中之一。

- Royi Namir

---

整个 OrResult 部分是不必要的。HandleTransientFailure 覆盖 408 和 5xx 状态码。 - Peter Csala

@peter 在所有尝试都无果的情况下，Polly 抛出了 TimedOutException。在我看来。 - Royi Namir

@RoyiNamir 这取决于情况。您可以定义本地/每个请求的超时时间，也可以定义一个全局超时时间。在后一种情况下，超时时间包括所有请求（初始尝试+重试尝试+重试之间的惩罚）。 - Peter Csala

@RoyiNamir 在这里详细介绍了这两种超时之间的区别，如果您想更好地理解的话。 - Peter Csala

@RoyiNamir，我留了一篇帖子，以明确这两个示例之间的区别。我希望它能给你带来清晰度。 - Peter Csala

Answer 1

正如 @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));

获取重试策略。

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。

- Peter Csala

---

顺便说一下，在我的项目中，我们构建了一个 AUTH docker api，并将其完全转换为 REST。（200、409（冲突）、401等等……）当我们添加 Polly 时，我遇到了那些非成功代码的问题。我甚至无法执行“EnsureSuccessCode”（我知道这不是 Polly 的问题，但是……）。这是我最后一次构建纯 REST api。下一次我会返回 200 和子代码。 - Royi Namir

没问题，我只是提到了EnsureSuccessStatusCode，因为如果状态码超过299，它会抛出异常。所以，如果你想打破正常流程，那就是最简单的方法。 - Peter Csala

请参阅 http-error-codes-are-retried-by-polly-net-by-default。 - Michael Freidgeim

Answer 2

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

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

- Stephen Cleary