.NET 使用HttpClientFactory+Polly替代直接使用HttpClient

在 .NET 开发中，了解如何发出高效、可靠且可伸缩的 Web 请求至关重要。曾几何时，在 .NET 的土地上，开发人员习惯于发出 Web 请求。这很简单：

var client = new HttpClient();  
var response = await client.GetAsync("https://example.com");  
var content = await response.Content.ReadAsStringAsync();

这个代码片段看起来无辜而有效，然而，随着应用程序的增长和请求数量的增加，开发人员开始遇到神秘的问题。这些问题的根源在于对 的误用。

直接使用 HttpClient 的陷阱

插座耗尽：每次为请求创建新实例时，它都会占用一个套接字。由于TIME_WAIT状态，使用后处理不会立即释放插座。在高负载情况下，这可能会导致套接字耗尽，从而影响应用程序进行传出连接的能力。

资源浪费：重复创建和处置实例会占用大量资源。这可能会导致不必要的开销和性能下降。

配置不一致：管理多个实例可能会导致请求之间的配置不一致，从而更难实现超时、标头和错误处理等全局策略。

HttpClientFactory 的进入

为了应对这些挑战，.NET 推出了HttpClientFactory，使其成为 Web 请求的最佳选择：

高效的资源管理

HttpClientFactory维护实例池。当不再需要实例时，该实例将返回到池中进行重用，从而减少套接字耗尽和资源浪费。

一致的配置

HttpClientFactory允许您集中配置实例。这可确保所有 HTTP 请求在标头、超时和其他策略方面保持一致。

提高弹性和 Poly 政策

与 Polly（一个弹性和瞬态故障处理库）的集成变得简单明了。这使开发人员能够轻松实施重试策略、断路器等，从而增强 HTTP 请求的稳健性。

使用 HttpClientFactory 进行实际测试

让我们踏上一场编码冒险，看看实际情况。首先，您需要在应用程序启动时注册：

// First, make sure you've installed the necessary Polly NuGet packages:  
// Microsoft.Extensions.Http.Polly  
// Polly  
  
var retryPolicy = HttpPolicyExtensions.HandleTransientHttpError() // Handle HTTP 5xx errors or HTTP 408 requests  
            .WaitAndRetryAsync(  
                retryCount: 3, // Retry three times  
                sleepDurationProvider: attempt => TimeSpan.FromSeconds(Math.Pow(2, attempt)), // Exponential backoff: 2, 4, 8 seconds  
                onRetry: (outcome, timespan, retryAttempt, context) =>  
                {  
                    // This is the action to take on each retry, log it or take some other action  
                    Console.WriteLine($"Retrying due to: {outcome.Exception?.Message}. Wait time: {timespan}. Attempt: {retryAttempt}.");  
                });  
  
// Register HttpClientFactory with Polly integration  
builder.Services.AddHttpClient("ExampleClient", client =>  
{  
    // This is where you can apply consistent configurations to all HttpClients  
    client.BaseAddress = new Uri("https://example.com");  
    client.DefaultRequestHeaders.Add("Accept", "application/json");  
    client.Timeout = TimeSpan.FromSeconds(30); // Set a global timeout for requests  
})  
.AddPolicyHandler(retryPolicy); // Use the Polly policy

接下来，注入到您的服务或控制器中：

public class MyService  
{  
    private readonly IHttpClientFactory _clientFactory;  
  
    public MyService(IHttpClientFactory clientFactory)  
    {  
        _clientFactory = clientFactory;  
    }  
  
    public async Task<string> GetWebContentAsync(string url)  
    {  
        var client = _clientFactory.CreateClient("ExampleClient");  
        var response = await client.GetAsync(url);  
        response.EnsureSuccessStatusCode();  
        var content = await response.Content.ReadAsStringAsync();  
        return content;  
    }  
}

在此示例中，我们首先使用 Polly 定义重试策略。该策略指定，我们应重试遇到暂时性错误的任何请求，最多三次，并呈指数退避。然后，我们向 The 注册，并将重试策略与其关联。现在，使用名称“ExampleClient”创建的所有 HTTP 客户端都将使用此策略和指定的配置，从而确保整个应用程序的一致性。

此模式具有以下优点：

弹性：通过优雅地处理暂时性故障，应用程序变得更有弹性。 一致的配置：使用出厂设置创建的所有实例将具有相同的基址、标头和超时设置，以确保一致性。 高效资源管理：管理底层处理程序，以优化连接池和生存期。

这种集成不仅使 HTTP 调用更加可靠，而且还简化了配置的管理和在整个 .NET 应用程序中应用复原策略。

更新于：1个月前