在 .NET 8 Web API 中实现弹性

在现代 Web 开发中，构建弹性 API 对于确保可靠性和性能至关重要。本文将指导您使用 Microsoft.Extensions.Http.Resilience 库在 .NET 8 Web API 中实现弹性。我们将介绍如何设置重试策略和超时，以使您的 API 更能抵御瞬时故障。

步骤 1.创建一个新的 .NET 8 Web API 项目

首先，如果您没有现有项目，请使用 .NET CLI 创建一个或使用默认的 Web API 模板。

步骤 2.添加所需的 NuGet 包

接下来，通过 NuGet 安装Microsoft.Extensions.Http.Resilience库：

dotnet add package Microsoft.Extensions.Http.Resilience --version 8.0.0

步骤 3.在 Program.cs 中配置 Resilience

修改 Program.cs 文件以使用 Microsoft.Extensions.Http.Resilience 提供的弹性策略设置 HttpClient。在这里，我们将定义重试策略和超时。

// 添加Resilience Pipeline
builder.Services.AddResiliencePipeline("default", x =>
{// 添加重试策略x.AddRetry(new Polly.Retry.RetryStrategyOptions{// 设置重试条件，处理所有异常ShouldHandle = new PredicateBuilder().Handle<Exception>(),// 设置重试的延迟时间为2秒Delay = TimeSpan.FromSeconds(2),// 最大重试次数为2次MaxRetryAttempts = 2,// 使用指数退避策略BackoffType = DelayBackoffType.Exponential,// 启用抖动，增加随机性以减少碰撞UseJitter = true})// 添加超时策略，超时时间为30秒.AddTimeout(TimeSpan.FromSeconds(30));
});

步骤 4.在服务中使用弹性 HttpClient

接下来，我们将在您的服务中注入并使用已配置的 HttpClient。此示例展示了如何使用弹性 HttpClient 从外部 API 获取数据。

public class WeatherService
{// HttpClient实例，用于发送HTTP请求private readonly HttpClient _httpClient;// 弹性管道提供程序private readonly ResiliencePipelineProvider<string> _resiliencePipelineProvider;// 构造函数，注入HttpClient和ResiliencePipelineProvider实例public WeatherService(HttpClient httpClient,ResiliencePipelineProvider<string> resiliencePipelineProvider){_httpClient = httpClient;_resiliencePipelineProvider = resiliencePipelineProvider;}// 异步方法，获取天气信息public async Task<string> GetWeatherAsync(){// 获取默认的弹性管道var pipeline = _resiliencePipelineProvider.GetPipeline("default");// 使用弹性管道执行HTTP GET请求var response = await pipeline.ExecuteAsync(async ct => await _httpClient.GetAsync($"https://localhost:7187/weatherforecast", ct));// 返回响应内容的字符串表示return await response.Content.ReadAsStringAsync();}
}

步骤 5. 在 Program.cs 中添加端点

app.MapGet("/weatherService/weather", async (WeatherService weatherService) =>
{// 调用WeatherService的GetWeatherAsync方法，获取天气信息var result = await weatherService.GetWeatherAsync();// 返回结果return result;
})// 设置该端点的名称为 "GetWeather".WithName("GetWeather")// 使该端点在OpenAPI文档中可见.WithOpenApi();