长期以来,.NET开发者都通过下面的方式发送http请求:

  1. using (var httpClient = new HttpClient())
  2. {
  3. var response = await httpClient.GetAsync(uri);
  4. //do something with response
  5. }

这段代码理论上来说遵守了C#的最佳实践,HttpClient是IDisposable类型,所以我们通过using语法糖来使用HttpClient。微软官方的文档也提到:

As a rule, when you use an IDisposable object, you should declare and instantiate it in a using statement

可是,当我们试图运行下面的测试:

  1. public static async Task SendRequest()
  2. {
  3. Console.WriteLine("Starting reqeust");
  4. for(int i = 0; i<10; i++)
  5. {
  6. using(var client = new HttpClient())
  7. {
  8. var result = await client.GetAsync("http://www.baidu.com");
  9. Console.WriteLine(result.StatusCode);
  10. }
  11. }
  12. Console.WriteLine("Reqeust done");
  13. }

此时在terminal下列出所有端口:

  1. netstat -ap tcp | grep -i "time_wait"


你会发现本地开启了10个端口,这说明HttpClient的工作原理其实跟我们认为的IDisposable是有区别的,如果你把HttpClient用作大规模的Http请求,实际上会创建很多个Http连接,而且这些资源并不能被立即释放。一个显而易见的改进方法是共享同一个HttpClient实例,从而达到节约socket资源的目的。

  1. private static readonly HttpClient _client = new HttpClient();
  2. public async Task SendRequest2()
  3. {
  4. _testOutputHelper.WriteLine("Start request");
  5. for(int i = 0; i<10; i++)
  6. {
  7. var result = await _client.GetAsync("http://www.baidu.com");
  8. Console.WriteLine(result.StatusCode);
  9. }
  10. _testOutputHelper.WriteLine("Request done");
  11. }

这个方案似乎解决了问题,使用单例的HttpClient的确会减少Socket资源,但是这个方案会引发新的问题:由于这个Http连接始终保持连接状态,所以当请求地址的DNS发生更新的时候并不会应用到这个Http连接上。这个问题在微服务,高可用时代更加常见Singeton HttpClient doesn’t respect DNS changes

最终,一个叫做HttpClientFactory的开源实现用来彻底解决这个问题。微软也将HttpClientFactory集成在了.NET Core中。

  1. Microsoft.Extensions.Http
  1. services.AddHttpClient();
  1. public class BasicUsage
  2. {
  3. private readonly IHttpClientFactory _clientFactory;
  4. public BasicUsage(IHttpClientFactory clientFactory)
  5. {
  6. _clientFactory = clientFactory;
  7. }
  8. public async Task SendRequest()
  9. {
  10. var request = new HttpRequestMessage(HttpMethod.Get, "http://www.baidu.com");
  11. var client = _clientFactory.CreateClient();
  12. var response = await client.SendAsync(request);
  13. //do something for response
  14. }
  15. }

由于我们在DI容器中注册了唯一的HttpClientFactory,意味着通过HttpClientFactory创建出来的HttpClient可能是同一个配置和参数,如果你需要不同配置的HttpClient,你可以通过“起名字的”的方式注册不同的HttpClient。

  1. services.AddHttpClient("baidu", c =>
  2. {
  3. c.BaseAddress = new Uri("https://www.baidu.com");
  4. c.DefaultRequestHeaders.Add("Accept", "application/json");
  5. });

一旦注册了一个名叫“baidu”的HttpClient,你就可以通过下面的方式来建创建HttpClient:

  1. var client = _clientFactory.CreateClient("baidu");

Polly是一个用来故障处理库,它允许开发者在Http请求中添加“重试、熔断器、超时等”策略。
先添加Nuget:

  1. Microsoft.Extensions.Http.Polly

添加策略:

  1. var timeout = Policy.TimeoutAsync<HttpResponseMessage>(TimeSpan.FromSeconds(10));
  2. services.AddHttpClient("baidu")
  3. .AddPolicyHandler(request => timeout)
  4. .AddTransientHttpErrorPolicy(p=>p.RetryAsync(3));

当然还有一些高阶用法,详见Initiate HTTP requests,总之HttpClientFactory提供了一种高效实用HttpClient的方式,如果你还在自己new HttpClient,请赶快试试新的方案吧。

版权声明:本文为xiandnc原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/xiandnc/p/10215187.html