我有以下使用 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'
最佳答案
当策略配置使用 .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 .
关于c# - 如何在 RetryPolicy<HttpResponseMessage> 上使用策略包装?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53942022/