我目前正在一起使用Polly和Flurl,但是我有一个通用的重试策略,必须添加到每个请求中。我注意到Polly允许您使用AddPolicyHandler(...)设置默认值,但这需要IHttpClientBuilder,而且我看不到任何从Flurl掌握此方法的方法。
我以为DefaultHttpClientFactory重载可能是解决方法,但这只能让我访问HttpClient,而不是IHttpClientBuilder。
我知道我可以制作自己的HttpClients并将它们传递给Flurl,但我宁愿避免这种情况,因为我希望Flurl管理它们的生命周期。
目前有什么方法可以做我想做的事吗?
最佳答案
好问题。 Flurl为您提供了所有必要的钩子。首先定义一个采用Polly策略的DelegatingHandler
:
public class PollyHandler : DelegatingHandler
{
private readonly IAsyncPolicy<HttpResponseMessage> _policy;
public PollyHandler(IAsyncPolicy<HttpResponseMessage> policy) {
_policy = policy;
}
protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) {
return _policy.ExecuteAsync(ct => base.SendAsync(request, ct), cancellationToken);
}
}
然后创建一个自定义
IHttpClientFactory
,以默认的处理程序作为其InnerHandler
返回您的自定义处理程序:public class PollyFactory : DefaultHttpClientFactory
{
private readonly IAsyncPolicy<HttpResponseMessage> _policy;
public PollyFactory(IAsyncPolicy<HttpResponseMessage> policy) {
_policy = policy;
}
public override HttpMessageHandler CreateMessageHandler() {
return new PollyHandler(_policy) {
InnerHandler = base.CreateMessageHandler()
};
}
}
最后,在应用启动时,定义您的策略并向Flurl注册:
var policy = Policy
.Handle<HttpRequestException>()
.OrResult<HttpResponseMessage>(r => !r.IsSuccessStatusCode)
.RetryAsync(5);
FlurlHttp.Configure(settings => settings.HttpClientFactory = new PollyFactory(policy));
一个重要的注意事项是此方法不适用于处理FlurlHttpException 的策略。那是因为您在这里拦截了
HttpMessageHandler
级别的 call 。 Flurl将响应和错误转换为堆栈上方更高的FlurlHttpException
,因此使用这种方法不会陷入或重试这些响应和错误。上面示例中的策略将捕获HttpRequestException
和HttpResponseMessage
(具有非2XX状态代码),它们将起作用。关于polly - 使用Flurl设置默认的Polly策略,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/52272374/