正文

在 .NET Core 中结合 HttpClientFactory 使用 Polly（中篇）

IP云
IP云V管理员/3 阅读
12/02
提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

译者：王亮
作者：Polly 团队
原文：http://t.cn/EhZ90oq
声明：我翻译技术文章不是逐句翻译的，而是根据我自己的理解来表述的（包括标题）。其中可能会去除一些不影响理解但本人实在不知道如何组织的句子

译者序：这是“Polly and HttpClientFactory”这篇Wiki文档翻译的中篇，你可以 点击这里查看上篇。接下来的两篇则是在这个基础上进行加强。本篇（中篇）主要讲如何在ASP.NET Core中通过HttpClientFactory配置Polly策略。如果你对ASP.NET Core 2.1新引入的HttpClient工厂还比较陌生，建议先阅读我的另一篇文章 .NET Core中正确使用 HttpClient的姿势，这有助于更好地理解本文。

—— 正文 ——

下面主要讲如何在ASP.NET Core中通过HttpClientFactory配置Polly策略。

使用 AddTransientHttpErrorPolicy

让我们先回到上篇的例子： 

services.AddHttpClient("GitHub", client =>
{
    client.BaseAddress = new Uri("https://api.github.com/");
    client.DefaultRequestHeaders.Add("Accept", "application/vnd.github.v3+json");
})
.AddTransientHttpErrorPolicy(builder => builder.WaitAndRetryAsync(new[]
{
    TimeSpan.FromSeconds(1),
    TimeSpan.FromSeconds(5),
    TimeSpan.FromSeconds(10)
}));

这里用了一个新的AddTransientHttpErrorPolicy方法，它可以很方便地配置一个策略来处理下面这些典型的HTTP调用错误：

  • 网络错误（HttpRequestException 异常）
  • HTTP状态码 5XX（服务器错误）
  • HTTP状态码 408（请求超时）

AddTransientHttpErrorPolicy方法添加了一个策略，这个策略默认预配置了上面HTTP错误的过滤器。在builder => builder子句中，你可以定义策略如何处理这些错误，还可以配置Polly提供的其它策略，比如重试（如上例所示）、断路或回退等。

在AddTransientHttpErrorPolicy中处理网络错误、HTTP 5XX和HTTP 408是一种便捷的方式，但这不是必需的。如果此方法内置的错误过滤器不适合您的需要（你需要仔细考虑一下），您可以扩展它，或者构建一个完全定制的Polly策略。

扩展 AddTransientHttpErrorPolicy

AddTransientHttpErrorPolicy方法也可以从Polly的一个扩展包Polly.Extensions.Http中得到，它在上面的基础上进行了扩展。例如下面配置的策略可以处理429状态码： 

using Polly.Extensions.Http;

// ...

var policy = HttpPolicyExtensions
  .HandleTransientHttpError() // HttpRequestException, 5XX and 408
  .OrResult(response => (int)response.StatusCode == 429) // RetryAfter
  .WaitAndRetryAsync(/* etc */);

使用典型Polly语法配置好的策略

Polly 还有另一个扩展方法是AddPolicyHandler，它的一个重载方法可以接收任意IAsyncPolicy参数，所以你可以用典型的Polly语法先定义好任意的一个策略（返回类型为IAsyncPolicy），然后再传给AddPolicyHandler扩展方法。

下面这个例子演示了用AddPolicyHandler来添加一个策略，其中我们编写了自己的错误处理策略： 

var retryPolicy = Policy.Handle<HttpRequestException>()
    .OrResult<HttpResponseMessage>(response => MyCustomResponsePredicate(response))
    .WaitAndRetryAsync(new[]
    {
        TimeSpan.FromSeconds(1),
        TimeSpan.FromSeconds(5),
        TimeSpan.FromSeconds(10)
    }));

services.AddHttpClient("GitHub", client =>
{
    client.BaseAddress = new Uri("https://api.github.com/");
    client.DefaultRequestHeaders.Add("Accept", "application/vnd.github.v3+json");
})
.AddPolicyHandler(retryPolicy);

类似的，你还可以配置其它策略，比如超时策略： 

var timeoutPolicy = Policy.TimeoutAsync<HttpResponseMessage>(10);

services.AddHttpClient(/* etc */)
    .AddPolicyHandler(timeoutPolicy);

所有通过HttpClient的调用返回的都是一个HttpResponseMessage对象，因此配置的策略必须是IAsyncPolicy对象（译注：HTTP请求返回的是HttpResponseMessage对象，Polly定义的策略是一个IAsyncPolicy对象，所以AddPolicyHandler方法接收的参数是这两者的结合体IAsyncPolicy对象）。非泛型的IAsyncPolicy可以通过下面的方式转换成泛型的IAsyncPolicy： 

var timeoutPolicy = Policy.TimeoutAsync(10);

