小编点评

## .NET 如何处理服务发现和熔断限流？ .NET 使用以下库来处理服务发现和熔断限流： * **Microsoft.Extensions.ServiceDiscovery**：用于注册和发现服务。 * **Microsoft.Extensions.Resilience**：用于实现熔断限流。 **服务发现** 1. 使用 `AddHttpClient` 注册服务。 2. 创建 `IHttpClientBuilder` 实例。 3. 使用 `AddTransientHttpErrorPolicy` 配置熔断限流。 4. 使用 `AddStandardResilienceHandler` 配置其他弹性配置。 **熔断限流** 1. 创建 `IHttpClientBuilder` 实例。 2. 使用 `AddTransientHttpErrorPolicy` 配置熔断限流。 3. 使用 `AddCircuitBreaker` 配置熔断器。 4. 使用 `AddStandardResilienceHandler` 配置其他弹性配置。 **示例代码** ```csharp // 使用 Microsoft.Extensions.Http.Resilience builder.Services.AddHttpClient("qrcode", client => { client.BaseAddress = "http://qrcode"; }); builder.Services.AddStandardResilienceHandler(options => { options.Retry.MaxRetryAttempts = 3; options.TotalRequestTimeout.Timeout = TimeSpan.FromSeconds(30); options.AttemptTimeout.Timeout = TimeSpan.FromSeconds(5); }); // 使用 Microsoft.Extensions.ServiceDiscovery builder.Services.AddHttpClient("qrcode", client => { client.BaseAddress = "http://qrcode"; }); builder.Services.AddTransientHttpErrorPolicy((builder) => { var retryPolicy = builder.WaitAndRetryAsync(3, retryCount => TimeSpan.FromSeconds(5d)); return retryPolicy.WrapAsync(circuitBreakerPolicy); }); ``` **注意** * 这些库都支持多种弹性策略，例如熔断、重试和超时。 * 可根据实际需求选择不同的策略。 * 可以使用 `Configure` 方法在配置文件中配置弹性设置。

正文

接上一篇,https://www.cnblogs.com/vipwan/p/18129361 借助Aspire中新增的Microsoft.Extensions.ServiceDiscovery库,我们可以很容易的做到服务发现,那么服务节点的熔断限流以及重试等弹性机制.NET是怎么处理的呢?
比如下图的微服务场景:

这里就不得不提到 Microsoft.Extensions.Http.Polly这个Polly的封装库了,这个库是从NETCore2.1增加的,我们可以很容易的对IHttpClientBuilder扩展弹性机制,比如下面的代码:

builder.Services.AddHttpClient("qrcode", client =>
{
    client.BaseAddress = new("http://qrcode");
})
.AddTransientHttpErrorPolicy((builder) =>
{
    // 重试3次,每次间隔5秒
    var retryPolicy = builder.WaitAndRetryAsync(3, retryCount => TimeSpan.FromSeconds(5d));
    // 熔断器,失败3次后,30秒内不再请求
    var circuitBreakerPolicy = builder.CircuitBreakerAsync(3, TimeSpan.FromSeconds(30));
    // 重试策略包装熔断器
    return retryPolicy.WrapAsync(circuitBreakerPolicy);
});

然鹅Microsoft.Extensions.Http.Polly库是早些年就存在的产物了,针对Polly V8及后续的版本巨硬在 NET8后增加了 Microsoft.Extensions.Http.Resilience库作为替代方案.

下面是巨硬给出的两个版本的性能差异:

Method	Mean	Error	StdDev	Ratio	Gen0	Allocated	Alloc Ratio
StandardPipeline_Polly_V7	3.236 us	0.0130 us	0.0187 us	1.00	0.1488	3816 B	1.00
StandardPipeline_Polly_V8	3.104 us	0.0237 us	0.0317 us	0.96	0.0381	1008 B	0.26

速度较快的同时,基于 Polly v8 构建的Microsoft.Extensions.Http.Resilience使用的内存减少了4倍之多。
所以至NET8+以后我推荐使用Microsoft.Extensions.Http.Resilience替代Microsoft.Extensions.Http.Polly库

下面我们使用新库实现模拟的策略:

builder.Services.AddHttpClient("qrcode", client =>
{
    client.BaseAddress = new("http://qrcode");
})

// Microsoft.Extensions.Http.Polly实现的代码:
.AddTransientHttpErrorPolicy((builder) =>
{
    // 重试3次,每次间隔5秒
    var retryPolicy = builder.WaitAndRetryAsync(3, retryCount => TimeSpan.FromSeconds(5d));
    // 熔断器,失败3次后,30秒内不再请求
    var circuitBreakerPolicy = builder.CircuitBreakerAsync(3, TimeSpan.FromSeconds(30));

    // 重试策略包装熔断器
    return retryPolicy.WrapAsync(circuitBreakerPolicy);
})
// Microsoft.Extensions.Http.Resilience实现代码:
.AddStandardResilienceHandler(options =>
{
    options.Retry.MaxRetryAttempts = 3;
    options.TotalRequestTimeout.Timeout = TimeSpan.FromSeconds(30);// 总的超时时间
    options.AttemptTimeout.Timeout = TimeSpan.FromSeconds(5);//每次重试的超时时间
    options.CircuitBreaker.BreakDuration = TimeSpan.FromSeconds(30);//熔断时间
})
;

当然大多数情况弹性机制是放到配置文件或者其他持久层的这个时候我们可以使用Configure(IConfigurationSection) 或者 Configure(Action<HttpStandardResilienceOptions, IServiceProvider>)

.AddStandardResilienceHandler(options =>
{
    options.Retry.MaxRetryAttempts = 3;
    options.TotalRequestTimeout.Timeout = TimeSpan.FromSeconds(5);// 超时时间
    options.AttemptTimeout.Timeout = TimeSpan.FromSeconds(5);//每次重试的超时时间
    options.CircuitBreaker.BreakDuration = TimeSpan.FromSeconds(30);//熔断时间
})
.Configure((options, sp) =>
{
    // 配置来自自定义的Provider
    var myResiliencePolicy = sp.GetRequiredService<IResiliencePolicyProvider>().GetResiliencePolicy("MyPolicy");
    options.Retry.MaxRetryAttempts = myResiliencePolicy.Retry.MaxRetryAttempts;
});

从代码上来说也优雅了一些

当然也可以使用AddResilienceHandler扩展方法实现一些比较个性化的配置需求,这个就比较类似于Microsoft.Extensions.Http.Polly:

builder.Services.AddHttpClient("qrcode", client =>
{
    client.BaseAddress = new("http://qrcode");
})
.AddResilienceHandler("MyPolicy", builder =>
{
    builder.AddTimeout(TimeSpan.FromSeconds(5));
    builder.AddRetry(new HttpRetryStrategyOptions
    {
        MaxRetryAttempts = 3,
        Delay = TimeSpan.FromSeconds(2),
        MaxDelay = TimeSpan.FromSeconds(10),
    });
    //其他的机制....
});

参考文档 https://github.com/dotnet/docs/blob/main/docs/core/resilience/http-resilience.md

https://devblogs.microsoft.com/dotnet/building-resilient-cloud-services-with-dotnet-8/