基于请求条件的断路器 选项 A选项 B

问题描述

我需要设置断路策略，以便它仅针对某些特定请求断路。

我有一种网关 A 调用 API B，后者又调用 C 或 D。我正在 A 中设置断路器策略。到达 A 的初始请求有一个参数，稍后用于决定是调用 C 还是 D，比如说{ {1}}。我希望以这种方式配置断路器，该电路可以为 C 和 D 分别打开。我的意思是，如果 D 失败，使用 http://gateway.A.com?usageParam=C 的调用应该立即失败，但 usageParam=D 应该仍然正常，反之亦然。

解决方法

简单来说，断路器只能有一个状态。其中之一：Closed、Open、Half-Open。

您应该将 CB 视为代理。如果下游系统被认为是健康的，它允许每个请求通过它。如果 CB 检测到瞬时故障（通过检查响应，如果有的话），那么它将通过拒绝所有请求来缩短执行时间。

---

因此，如果您想区分 C 和 D 下游系统的健康状况，那么您需要两个 CB（每个一个）。这允许您分别允许或拒绝针对不同子系统的传出请求。

选项 A

您可以将两个 CB 放在服务 A 中。在这里你可以注册两个命名的 HttpClients，它们用不同的断路器装饰：

private IAsyncPolicy<HttpResponseMessage> GetCBPolicy()
    => HttpPolicyExtensions
        .HandleTransientHttpError()
        .CircuitBreakerAsync(2,TimeSpan.FromSeconds(1));

...
services.AddHttpClient("CService",c => { 
            c.BaseAddress = new Uri(BServiceBasePath);
            ... 
         })
        .AddPolicyHandler(GetCBPolicy());
services.AddHttpClient("DService" c => { 
            c.BaseAddress = new Uri(BServiceBasePath);
            ... 
         })
        .AddPolicyHandler(GetCBPolicy());

但是您必须手动进行路由，如下所示：

if(!Context.Request.Query.TryGetValue("usageParam",out var usage))
   return;

HttpClient client = usage switch
{
    "C" => _clientFactory.CreateClient("CService"),"D" => _clientFactory.CreateClient("DService"),_ => throw new NotSupportedException("..."),};

选项 B

您可以将两个 CB 放在服务 B 中。在这里你可以注册两个类型化的 HttpClient，它们用不同的断路器装饰：

private IAsyncPolicy<HttpResponseMessage> GetCBPolicy()
    => HttpPolicyExtensions
        .HandleTransientHttpError()
        .CircuitBreakerAsync(2,TimeSpan.FromSeconds(1));

...
services.AddHttpClient<ICService,CService>()
        .AddPolicyHandler(GetCBPolicy());
services.AddHttpClient<IDService,DService>()
        .AddPolicyHandler(GetCBPolicy());