Estoy usando Polly para implementar reintentos de solicitud. Sin embargo, después de que se devuelve una respuesta 500 para una solicitud, Polly no solo no envía una solicitud cuando vuelve a intentarlo, sino que no se envía ninguna solicitud hasta que se reinicia el proceso. En cambio, Polly solo espera hasta que haya un tiempo de espera. El siguiente es el código:
var timeoutPolicy = TimeoutPolicy .TimeoutAsync<HttpResponseMessage>(c => c.GetTimeout() ?? TimeSpan.FromSeconds(30)); //timeout para cada intento var retryPolicy = HttpPolicyExtensions .HandleTransientHttpError() .Or<TimeoutRejectedException>() //tirado por la TimeoutPolicy .WaitAndRetryAsync(new[] { TimeSpan.FromSeconds(1), TimeSpan.FromSeconds(5), TimeSpan.FromSeconds(10) }); var policyHandler = new PolicyHandler(Policy.WrapAsync(retryPolicy, timeoutPolicy));¿Cómo puedo arreglar el código de modo que Polly realmente envíe la solicitud cuando vuelva a intentar después de 500 y también para las siguientes solicitudes?
El error fue causado por el siguiente problema
Así es como lo arreglé:
var retryPolicy = HttpPolicyExtensions .HandleTransientHttpError() .Or<TimeoutRejectedException>() //tirado por la TimeoutPolicy .WaitAndRetryAsync(new[] { TimeSpan.FromSeconds(1), TimeSpan.FromSeconds(5), TimeSpan.FromSeconds(10) }, onRetry: (x, _) => { //dispose response when retrying x.Result?.Dispose(); });Creo que el bloqueo de la aplicación no está relacionado con estas políticas.
He modificado su código con algunos registros de depuración como este:
public static readonly HttpClient client = new HttpClient(); public static async Task Main(string[] args) { var sw = Stopwatch.StartNew(); Console.WriteLine($"{sw.Elapsed.Seconds}: Application starts"); var timeoutPolicy = TimeoutPolicy .TimeoutAsync<HttpResponseMessage>( TimeSpan.FromSeconds(30), onTimeoutAsync: (ctx, ts, t) => { Console.WriteLine($"{sw.Elapsed.Seconds}: Timeout has occurred"); return Task.CompletedTask; }); var retryPolicy = HttpPolicyExtensions .HandleTransientHttpError() .Or<TimeoutRejectedException>() .WaitAndRetryAsync( new[] { TimeSpan.FromSeconds(1), TimeSpan.FromSeconds(5), TimeSpan.FromSeconds(10) }, onRetryAsync: (dr, ts) => { Console.WriteLine($"{sw.Elapsed.Seconds}: Retry will be triggered"); return Task.CompletedTask; }); var strategy = Policy.WrapAsync(retryPolicy, timeoutPolicy); await strategy.ExecuteAsync(async (ct) => { var response = await client.GetAsync("https://httpstat.us/500"); Console.WriteLine($"{sw.Elapsed.Seconds}: Response has been received"); return response; }, CancellationToken.None); Console.WriteLine($"{sw.Elapsed.Seconds}: Application finishes"); }Response has been received cada vez que el httpClient ha recibido una respuesta.httpstat.us solo con fines de pruebaTimeout has occurred cada vez que el httpClient no recibió una respuesta en menos de 30 segundos.Retry will be triggered cada vez que se deba activar la política de reintento, pero antes de la penalización por retrasoApplication finishes cada vez que se emiten todos los reintentos y ninguno de ellos tuvo éxito o cuando una de las solicitudes tiene éxitoCon la configuración actual, la salida se vería así:
1: Response has been received 1: Retry will be triggered 2: Response has been received 2: Retry will be triggered 8: Response has been received 8: Retry will be triggered 18: Response has been received 18: Application finishesComo puede ver, hemos emitido 4 solicitudes (una inicial y 3 reintentos) sin suerte. Pero al final la aplicación ha continuado su trabajo.