如何解包IAsyncPolicy以获取Polly的ICircuitBreakerPolicy？

一、解包嵌套策略获取AsyncCircuitBreakerPolicy #

Polly的WrapAsync会生成AsyncPolicyWrap（或泛型AsyncPolicyWrap<TResult>）实例，其内部的Inner和Outer策略属性为非公开状态，需通过反射递归遍历嵌套结构，提取所有AsyncCircuitBreakerPolicy实例：

public static IEnumerable<AsyncCircuitBreakerPolicy> FindCircuitBreakers(this IAsyncPolicy policy)
{
    if (policy is AsyncCircuitBreakerPolicy circuitBreaker)
    {
        yield return circuitBreaker;
        yield break;
    }

    // 处理泛型策略（如IAsyncPolicy<HttpResponseMessage>）
    if (policy is IAsyncPolicy<HttpResponseMessage> genericPolicy)
    {
        foreach (var cb in FindCircuitBreakers(genericPolicy.As<IAsyncPolicy>()))
        {
            yield return cb;
        }
        yield break;
    }

    // 检查是否为PolicyWrap，递归遍历Inner和Outer
    var policyType = policy.GetType();
    if (policyType.Name.StartsWith("AsyncPolicyWrap", StringComparison.Ordinal))
    {
        var innerProp = policyType.GetProperty("Inner", BindingFlags.Instance | BindingFlags.NonPublic);
        var outerProp = policyType.GetProperty("Outer", BindingFlags.Instance | BindingFlags.NonPublic);

        if (innerProp?.GetValue(policy) is IAsyncPolicy innerPolicy)
        {
            foreach (var cb in innerPolicy.FindCircuitBreakers())
            {
                yield return cb;
            }
        }

        if (outerProp?.GetValue(policy) is IAsyncPolicy outerPolicy)
        {
            foreach (var cb in outerPolicy.FindCircuitBreakers())
            {
                yield return cb;
            }
        }
    }
}

使用时遍历注册表中的策略，调用该扩展方法即可提取断路器：

foreach (var entry in policyRegistry)
{
    var circuitBreakers = entry.Value.FindCircuitBreakers();
    foreach (var cb in circuitBreakers)
    {
        // 收集断路器状态用于健康检查
    }
}

注意：该方式依赖Polly内部类型命名与结构，版本更新时可能需要同步调整。

二、开箱即用的方案？ #

Polly官方未提供从IReadOnlyPolicyRegistry<string>中筛选所有断路器的开箱即用API，因为注册表仅作为策略存储容器，不对策略类型做分类管理。

三、自行维护断路器列表（推荐方案） #

相比反射解包，自行维护断路器实例列表更可靠、高效，且不依赖Polly内部实现：

1. 创建全局线程安全集合存储断路器实例：

private static readonly ConcurrentBag<AsyncCircuitBreakerPolicy> _circuitBreakers = new();

2. 创建策略时，先单独实例化断路器，再执行Wrap操作并将断路器加入集合：

var circuitBreaker = Policy
    .Handle<Exception>()
    .AdvancedCircuitBreakerAsync(failureThreshold, samplingDuration, minimumThroughput, durationOfBreak);

var timeoutPolicy = Policy.TimeoutAsync(timeout, TimeoutStrategy.Pessimistic);
var wrappedPolicy = circuitBreaker.WrapAsync(timeoutPolicy);

// 同时添加到注册表和断路器集合
policyRegistry.Add("MyPolicy", wrappedPolicy);
_circuitBreakers.Add(circuitBreaker);

3. 健康检查时直接遍历_circuitBreakers集合，获取每个断路器的状态（CircuitState、FailureRate等），即使断路器处于关闭状态也能生成检查条目。

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