Basit Bir Rest Api Client Geliştirelim 7

2023-05-12

Birkaç özelleştirilebilir başlık ayarlama yeteneği ekleyelim. Bu özellik, belirli bir istek için özel HTTP başlıkları ayarlamayı kolaylaştıracaktır.

using Newtonsoft.Json;
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;
using Microsoft.Extensions.Logging;

public class MyHttpClient : IDisposable
{
    private readonly HttpClient _client;
    private readonly IPolicyRegistry<string> _policyRegistry;
    private readonly ILogger<MyHttpClient> _logger;

    public MyHttpClient(HttpClient client, IPolicyRegistry<string> policyRegistry, ILogger<MyHttpClient> logger, 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;
        _logger = logger;
    }

    public void SetDefaultHeader(string name, string value)
    {
        if (_client.DefaultRequestHeaders.Contains(name))
        {
            _client.DefaultRequestHeaders.Remove(name);
        }

        _client.DefaultRequestHeaders.Add(name, value);
    }

    public void RemoveDefaultHeader(string name)
    {
        _client.DefaultRequestHeaders.Remove(name);
    }

    // ...
    // ...
    // ...
}

Bu kod parçacığı, SetDefaultHeader ve RemoveDefaultHeader adında iki yeni yöntem ekler. SetDefaultHeader yöntemi, belirli bir isme sahip bir HTTP başlığını varsayılan değer olarak ayarlar. Eğer bu isimde bir başlık zaten varsa, önce mevcut başlık kaldırılır. RemoveDefaultHeader yöntemi, belirli bir isme sahip bir HTTP başlığını kaldırır.

Bu özellikler, belirli bir istek için özel HTTP başlıkları ayarlamanızı sağlar. Örneğin, belirli bir API’nin belirli bir özelliğini kullanırken özel bir User-Agent başlığı veya bir Accept-Language başlığı ayarlamak isteyebilirsiniz. Bu tür durumlar için, bu yöntemlerin her ikisi de çok yararlı olabilir.

Bu noktada, HTTP talepleri yapabilen ve yanıtları işleyebilen oldukça sağlam bir HTTP istemci sınıfımız var. Ancak, bir sonraki adım olarak, HTTP taleplerinin sonuçlarını izlemek ve hataları loga kaydetmek için daha gelişmiş bir hata yakalama ve log kaydetme mekanizması ekleyebiliriz. Bunun için, hataların izlenmesini ve loga kaydedilmesini sağlayacak bir hata işleyicisi ekleyelim.

using Newtonsoft.Json;
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;
using Microsoft.Extensions.Logging;

public class MyHttpClient : IDisposable
{
    private readonly HttpClient _client;
    private readonly IPolicyRegistry<string> _policyRegistry;
    private readonly ILogger<MyHttpClient> _logger;

    public MyHttpClient(HttpClient client, IPolicyRegistry<string> policyRegistry, ILogger<MyHttpClient> logger, 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;
        _logger = logger;
    }

    public void SetDefaultHeader(string name, string value)
    {
        if (_client.DefaultRequestHeaders.Contains(name))
        {
            _client.DefaultRequestHeaders.Remove(name);
        }

        _client.DefaultRequestHeaders.Add(name, value);
    }

    public void RemoveDefaultHeader(string name)
    {
        _client.DefaultRequestHeaders.Remove(name);
    }

    private async Task<T> HandleExceptions<T>(Func<Task<T>> action)
    {
        try
        {
            return await action();
        }
        catch (HttpRequestException ex)
        {
            _logger.LogError(ex, "An HTTP request exception occurred.");
            throw;
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "An unexpected exception occurred.");
            throw;
        }
    }

    // ...
    // ...
}

HandleExceptions metodu, bir işlemi gerçekleştirmeye çalışır ve bu işlem sırasında bir hata oluşursa, bu hatayı loga kaydeder. Bu, HTTP talepleri sırasında ortaya çıkan hataları belgelemek için kullanılabilir.

