HttpClientFactory+Refit集成Polly实现Fallback的问题求助

问题的核心在于你当前的Polly策略是绑定在HttpClient的HttpResponseMessage级别，而Refit需要将这个消息转换为ApiResponse<T>，模拟的空HttpResponseMessage缺少必要的请求上下文（比如RequestMessage）导致转换失败。更合理的方案是将Polly策略直接绑定到Refit的ApiResponse<T>返回类型上，这样就能直接返回自定义的业务对象作为降级结果。

核心思路 #

放弃在HttpClient层面配置策略，转而在Refit接口的调用层面应用Polly策略，让策略直接处理ApiResponse<T>类型，降级时直接构造包含自定义对象的ApiResponse<T>，跳过HttpResponseMessage的转换环节。

具体实现步骤 #

1. 定义你的Refit接口 #

假设你的业务返回对象是AccountDto，Refit接口定义如下：

public interface IAccountService
{
    [Get("/api/accounts/{id}")]
    Task<ApiResponse<AccountDto>> GetAccountAsync(int id, CancellationToken cancellationToken = default);
}

public class AccountDto
{
    public int Id { get; set; }
    public string Name { get; set; } = string.Empty;
    // 其他业务字段
}

2. 重新配置Polly策略（针对ApiResponse） #

重试策略

var retryPolicy = Policy<ApiResponse<AccountDto>>
    .Handle<Exception>()
    .OrResult(response => !response.IsSuccessStatusCode) // 同时捕获异常和非成功响应
    .WaitAndRetryAsync(
        Backoff.DecorrelatedJitterBackoffV2(medianFirstRetryDelay: TimeSpan.FromSeconds(1), retryCount: 5, fastFirst: true),
        (result, timeSpan, retryCount, context) =>
        {
            var errorMsg = result.Exception != null 
                ? result.Exception.Message 
                : $"HTTP状态码: {result.Result.StatusCode}";
            Debug.WriteLine($"Account Service调用出错，触发重试 | 重试次数: {retryCount} | 等待时间: {timeSpan.TotalSeconds}秒 | 错误信息: {errorMsg}");
        });

熔断策略

var circuitBreakerPolicy = Policy<ApiResponse<AccountDto>>
    .Handle<Exception>()
    .OrResult(response => !response.IsSuccessStatusCode)
    .CircuitBreakerAsync(
        exceptionsAllowedBeforeBreaking: 3, // 连续3次失败触发熔断
        durationOfBreak: TimeSpan.FromMinutes(1), // 熔断持续1分钟
        onBreak: (result, timespan, context) =>
        {
            Debug.WriteLine($"Account Service触发熔断，状态变为Open，将持续{timespan.TotalMinutes}分钟");
        },
        onReset: context =>
        {
            Debug.WriteLine($"Account Service熔断重置，状态变为Closed");
        });

降级策略（直接返回自定义对象）

var fallbackPolicy = Policy<ApiResponse<AccountDto>>
    .Handle<BrokenCircuitException>() // 捕获熔断异常
    .OrResult(response => !response.IsSuccessStatusCode) // 也可以针对其他失败场景降级
    .FallbackAsync(
        // 构造自定义的降级响应
        fallbackValue: new ApiResponse<AccountDto>(
            new AccountDto { Id = -1, Name = "降级默认账户" }, 
            HttpStatusCode.OK
        ),
        onFallbackAsync: (result, context) =>
        {
            Debug.WriteLine("触发降级逻辑，返回默认账户数据");
            return Task.CompletedTask;
        });

3. 组合策略并绑定到Refit客户端 #

将策略按顺序组合（降级→熔断→重试，顺序可根据业务需求调整），然后注册到Refit客户端：

// 组合策略：外层降级，中间熔断，内层重试
var combinedPolicy = Policy.WrapAsync(fallbackPolicy, circuitBreakerPolicy, retryPolicy);

// 注册Refit客户端并绑定策略
builder.Services.AddRefitClient<IAccountService>()
    .ConfigureHttpClient(c => c.BaseAddress = new Uri("https://your-account-service-url"))
    .AddPolicyHandler(combinedPolicy);

4. 调用Refit接口（自动应用策略） #

直接注入IAccountService调用即可，Polly策略会自动生效：

public class AccountController : ControllerBase
{
    private readonly IAccountService _accountService;

    public AccountController(IAccountService accountService)
    {
        _accountService = accountService;
    }

    [HttpGet("{id}")]
    public async Task<IActionResult> GetAccount(int id, CancellationToken cancellationToken)
    {
        var response = await _accountService.GetAccountAsync(id, cancellationToken);
        if (response.IsSuccessStatusCode)
        {
            return Ok(response.Content);
        }
        return StatusCode((int)response.StatusCode, response.Error);
    }
}

可选方案：如果必须在HttpClient层面处理 #

如果因为某些原因需要保留HttpClient层面的策略，你需要正确构造包含请求上下文和业务内容的HttpResponseMessage：

AsyncFallbackPolicy<HttpResponseMessage> fallbackPolicyForCircuitBreaker = Policy<HttpResponseMessage>
    .Handle<BrokenCircuitException>()
    .FallbackAsync((cancellationToken) =>
    {
        Debug.WriteLine($"断路器已打开，返回降级数据");
        var fallbackResponse = new HttpResponseMessage(HttpStatusCode.OK)
        {
            // 必须设置RequestMessage，否则Refit转换会报错
            RequestMessage = new HttpRequestMessage(HttpMethod.Get, "/api/accounts/1"),
            // 将自定义对象序列化为响应内容
            Content = JsonContent.Create(new AccountDto { Id = -1, Name = "降级默认账户" })
        };
        return Task.FromResult(fallbackResponse);
    });

这种方式需要提前知道请求路径，灵活性较差，不推荐优先使用。

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