Polly Circuit Breaker не поддерживает состояние с. net core HTTP Client - PullRequest
Новая
       84

Polly Circuit Breaker не поддерживает состояние с. net core HTTP Client

0 голосов
/ 24 января 2020

Я реализовал политику повторных попыток и политики автоматического выключателя (упаковано). когда вызов не удался, и канал разомкнут для предыдущего вызова, следующий вызов снова переходит к повторной попытке и снова включает прерыватель цепи вместо того, чтобы просто вызвать исключение прерывания цепи. Я думаю, что клиент HTTP снова воссоздается, хотя я использую типизированный клиент. Я не могу понять проблему. Вот код

Запуск 

    public void ConfigureServices(IServiceCollection services)
    {
        services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);
        services.AddHttpClient<IIntCall, IntCall>().WrapResilientPolicies();
    }

Интерфейс 

public interface IIntCall
    {
        Task<bool> DoSomething();
    }

Реализация: 

public class IntCall : IIntCall
    {
    private readonly HttpClient client;

    public IntCall(HttpClient httpClient)
    {
        this.client = httpClient;
    }

    public async Task<bool> DoSomething()
    {
        var response = await client.GetAsync("http://www.onegoogle.com");
        var content = await response.Content.ReadAsStringAsync();
        return false;
    }
}

Реализация Polly 

public static class CBExtensions
    {
        public static void WrapResilientPolicies(this IHttpClientBuilder builder)
        {
            builder.AddPolicyHandler((service, request) =>
            GetRetryPolicy().WrapAsync(GetCircuitBreakerPolicy()));
        }

    private static IAsyncPolicy<HttpResponseMessage> GetCircuitBreakerPolicy()
    {
        return HttpPolicyExtensions.HandleTransientHttpError()
            .CircuitBreakerAsync(3, TimeSpan.FromSeconds(30), (result, retryAttempt) =>
            {
                Debug.WriteLine("circuit broken");
            },
            () =>
            {
                Debug.WriteLine("circuit closed");
            });
    }

    private static IAsyncPolicy<HttpResponseMessage> GetRetryPolicy()
    {
        return HttpPolicyExtensions.HandleTransientHttpError()
            .Or<Exception>(e => !(e is BrokenCircuitException))
          .WaitAndRetryAsync(3,
              retryAttempt => TimeSpan.FromMilliseconds(500),
              onRetry: (context, attempt) =>
              {
                  Debug.WriteLine("error");
              }
          );
    }
}

1 Ответ

0 голосов
/ 24 января 2020

Я понял проблему. потому что я получаю детали запроса, политика вводится при каждом вызове и, следовательно, состояние обновляется. Я переместил свой код с 

public static void WrapResilientPolicies(this IHttpClientBuilder builder)
        {
            builder.AddPolicyHandler((service, request) =>
            GetRetryPolicy().WrapAsync(GetCircuitBreakerPolicy()));
        }

на этот 

public static void WrapResilientPolicies(this IHttpClientBuilder builder)
        {
            builder.AddPolicyHandler(
                GetRetryPolicy().WrapAsync(GetCircuitBreakerPolicy()));
        }
...