用HttpClientFactory来实现简单的熔断降级

由于我们要实现熔断降级，所以，我们必不可少的要用到CircuitBreakerPolicy和FallbackPolicy，同时为了方便演示，再加个TimeoutPolicy。

由于涉及到多个Policy，所以我们必须要确定他们的执行顺序！

Polly的wiki页面有个示例，还配了一幅很详细的时序图。

一句话来说就是最先起作用的，还是最后添加的那个。

下面就新建一个API项目，用来演示一下。

修改ConfigureServices方法，具体如下

public void ConfigureServices(IServiceCollection services)
{
    var fallbackResponse = new HttpResponseMessage();
    fallbackResponse.Content = new StringContent("fallback");
    fallbackResponse.StatusCode = System.Net.HttpStatusCode.TooManyRequests;
services.AddHttpClient("cb",x =>
{
    x.BaseAddress = new Uri("http://localhost:8000");
    x.DefaultRequestHeaders.Add("User-Agent","HttpClientFactory-Test");
})
//fallback
.AddPolicyHandler(Policy<HttpResponseMessage>.Handle<Exception>().FallbackAsync(fallbackResponse,async b =>
{
    Logger.LogWarning($"fallback here {b.Exception.Message}");
}))
//circuit breaker
.AddPolicyHandler(Policy<HttpResponseMessage>.Handle<Exception>().CircuitBreakerAsync(2,TimeSpan.FromSeconds(4),(ex,ts) =>
{
    Logger.LogWarning($"break here {ts.TotalMilliseconds}");
},() =>
{                
    Logger.LogWarning($"reset here ");
}))
//timeout
.AddPolicyHandler(Policy.TimeoutAsync<HttpResponseMessage>(1));

services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1);
}

然后是在控制器去使用。

[Route("api/[controller]")]
[ApiController]
public class ValuesController : ControllerBase
{
    private static int myCount = 0;
private readonly IHttpClientFactory _clientFactory;

public ValuesController(IHttpClientFactory clientFactory)
{
    this._clientFactory = clientFactory;
}

// GET api/values/timeout
[HttpGet("timeout")]
public ActionResult<IEnumerable<string>> Timeout()
{
    if (myCount < 3)//模拟超时
    {
        System.Threading.Thread.Sleep(3000);
    }
    myCount++;

    return new string[] { "value1","value2" };
}

// GET api/values
[HttpGet("")]
public async Task<string> GetAsync()
{
    var client = _clientFactory.CreateClient("cb");

    var request = new HttpRequestMessage(HttpMethod.Get,"/api/values/timeout");
    var response = await client.SendAsync(request);
    var content = await response.Content.ReadAsStringAsync();

    return content;
}
}

效果如下

前面几次请求，会因为超时或熔断，从而我们得到的结果是fallback。

过了4秒钟后再请求，由于没有超时，正常拿到了结果，所以熔断器会被reset。

来看看日志

比较清晰的看到了所有的操作。

总体来说，HttpClientFactory还是很不错的。尤其是它可以直接使用Polly相关的特性。

部分示例代码：

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!