雷达智富

首页 > 内容 > 程序笔记 > 正文

程序笔记

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

2024-10-23 28

在 .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 应用程序中应用复原策略。

更新于:20天前
赞一波!

文章评论

评论问答