복원력 파이프라인

전략 조합하기

ResiliencePipelineBuilder

var pipeline = new ResiliencePipelineBuilder()
    .AddRetry(new RetryStrategyOptions())
    .AddTimeout(TimeSpan.FromSeconds(5))
    .Build();

순서가 중요합니다

var pipeline = new ResiliencePipelineBuilder()
    .AddTimeout(TimeSpan.FromSeconds(10))      // overall
    .AddRetry(new RetryStrategyOptions())
    .AddCircuitBreaker(new CircuitBreakerStrategyOptions())
    .AddTimeout(TimeSpan.FromSeconds(2))       // per attempt
    .Build();

형식이 지정된 pipeline

var pipeline = new ResiliencePipelineBuilder<HttpResponseMessage>()
    .AddRetry(new HttpRetryStrategyOptions())
    .Build();

상태를 전달하여 실행하기

await pipeline.ExecuteAsync(
    static async (state, token) => await state.CallAsync(token),
    myService);

ResiliencePipelineProvider

builder.Services.AddResiliencePipeline("db", pipeline =>
{
    pipeline.AddRetry(new RetryStrategyOptions())
            .AddTimeout(TimeSpan.FromSeconds(3));
});

이름이 지정된 pipeline 가져오기

public class OrderService
{
    private readonly ResiliencePipeline _pipeline;
    public OrderService(ResiliencePipelineProvider<string> provider)
    {
        _pipeline = provider.GetPipeline("db");
    }
}

HttpClient의 복원력

builder.Services.AddHttpClient<CatalogClient>()
    .AddResilienceHandler("catalog", b =>
    {
        b.AddRetry(new HttpRetryStrategyOptions());
        b.AddCircuitBreaker(new HttpCircuitBreakerStrategyOptions());
    });

표준 복원력 처리기

builder.Services.AddHttpClient<CatalogClient>()
    .AddStandardResilienceHandler();

Pipeline은 재사용 가능하고 비용이 적습니다

관찰성 확장 지점

빠른 확인

요약