问题来源
长期以来,.NET 开发者都通过下面的方式发送 http 请求:
- using (var httpClient = new HttpClient())
- {
- var response = await httpClient.GetAsync(uri);
- //do something with response
- }
这段代码理论上来说遵守了 C# 的最佳实践, HttpClient 是 IDisposable 类型, 所以我们通过 using 语法糖来使用 HttpClient. 微软官方的文档也提到:
As a rule, when you use an IDisposable object, you should declare and instantiate it in a using statement
可是, 当我们试图运行下面的测试:
- public async Task SendRequest()
- {
- Console.WriteLine("Starting reqeust");
- for(int i = 0; i<10; i++)
- {
- using(var client = new HttpClient())
- {
- var result = await client.GetAsync("http://www.baidu.com");
- Console.WriteLine(result.StatusCode);
- }
- }
- Console.WriteLine("Reqeust done");
- }
此时在 terminal 下列出所有端口:
netstat -ap tcp | grep -i "time_wait"
你会发现本地开启了 10 个端口, 这说明 HttpClient 的工作原理其实跟我们认为的 IDisposable 是有区别的, 如果你把 HttpClient 用作大规模的 Http 请求, 实际上会创建很多个 Http 连接, 而且这些资源并不能被立即释放. 一个显而易见的改进方法是共享同一个 HttpClient 实例, 从而达到节约 socket 资源的目的.
- private static readonly HttpClient _client = new HttpClient();
- public async Task SendRequest2()
- {
- _testOutputHelper.WriteLine("Start request");
- for(int i = 0; i<10; i++)
- {
- var result = await _client.GetAsync("http://www.baidu.com");
- Console.WriteLine(result.StatusCode);
- }
- _testOutputHelper.WriteLine("Request done");
- }
这个方案似乎解决了问题, 使用单例的 HttpClient 的确会减少 Socket 资源, 但是这个方案会引发新的问题: 由于这个 Http 连接始终保持连接状态, 所以当请求地址的 DNS 发生更新的时候并不会应用到这个 Http 连接上. 这个问题在微服务, 高可用时代更加常见 Singeton HttpClient doesn't respect DNS changes https://github.com/dotnet/corefx/issues/11224 .
最终, 一个叫做 https://github.com/aspnet/HttpClientFactory 的开源实现用来彻底解决这个问题. 微软也将 HttpClientFactory 集成在了. NET Core 中.
在. NET Core 中创建 HttpClient
1. 添加 Nuget
Microsoft.Extensions.Http
2. 在 Dependency Injection 容器中注册服务
services.AddHttpClient();
3. 使用构造器注入使用 IhttpClientFactory
- public class BasicUsage
- {
- private readonly IHttpClientFactory _clientFactory;
- public BasicUsage(IHttpClientFactory clientFactory)
- {
- _clientFactory = clientFactory;
- }
- public async Task SendRequest()
- {
- var request = new HttpRequestMessage(HttpMethod.Get,
- "http://www.baidu.com");
- var client = _clientFactory.CreateClient();
- var response = await client.SendAsync(request);
- //do something for response
- }
- }
4. 使用 Named HttpClient
由于我们在 DI 容器中注册了唯一的 HttpClientFactory, 意味着通过 HttpClientFactory 创建出来的 HttpClient 可能是同一个配置和参数, 如果你需要不同配置的 HttpClient, 你可以通过 "起名字的" 的方式注册不同的 HttpClient.
- services.AddHttpClient("baidu", c =>
- {
- c.BaseAddress = new Uri("https://www.baidu.com");
- c.DefaultRequestHeaders.Add("Accept", "application/json");
- });
一旦注册了一个名叫 "baidu" 的 HttpClient, 你就可以通过下面的方式来建创建 HttpClient:
var client = _clientFactory.CreateClient("baidu");
5. 集成 Polly
https://github.com/App-vNext/Polly 是一个用来故障处理库, 它允许开发者在 Http 请求中添加 "重试, 熔断器, 超时等" 策略.
先添加 Nuget:
Microsoft.Extensions.Http.Polly
添加策略:
- var timeout = Policy.TimeoutAsync<HttpResponseMessage>(TimeSpan.FromSeconds(10));
- services.AddHttpClient("baidu")
- .AddPolicyHandler(request => timeout)
- .AddTransientHttpErrorPolicy(p=>p.RetryAsync(3));
当然还有一些高阶用法, 详见 Initiate HTTP requests, 总之 HttpClientFactory 提供了一种高效实用 HttpClient 的方式, 如果你还在自己 new HttpClient, 请赶快试试新的方案吧.
来源: https://www.cnblogs.com/xiandnc/p/10215187.html