65 lines
2.2 KiB
C#
65 lines
2.2 KiB
C#
using Microsoft.Extensions.Logging;
|
|
using Newtonsoft.Json;
|
|
using Polly;
|
|
using Polly.Wrap;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Net;
|
|
using System.Net.Http;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace Microsoft.eShopOnContainers.BuildingBlocks.Resilience.Http
|
|
{
|
|
/// <summary>
|
|
/// HttpClient wrapper that integrates Retry and Circuit
|
|
/// breaker policies when invoking HTTP services.
|
|
/// Based on Polly library: https://github.com/App-vNext/Polly
|
|
/// </summary>
|
|
public class ResilientHttpClient : IHttpClient
|
|
{
|
|
private HttpClient _client;
|
|
private PolicyWrap _policyWrapper;
|
|
private ILogger<ResilientHttpClient> _logger;
|
|
public HttpClient Inst => _client;
|
|
|
|
public ResilientHttpClient(Policy[] policies, ILogger<ResilientHttpClient> logger)
|
|
{
|
|
_client = new HttpClient();
|
|
_logger = logger;
|
|
|
|
// Add Policies to be applied
|
|
_policyWrapper = Policy.WrapAsync(policies);
|
|
}
|
|
|
|
public Task<string> GetStringAsync(string uri) =>
|
|
HttpInvoker(() =>
|
|
_client.GetStringAsync(uri));
|
|
|
|
public Task<HttpResponseMessage> PostAsync<T>(string uri, T item) =>
|
|
// a new StringContent must be created for each retry
|
|
// as it is disposed after each call
|
|
HttpInvoker(() =>
|
|
{
|
|
var response = _client.PostAsync(uri, new StringContent(JsonConvert.SerializeObject(item), System.Text.Encoding.UTF8, "application/json"));
|
|
// raise exception if HttpResponseCode 500
|
|
// needed for circuit breaker to track fails
|
|
if (response.Result.StatusCode == HttpStatusCode.InternalServerError)
|
|
{
|
|
throw new HttpRequestException();
|
|
}
|
|
|
|
return response;
|
|
});
|
|
|
|
public Task<HttpResponseMessage> DeleteAsync(string uri) =>
|
|
HttpInvoker(() => _client.DeleteAsync(uri));
|
|
|
|
|
|
private Task<T> HttpInvoker<T>(Func<Task<T>> action) =>
|
|
// Executes the action applying all
|
|
// the policies defined in the wrapper
|
|
_policyWrapper.ExecuteAsync(() => action());
|
|
}
|
|
|
|
}
|