Daha sonra, bu hata işleyiciyi SendRequestAsync ve diğer HTTP istek metotlarına uygulayabiliriz. Bu, hataların daha iyi izlenmesini ve loga kaydedilmesini sağlar ve hata ayıklama sürecini kolaylaştırır.

Geliştirmeye devam ederken, HandleExceptions fonksiyonunu her bir HTTP talep yöntemine entegre edelim. Bu sayede, her talep hata yakalama mekanizmasından geçer ve hatalar uygun bir şekilde loga kaydedilir.

using Newtonsoft.Json;
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;
using Microsoft.Extensions.Logging;

public class MyHttpClient : IDisposable
{
    private readonly HttpClient _client;
    private readonly IPolicyRegistry<string> _policyRegistry;
    private readonly ILogger<MyHttpClient> _logger;

    public MyHttpClient(HttpClient client, IPolicyRegistry<string> policyRegistry, ILogger<MyHttpClient> logger, 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;
        _logger = logger;
    }

    public void SetDefaultHeader(string name, string value)
    {
        if (_client.DefaultRequestHeaders.Contains(name))
        {
            _client.DefaultRequestHeaders.Remove(name);
        }

        _client.DefaultRequestHeaders.Add(name, value);
    }

    public void RemoveDefaultHeader(string name)
    {
        _client.DefaultRequestHeaders.Remove(name);
    }

    private async Task<T> HandleExceptions<T>(Func<Task<T>> action)
    {
        try
        {
            return await action();
        }
        catch (HttpRequestException ex)
        {
            _logger.LogError(ex, "An HTTP request exception occurred.");
            throw;
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "An unexpected exception occurred.");
            throw;
        }
    }

    public async Task<T> SendRequestAsync<T>(string uri, HttpMethod method, object content = null, Dictionary<string, string> headers = null, TimeSpan? timeout = null) where T : class
    {
        return await HandleExceptions(async () =>
        {
            var request = CreateRequest(uri, method, content, headers, timeout);

            var policyWrap = Policy.WrapAsync(_policyRegistry.Get<IAsyncPolicy<HttpResponseMessage>>("RetryPolicy"),
                                              _policyRegistry.Get<IAsyncPolicy<HttpResponseMessage>>("CachePolicy"));

            var response = await policyWrap.ExecuteAsync(async () => await _client.SendAsync(request));

            if (!response.IsSuccessStatusCode)
            {
                _logger.LogWarning($"Received HTTP {response.StatusCode} for {method} request to {uri}.");
            }

            response.EnsureSuccessStatusCode();

            var responseBody = await response.Content.ReadAsStringAsync();
            return JsonConvert.DeserializeObject<T>(responseBody);
        });
    }

    // ...
    // ...
}

Bu değişikliklerle, SendRequestAsync metodu şimdi HandleExceptions fonksiyonunu kullanıyor. Bu, her HTTP talebinin hata yakalama ve loga kaydetme mekanizmasından geçmesini sağlar.

HTTP yanıtlarında hata durumlarını daha iyi ele almak için bir sonraki adımımızı yapalım. Şu anda, bir HTTP yanıtı başarısız durum kodları (4xx veya 5xx) içerdiğinde, sadece durum kodunu loga kaydediyoruz. Ancak, bazen yanıtın içeriği de hata hakkında yararlı bilgiler içerebilir. Bu nedenle, yanıtın içeriğini de loga kaydedelim.

