如何为YARP反向代理的HttpClient配置断路器模式

完全可行，YARP基于HttpClient构建，支持通过自定义DelegatingHandler扩展请求管道，你的CircuitBreakerAndRetryDelegatingHandler可以直接集成进去，步骤如下：

1. 注册自定义Handler到DI容器 #

因为你的Handler依赖IOptionsMonitor<AppSettings>，需要先把它注册到服务容器中：

builder.Services.AddTransient<CircuitBreakerAndRetryDelegatingHandler>();

2. 在YARP配置中添加Handler #

通过ConfigureHttpClient扩展方法，将自定义Handler注入到YARP使用的HttpClient管道中：

builder.Services.AddReverseProxy()
    .LoadFromMemory()
    .ConfigureHttpClient((context, handler) =>
    {
        // 将自定义断路器+重试Handler添加到请求管道
        handler.AddHttpMessageHandler<CircuitBreakerAndRetryDelegatingHandler>();
    });

3. 优化自定义Handler的实现（可选但推荐） #

原Handler有几个可以完善的地方，让策略更实用：

3.1 处理HTTP错误状态码 #

默认情况下，YARP不会将4xx/5xx状态码抛出HttpRequestException，所以需要让策略同时处理非成功响应：

private void UpdateCircuitBreakerConfig()
{
    // 断路器策略：捕获请求异常+非成功状态码
    var circuitBreakerPolicy = Policy.Handle<HttpRequestException>()
        .OrResult<HttpResponseMessage>(resp => !resp.IsSuccessStatusCode)
        .CircuitBreakerAsync(
            exceptionsAllowedBeforeBreaking: 3,
            durationOfBreak: TimeSpan.FromSeconds(30),
            onBreak: (ex, breakTime) => 
            {
                // 可添加熔断日志记录
            },
            onReset: () => 
            {
                // 可添加熔断恢复日志记录
            }
        );

    // 重试策略：捕获请求异常+非成功状态码，指数退避重试
    var retryPolicy = Policy.Handle<HttpRequestException>()
        .OrResult<HttpResponseMessage>(resp => !resp.IsSuccessStatusCode)
        .WaitAndRetryAsync(
            retryCount: 3,
            attempt => TimeSpan.FromSeconds(Math.Pow(2, attempt)),
            onRetry: (ex, delay, count, ctx) => 
            {
                // 可添加重试日志记录
            }
        );

    // 策略顺序：重试在外层，断路器在内层（WrapAsync第一个参数为内层策略）
    _circuitBreakerAndRetryPolicy = Policy.WrapAsync(retryPolicy, circuitBreakerPolicy);
}

3.2 明确泛型类型 #

为AsyncPolicyWrap指定泛型，避免隐式转换风险：

private AsyncPolicyWrap<HttpResponseMessage> _circuitBreakerAndRetryPolicy;

3.3 释放资源 #

在Handler中实现Dispose逻辑，释放IOptionsMonitor的变更订阅：

public override void Dispose()
{
    _onChangeDisposable?.Dispose();
    base.Dispose();
}

// 异步Dispose（适用于.NET Core 3.0+）
protected override async ValueTask DisposeAsync(bool disposing)
{
    if (disposing)
    {
        _onChangeDisposable?.Dispose();
    }
    await base.DisposeAsync(disposing);
}

3.4 修正ExecuteAsync泛型调用 #

确保策略执行时明确返回类型：

protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
{
    return await _circuitBreakerAndRetryPolicy.ExecuteAsync(
        async (ct) => await base.SendAsync(request, ct),
        cancellationToken
    );
}

工作原理 #

YARP为每个代理目标创建HttpClient实例，你的自定义Handler会被插入到HttpClient的消息处理管道中，所有代理请求都会经过该Handler，从而应用重试和断路器策略。同时借助IOptionsMonitor，你的策略配置可以动态更新，无需重启服务。

内容的提问来源于stack exchange，提问作者Ghanshyam Singh