Basit Bir Rest Api Client Geliştirelim 4
2023-05-12
Bir sonraki adımda, HTTP istemci sınıfımızda önbellekleme ve otomatik yeniden deneme gibi özellikler ekleyebiliriz. Bu özellikler, API isteklerini daha verimli ve dayanıklı hale getirir. Bu geliştirmeleri yapmak için, Polly adlı bir kütüphaneyi kullanacağız.
using Polly;
using Polly.Caching;
using Polly.Caching.Memory;
using Polly.Registry;
using System;
using System.Collections.Generic;
using System.Net.Http;
using System.Text;
using System.Threading.Tasks;
public class MyHttpClient : IDisposable
{
private readonly HttpClient _client;
private readonly IPolicyRegistry<string> _policyRegistry;
public MyHttpClient(HttpClient client, IPolicyRegistry<string> policyRegistry, string baseAddress, TimeSpan? timeout = null, HttpMessageHandler handler = null)
{
_client = handler == null ? client : new HttpClient(handler);
_client.BaseAddress = new Uri(baseAddress);
if (timeout.HasValue)
{
_client.Timeout = timeout.Value;
}
_policyRegistry = policyRegistry;
}
private HttpRequestMessage CreateRequest(string uri, HttpMethod method, string jsonData = null, Dictionary<string, string> headers = null)
{
var request = new HttpRequestMessage(method, uri);
if (headers != null)
{
foreach (var header in headers)
{
request.Headers.Add(header.Key, header.Value);
}
}
if (!string.IsNullOrWhiteSpace(jsonData))
{
request.Content = new StringContent(jsonData, Encoding.UTF8, "application/json");
}
return request;
}
public async Task<HttpResponseMessage> SendRequestAsync(string uri, HttpMethod method, string jsonData = null, Dictionary<string, string> headers = null)
{
var request = CreateRequest(uri, method, jsonData, headers);
try
{
var policyWrap = Policy.WrapAsync(_policyRegistry.Get<IAsyncPolicy<HttpResponseMessage>>("RetryPolicy"),
_policyRegistry.Get<IAsyncPolicy<HttpResponseMessage>>("CachePolicy"));
var response = await policyWrap.ExecuteAsync(async () => await _client.SendAsync(request));
response.EnsureSuccessStatusCode();
return response;
}
catch (HttpRequestException ex)
{
throw new Exception($"{method} request to {uri} failed.", ex);
}
}
public async Task<string> GetAsync(string uri, Dictionary<string, string> headers = null) =>
(await SendRequestAsync(uri, HttpMethod.Get, null, headers)).Content.ReadAsStringAsync().Result;
public async Task<string> PostAsync(string uri, string jsonData, Dictionary<string, string> headers = null) =>
(await SendRequestAsync(uri, HttpMethod.Post, jsonData, headers)).Content.ReadAsStringAsync().Result;
public async Task<string> PutAsync(string uri, string jsonData, Dictionary<string, string> headers = null) =>
(await SendRequestAsync(uri, HttpMethod.Put, jsonData, headers)).Content.ReadAsStringAsync().Result;
public async Task<string> DeleteAsync(string uri, Dictionary<string, string> headers = null) =>
(await SendRequestAsync(uri, HttpMethod.Delete, null, headers)).Content.ReadAsStringAsync().Result;
public void SetAuthorizationHeader(string scheme, string parameter)
{
_client.DefaultRequestHeaders.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue(scheme, parameter);
}
public void Dispose()
{
_client?.Dispose();
}
}
Polly’nin nasıl yapılandırılacağına dair bir örnek:
public void ConfigureServices(IServiceCollection services)
{
services.AddHttpClient<MyHttpClient>();
services.AddSingleton<IAsyncCacheProvider, MemoryCacheProvider>();
services.AddSingleton<IPolicyRegistry<string>, PolicyRegistry>((serviceProvider) =>
{
var cacheProvider = serviceProvider.GetRequiredService<IAsyncCacheProvider>();
var policyRegistry = new PolicyRegistry();
// Retry policy
policyRegistry.Add("RetryPolicy", HttpPolicyExtensions
.HandleTransientHttpError()
.WaitAndRetryAsync(3, retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt))));
// Cache policy
policyRegistry.Add("CachePolicy", Policy.CacheAsync<HttpResponseMessage>(
cacheProvider.AsyncFor<HttpResponseMessage>(), TimeSpan.FromMinutes(5)));
return policyRegistry;
});
}
Bu yapılandırma, HTTP istemci sınıfımızın, her API isteği için otomatik yeniden deneme ve önbellekleme özelliklerine sahip olmasını sağlar. İstek başarısız olursa, yeniden deneme politikası belirli bir süre bekler ve ardından isteği yeniden dener. Bu, ağ hatalarını ve geçici API hatalarını tolere etmek için bize yardımcı olabilir.
Önbellekleme politikası, API yanıtlarını belirli bir süre boyunca önbelleğe alır. Bu, aynı API’ye birkaç saniye içinde birkaç kez istek yapmanız gerektiğinde kullanışlıdır. Bu politika, API isteklerinin sayısını azaltabilir ve uygulamanın performansını artırabilir.
Not: Bu örnekte, MemoryCacheProvider Polly’nin önbellek sağlayıcısı olarak kullanılmaktadır. Bu, yanıtları bellekte önbelleğe alır. Ancak, başka bir önbellek sağlayıcısı da kullanabilirsiniz. Örneğin, Redis önbellek sağlayıcısını kullanarak yanıtları Redis’te önbelleğe alabilirsiniz. Bu, önbelleğin birden çok sunucu arasında paylaşılmasını sağlar ve ölçeklenebilirliği artırır.