public async Task<T> SendRequestAsync<T>(string uri, HttpMethod method, object content = null, Dictionary<string, string> headers = null, TimeSpan? timeout = null) where T : class
{
    return await HandleExceptions(async () =>
    {
        var request = CreateRequest(uri, method, content, headers, timeout);

        var policyWrap = Policy.WrapAsync(_policyRegistry.Get<IAsyncPolicy<HttpResponseMessage>>("RetryPolicy"),
                                          _policyRegistry.Get<IAsyncPolicy<HttpResponseMessage>>("CachePolicy"));

        var response = await policyWrap.ExecuteAsync(async () => await _client.SendAsync(request));

        var responseBody = await response.Content.ReadAsStringAsync();
        if (!response.IsSuccessStatusCode)
        {
            _logger.LogWarning($"Received HTTP {response.StatusCode} for {method} request to {uri}. Response body: {responseBody}");
            throw new HttpRequestException($"Request to {uri} failed with status code {response.StatusCode}. Response body: {responseBody}");
        }

        response.EnsureSuccessStatusCode();

        return JsonConvert.DeserializeObject<T>(responseBody);
    });
}

Bu geliştirmelerle, SendRequestAsync metodu artık başarısız durum kodlarına sahip HTTP yanıtlarının içeriğini de loga kaydediyor.

Etiket: #diy-rest-api-client #do-it-yourself #net #rest-api

Bu gibi daha fazla gönderi...

SemaphoreSlim Sınıfı: C#'ta Çoklu Görevlere Dayalı Programlama

2023-06-10 | #net #semaphoreslim

Genel Bakış SemaphoreSlim sınıfı, bir veya daha fazla threadin aynı anda belirli bir kaynağı veya işlemi kullanmasını kontrol etmek için C# ‘ta kullanılan bir yapıdır. SemaphoreSlim, aynı anda kaynağa erişebilecek thread sayısını sınırlar. SemaphoreSlim kullanımı, genellikle çok threadli uygulamalarda deadlock durumlarını önlemek ve belirli bir kaynağın aynı anda yalnızca bir veya daha fazla thread tarafından kullanılmasını sağlamak için kullanılır. SemaphoreSlim Kullanımı SemaphoreSlim sınıfı, aşağıdaki gibi kullanılır: SemaphoreSlim semaphoreSlim = new SemaphoreSlim(1, 1); Burada ilk parametre, aynı anda kaç threadin kaynağı kullanabileceğini belirler.

Devamı 

Basit Bir Rest Api Client Geliştirelim 9

2023-05-14 | #diy-rest-api-client #do-it-yourself #net #rest-api

HTTP isteklerini izlemek ve teşhis etmek için daha fazla yetenek ekleyerek, kütüphanemizi daha da geliştirebiliriz. Bu amaçla, isteklerin ve yanıtların bazı temel bilgilerini loga kaydeden bir middleware ekleyelim. Bu özellik, HTTP isteklerinin ve yanıtlarının kaydını tutmak için HttpClient‘in DelegatingHandler sınıfını kullanır. Bu, bir HTTP isteği gönderildiğinde ve bir yanıt alındığında çalışan bir kod parçasıdır. Bu durumda, HTTP isteklerinin ve yanıtlarının bazı temel bilgilerini loga kaydeder. Aşağıda, bu özelliği eklemek için gereken kod parçacığı bulunmaktadır:

Devamı 

Basit Bir Rest Api Client Geliştirelim 8

2023-05-12 | #diy-rest-api-client #do-it-yourself #net #rest-api

Bu noktada, geliştirmemiz gereken bir diğer önemli konu da güvenlikle ilgili olabilir. Özellikle, API çağrıları genellikle belirli bir kimlik doğrulama yöntemi gerektirir. Bunu sağlamak için, HTTP istemcimizi çok kullanılan iki kimlik doğrulama yöntemiyle, yani Basic Authentication ve Bearer (Token) Authentication ile uyumlu hale getirebiliriz. Bu amaçla, istemcimize iki yeni metot ekleyelim: public void SetBasicAuthentication(string username, string password) { var basicAuthValue = Convert.ToBase64String(Encoding.UTF8.GetBytes($"{username}:{password}")); SetDefaultHeader("Authorization", $"Basic {basicAuthValue}"); } public void SetBearerToken(string token) { SetDefaultHeader("Authorization", $"Bearer {token}"); } Bu metodlar, Authorization başlığını ayarlar, böylece her HTTP talebi kimlik doğrulama bilgilerini içerir.

Devamı 