services.AddHttpClient(/* etc */)
    .AddPolicyHandler(timeoutPolicy.AsAsyncPolicy<HttpResponseMessage>());

应用多个策略

所有策略配置的方法也可以链式地配置多个策略，例如： 

services.AddHttpClient(/* etc */)
    .AddTransientHttpErrorPolicy(builder => builder.WaitAndRetryAsync(new[]
    {
        TimeSpan.FromSeconds(1),
        TimeSpan.FromSeconds(5),
        TimeSpan.FromSeconds(10)
    }))
    .AddTransientHttpErrorPolicy(builder => builder.CircuitBreakerAsync(
        handledEventsAllowedBeforeBreaking: 3,
        durationOfBreak: TimeSpan.FromSeconds(30)
    ));

多个策略被应用的顺序

当您配置多个策略时（如上例所示），策略应用于从外部（第一次配置）到内部（最后配置）的顺序依次调用。在上面的示例中，调用的顺序是这样的：

  1. 首先通过（外部）重试策略，该策略将依次：
  2. 通过（内部）断路策略的调用，该策略将依次：
  3. 进行底层HTTP调用。

这个示例之所以用此顺序的策略是因为当重试策略在两次尝试之间等待时，断路器可能在其中一个时间段（1、5或10秒）内改变状态（译注：上面示例中断路策略是出现3次异常就“休息”30分钟）。断路策略被配置在重试策略的内部，因此每执行一次重试就会执行其内部的断路策略。

上面的例子应用了两个策略（重试和断路），任意数量的策略都是可以的。一个常见的多个策略组合可能是这样的：重试、断路和超时（“下篇”会有例子）。

对于那些熟悉Polly的策略包的人来说，使用上面的方式配置多个策略完全等同于使用策略包，也适用于所有“策略包的使用建议”（链接：http://t.cn/EhJ4jfN）。

动态选择策略

AddPolicyHandler的重载方法允许你根据HTTP请求动态选择策略。

其中一个用例是对非等幂的操作应用不同的策略行为（译注：“等幂“指的是一个操作重复使用，始终都会得到同一个结果）。对于HTTP请求来说，POST操作通常不是幂等的（译注：比如注册），PUT操作应该是幂等的。所以对于给定的API可能不是一概而论的。比如，您可能想要定义一个策略，让它只重试GET请求，但不重试其他HTTP谓词，比如这个示例： 

var retryPolicy = HttpPolicyExtensions
    .HandleTransientHttpError()
    .WaitAndRetryAsync(new[]
    {
        TimeSpan.FromSeconds(1),
        TimeSpan.FromSeconds(5),
        TimeSpan.FromSeconds(10)
    });
var noOpPolicy = Policy.NoOpAsync().AsAsyncPolicy<HttpResponseMessage>();

services.AddHttpClient(/* etc */)
    // 如果是GET请求，则使用重试策略，否则使用空策略
    .AddPolicyHandler(request => request.Method == HttpMethod.Get ? retryPolicy : noOpPolicy);

上面的空策略会被应用于所有非GET的请求。空策略只是一种占坑模式，实际上不做任何事情。

从策略的注册池中选择策略

Polly还提供了策略注册池（请参阅：http://t.cn/Ehi1SQp ），它相当于策略的存储中心，被注册的策略可以让你在应用程序的多个位置重用。AddPolicyHandler的一个重载方法允许您从注册池中选择策略。

下面的示例使用IServiceCollection添加一个策略注册池服务，向注册池中添加一些策略，然后使用注册池中的不同策略定义两个调用逻辑。 

var registry = services.AddPolicyRegistry();

registry.Add("defaultretrystrategy", 
    HttpPolicyExtensions.HandleTransientHttpError().WaitAndRetryAsync(/* etc */));
registry.Add("defaultcircuitbreaker", 
    HttpPolicyExtensions.HandleTransientHttpError().CircuitBreakerAsync(/* etc */));

services.AddHttpClient(/* etc */)
    .AddPolicyHandlerFromRegistry("defaultretrystrategy");

services.AddHttpClient(/* etc */)
    .AddPolicyHandlerFromRegistry("defaultretrystrategy")
    .AddPolicyHandlerFromRegistry("defaultcircuitbreaker");

这个示例演示了从注册池中选择一个或多个策略应用在不同的HttpClient上，同一个策略被重复使用了两次。策略注册池的更复杂用例包括从外部动态更新注册池中的策略，以便在运行期间动态重新配置策略（请查阅 http://t.cn/Ehidgqy 了解更多）。

相关阅读：

.NET 开源项目 Polly 介绍

在 .NET Core 中结合 HttpClientFactory 使用 Polly（上篇）

在 .NET Core 中结合 HttpClientFactory 使用 Polly（下篇）

相关阅读

目录[+]