c# - 如何在 RetryPolicy 上使用策略包装？

Question

我有以下使用 Polly.Extensions.Http 的重试策略:

var retryPolicy = Policy.Handle<BrokenCircuitException>().OrTransientHttpError().WaitAndRetryAsync
                (
                    retryCount: maxRetryCount,
                    sleepDurationProvider: attempt => TimeSpan.FromSeconds(Math.Pow(2, attempt)),
                    onRetryAsync: (exception, calculatedWaitDuration, retryCount, context) =>
                    {
                      //Code
                    }
                );

我想用断路器和舱头政策包装政策:

var circuitBreaker = Policy.Handle<HttpRequestException>().CircuitBreakerAsync(
            exceptionsAllowedBeforeBreaking: maxExceptionsBeforeBreaking,
            durationOfBreak: TimeSpan.FromSeconds(circuitBreakDurationSeconds),
            onBreak: (exception, timespan, context) =>
            {
              //Code
            },
            onReset: (context) =>
            {
                //Code
            }
        );

var sharedBulkhead = Policy.BulkheadAsync(
            maxParallelization: maxParallelizations,
            maxQueuingActions: maxQueuingActions,
            onBulkheadRejectedAsync: (context) =>
            {
                //Code
            }
        );

我使用以下代码将政策包装在一起:

Policy.WrapAsync(retryPolicy, circuitBreaker, sharedBulkhead);

这是一个错误:

can not convert from 'Polly.Retry.RetryPolicy<System.Net.Http.HttpResponseMessage>' to 'Polly.IAsyncPolicy'

Answer 1

当策略配置使用 .HandleTransientHttpError() or .OrTransientHttpError() 时，策略配置为处理 specific status code results执行返回 HttpResponseMessage .

这使得返回的策略类型满足通用接口(interface) IAsyncPolicy<HttpResponseMessage>而不是非通用的 IAsyncPolicy .

创建通用 PolicyWrap<TResult>使用 PolicyWrap static syntax您必须显式指定泛型类型参数:

Policy.WrapAsync<HttpResponseMessage>(retryPolicy, circuitBreaker, sharedBulkhead)

如果您使用 PolicyWrap instance syntax ，编译器通常可以推断语法。所以以下内容也应该足够了:

retryPolicy.WrapAsync(circuitBreaker).WrapAsync(sharedBulkhead)

---

Polly 文档涵盖了非通用策略和通用策略之间的差异，通常在 the readme 中和 wiki .