记录 Polly 等待和重试策略 ASP.NET CORE 2.1
Logging Polly wait and retry policy ASP.NET CORE 2.1
我需要在 APS.NET CORE 2.1+ 中记录通过 Polly 定义的重试策略。
下面我的代码显示了 Polly 重试 polly 和使用 HttpClient。
public IServiceProvider ConfigureServices(IServiceCollection services)
{
//...
//https://github.com/App-vNext/Polly/wiki/Polly-and-HttpClientFactory
Random jitterer = new Random();
services.AddHttpClient<SimpleCastClient>()
//TransientErrors:
//Network failures(System.Net.Http.HttpRequestException)
//HTTP 5XX status codes(server errors)
//HTTP 408 status code(request timeout)
.AddTransientHttpErrorPolicy(policyBuilder =>
//Exponential backoff with Randomisation
policyBuilder.WaitAndRetryAsync(10,
retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt))
+ TimeSpan.FromMilliseconds(jitterer.Next(1, 100))
));
}
[ApiVersion("1")]
[Route("api/v{version:apiVersion}/[controller]")]
[ApiController]
public class MyController : ControllerBase
{
ILog _logger;
private SimpleCastClient _simpleCastClient;
public MyController(ILog logger, SimpleCastClient simpleCastClient)
{
_logger = logger;
_simpleCastClient = simpleCastClient;
}
[HttpPost]
public async Task Post()
{
await _simpleCastClient.PostAsync();
}
}
public class SimpleCastClient
{
private HttpClient _client;
public SimpleCastClient(HttpClient client)
{
_client = client;
}
public async Task PostAsync()
{
string url = $"http://localhost:1111/api/v1/Mock/";
using (var content = new StringContent("data", Encoding.UTF8, "application/json"))
{
var response = await _client.PostAsync(url, content);
}
}
}
我想知道是否有比 stevejgordon.
上更好的方法
由于您使用的是 ASP.NET 核心 2.1,请考虑使用 HttpClientFactory。非常适合 polly 并具有额外的好处,并且日志记录得到了简化。
https://github.com/App-vNext/Polly/wiki/Polly-and-HttpClientFactory
使用 HttpClientFactory,您可以将 Polly 策略应用于预配置的 HttpClient
,并使用在该 Polly 策略中的 DI 上配置的 ILogger
,代码如下:
services.AddHttpClient<MyServiceHttpClient>(/* etc */)
.AddPolicyHandler((services, request) => HttpPolicyExtensions.HandleTransientHttpError()
.WaitAndRetryAsync(new[]
{
TimeSpan.FromSeconds(1),
TimeSpan.FromSeconds(5),
TimeSpan.FromSeconds(10)
},
onRetry: (outcome, timespan, retryAttempt, context) =>
{
services.GetService<ILogger<MyServiceHttpClient>>()
.LogWarning("Delaying for {delay}ms, then making retry {retry}.", timespan.TotalMilliseconds, retryAttempt);
}
));
我需要在 APS.NET CORE 2.1+ 中记录通过 Polly 定义的重试策略。
下面我的代码显示了 Polly 重试 polly 和使用 HttpClient。
public IServiceProvider ConfigureServices(IServiceCollection services)
{
//...
//https://github.com/App-vNext/Polly/wiki/Polly-and-HttpClientFactory
Random jitterer = new Random();
services.AddHttpClient<SimpleCastClient>()
//TransientErrors:
//Network failures(System.Net.Http.HttpRequestException)
//HTTP 5XX status codes(server errors)
//HTTP 408 status code(request timeout)
.AddTransientHttpErrorPolicy(policyBuilder =>
//Exponential backoff with Randomisation
policyBuilder.WaitAndRetryAsync(10,
retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt))
+ TimeSpan.FromMilliseconds(jitterer.Next(1, 100))
));
}
[ApiVersion("1")]
[Route("api/v{version:apiVersion}/[controller]")]
[ApiController]
public class MyController : ControllerBase
{
ILog _logger;
private SimpleCastClient _simpleCastClient;
public MyController(ILog logger, SimpleCastClient simpleCastClient)
{
_logger = logger;
_simpleCastClient = simpleCastClient;
}
[HttpPost]
public async Task Post()
{
await _simpleCastClient.PostAsync();
}
}
public class SimpleCastClient
{
private HttpClient _client;
public SimpleCastClient(HttpClient client)
{
_client = client;
}
public async Task PostAsync()
{
string url = $"http://localhost:1111/api/v1/Mock/";
using (var content = new StringContent("data", Encoding.UTF8, "application/json"))
{
var response = await _client.PostAsync(url, content);
}
}
}
我想知道是否有比 stevejgordon.
上更好的方法由于您使用的是 ASP.NET 核心 2.1,请考虑使用 HttpClientFactory。非常适合 polly 并具有额外的好处,并且日志记录得到了简化。
https://github.com/App-vNext/Polly/wiki/Polly-and-HttpClientFactory
使用 HttpClientFactory,您可以将 Polly 策略应用于预配置的 HttpClient
,并使用在该 Polly 策略中的 DI 上配置的 ILogger
,代码如下:
services.AddHttpClient<MyServiceHttpClient>(/* etc */)
.AddPolicyHandler((services, request) => HttpPolicyExtensions.HandleTransientHttpError()
.WaitAndRetryAsync(new[]
{
TimeSpan.FromSeconds(1),
TimeSpan.FromSeconds(5),
TimeSpan.FromSeconds(10)
},
onRetry: (outcome, timespan, retryAttempt, context) =>
{
services.GetService<ILogger<MyServiceHttpClient>>()
.LogWarning("Delaying for {delay}ms, then making retry {retry}.", timespan.TotalMilliseconds, retryAttempt);
}
));