Rabbit.Common.Http 1.3.1

Rabbit.Common.Http

Typed HTTP client wrapper with JSON serialization. Supports GET/POST with automatic deserialization, custom headers, timeout configuration, and multiple encodings.

HTTP 客户端组件，封装常用 HTTP 请求操作。

安装

dotnet add package Rabbit.Common.Http

依赖

• Rabbit.Common.Lite
• Microsoft.Extensions.Http 10.0.8
• Microsoft.Extensions.Http.Resilience 10.6.0

功能

• GET/POST 请求封装
• 支持多种编码（UTF-8、GBK 等）
• JSON/FormData 自动序列化
• 自定义请求头
• 可选的重试 + 熔断策略（默认关闭）

使用方式

Console 项目

using Microsoft.Extensions.DependencyInjection;
using Rabbit.Common.Http;

// 1. 创建 DI 容器
var services = new ServiceCollection();

// 2. 注册 HttpClient
services.AddHttpClientHelperConfigure(
    timeoutSeconds: 30,
    configureHttpClient: client =>
    {
        client.DefaultRequestHeaders.Add("X-Api-Key", "your-key");
    }
);

// 3. 构建服务提供者
var provider = services.BuildServiceProvider();

// 4. 发送请求
var http = provider.GetRequiredService<HttpClientHelper>();

// GET 请求
var result = await http.GetAsync("https://api.example.com/data");

// GET 并反序列化
var user = await http.GetAsync<User>("https://api.example.com/users/1");

// POST JSON
var response = await http.PostJsonAsync(
    "https://api.example.com/users",
    new { Name = "Test", Age = 25 }
);

Web API 项目

using Rabbit.Common.Http;

services.AddHttpClientHelperConfigure(
    timeoutSeconds: 30,
    configureHttpClient: client =>
    {
        client.DefaultRequestHeaders.Add("X-Api-Key", "your-key");
    }
);

开启重试策略

services.AddHttpClientHelperConfigure(
    timeoutSeconds: 30,
    configureResilience: options =>
    {
        options.EnableRetry = true;
        options.MaxRetryAttempts = 3;           // 最大重试次数，默认 3
        options.RetryDelay = TimeSpan.FromSeconds(1);  // 重试间隔，默认 1s
        options.RetryBackoffType = RetryBackoffType.Exponential; // 退避策略
    }
);

开启熔断策略

services.AddHttpClientHelperConfigure(
    timeoutSeconds: 30,
    configureResilience: options =>
    {
        options.EnableCircuitBreaker = true;
        options.FailureRatio = 0.5;             // 失败率 50% 触发熔断
        options.SamplingDuration = TimeSpan.FromSeconds(30); // 采样窗口
        options.BreakDuration = TimeSpan.FromSeconds(30);    // 熔断持续时间
        options.MinimumThroughput = 10;          // 最小请求数
    }
);

同时开启重试 + 熔断

services.AddHttpClientHelperConfigure(
    timeoutSeconds: 30,
    configureResilience: options =>
    {
        options.EnableRetry = true;
        options.EnableCircuitBreaker = true;
    }
);

使用示例

public class ThirdPartyService
{
    private readonly HttpClientHelper _http;

    public ThirdPartyService(HttpClientHelper http)
    {
        _http = http;
    }

    // GET 请求
    public async Task<string> GetData(string url)
    {
        return await _http.GetAsync(url);
    }

    // GET 并反序列化
    public async Task<WeatherData?> GetWeather(string city)
    {
        var url = $"https://api.weather.com/v1/current?city={city}";
        return await _http.GetAsync<WeatherData>(url);
    }

    // POST JSON
    public async Task<string> PostOrder(Order order)
    {
        return await _http.PostJsonAsync(
            "https://api.example.com/orders",
            order
        );
    }

    // POST FormData
    public async Task<string> UploadForm(Dictionary<string, string> data)
    {
        return await _http.PostFormDataAsync(
            "https://api.example.com/form",
            data
        );
    }
}

使用 GBK 编码

// 某些老系统使用 GBK 编码
var content = await _http.GetAsync(
    url,
    encoding: Encoding.GetEncoding("GBK")
);

JSON 时间转换器

// 处理 yyyy-MM-dd HH:mm:ss 格式
var options = new JsonSerializerOptions
{
    Converters = { new JsonDateTimeConverter() }
};

API 参考

许可证

MIT