使用polly c#在http请求超时时重试多次

pix*_*xel 2 c# asp.net-mvc connection-timeout polly

我的初衷是在请求本身超时时重试多次,例如尝试与另一个关闭几秒钟的微服务通信时,希望它是暂时的失败。如果有一个更简单的解决方案来做到这一点就足够了。我决定使用包装策略手动设置每次重试的超时时间,希望达到相同的结果。

我在这里看到了一个类似的解决方案,没有使用 httpclientfactory Use a specific timeout connected to a retrypolicy,但它对我不起作用。

我的代码如下所示:

services.AddHttpClient("retryclient", client =>
{
    client.Timeout = TimeSpan.FromSeconds(100);
}).AddPolicyHandler((servs, request) =>
    Policy.HandleResult<HttpResponseMessage>(r =>
        {
            return r.StatusCode == HttpStatusCode.NotFound; //(1)
        }).
.OrTransiesntHttpError().
WaitAndRetryAsync(5, retryAttempt => TimeSpan.FromSeconds(retryAttempt),
    onRetry: (exception, timespan, retryAttempt, context) =>
        { // using servs to log // });
}).WrapAsync(Policy.TimeoutAsync(1)));
Run Code Online (Sandbox Code Playgroud)

当我尝试访问“未找到”地址而不包装超时策略时,我已经检查过重试策略是否有效,并且它工作正常。我还尝试将第 (1) 行与状态代码一起使用,HttpStatusCode.RequestTimeout而不是在我的案例中找不到,但它不起作用。

当我使用包装并尝试访问已关闭的服务时,它会Polly.Timeout.TimeoutRejectedException在第一次尝试时按我的预期抛出 a ,但不会再次重试。我无法找到重试多次的方法,要么为每次重试设置超时,要么仅在请求本身超时时不使用超时策略。

编辑:进一步阅读 https://cm.engineering/transient-timeouts-and-the-retry-rabbit-hole-net-4-5-f406cebbf194 后,似乎我的问题出在我无法访问的策略处理中HttpClient 的取消令牌。我假设我可以通过覆盖 sendAsync 方法来修复它,如链接所示。在创建工厂时是否有一种优雅的方式来做同样的事情?

mou*_*ler 5

HttpClientFactory 上Polly 文档在标记为应用超时的部分中介绍了这一点:

如果任何个人尝试超时,您可能希望重试策略重试。为此,请使重试策略处理TimeoutRejectedExceptionPolly 的超时策略引发的问题。

所以:

services.AddHttpClient("retryclient", client =>
{
    client.Timeout = TimeSpan.FromSeconds(100);
}).AddPolicyHandler((servs, request) =>
    Policy.HandleResult<HttpResponseMessage>(r =>
        {
            return r.StatusCode == HttpStatusCode.NotFound; //(1)
        }).
.OrTransientHttpError()
.Or<TimeoutRejectedException>() // ** ADDED **
.WaitAndRetryAsync(5, retryAttempt => TimeSpan.FromSeconds(retryAttempt),
    onRetry: (exception, timespan, retryAttempt, context) =>
        { // using servs to log // });
})
.WrapAsync(Policy.TimeoutAsync(1)));
Run Code Online (Sandbox Code Playgroud)

Polly正确地将 传递CancellationToken给内部.SendAsync()调用;对此无需作出任何改变。