Sage.Http 2.0.0.3

Sage.Http

开源地址: https://gitee.com/liupenglai/sage.http

项目简介

一个简洁、可扩展、支持 DI 与独立模式的 HttpClient 管理库，提供统一配置、稳健的弹性策略（重试、熔断、限流、超时）、事件监控、消息处理器与拦截器，并兼顾线程安全、内存安全与 AOT 友好。

特性

• 统一管理 HttpClient：支持 ASP.NET Core（DI）与独立模式（WinForms/WPF/控制台）
• 流式 HttpRequestBuilder：简洁链式 API，内置 JSON 序列化/反序列化，AOT 友好重载
• 弹性策略：重试、熔断、限流、超时，支持事件观测与订阅
• 消息处理器与拦截器：推荐工厂重载注册，可灵活注入运行时参数；内置 LoggingHandler、BearerTokenHandler、CorrelationIdHandler 等
• 配置即用：JSON 配置（appsettings.json）与环境差异化配置，优雅加载到 HttpClientOptions
• 事件监控：RetryEvent、CircuitBreakerEvent、RateLimiterEvent 等，支持弱引用订阅，避免泄漏
• 高性能与安全：基于 SocketsHttpHandler 的连接池/HTTP/2，多线程安全，关注内存与线程开销
• 易扩展：自定义处理器、拦截器、事件处理，可与现有日志/监控系统集成

安装

dotnet add package Sage.Http

快速开始

ASP.NET Core（DI 模式）

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddHttpClientManager();

builder.Services.AddHttpClient("github", options =>
{
    options.BaseAddress = new Uri("https://api.github.com");
    options.Timeout = TimeSpan.FromSeconds(30);
    options.AddDefaultHeader("User-Agent", "SageHttpDemo/1.0");

    options.ConfigureRetry(r =>
    {
        r.MaxRetryAttempts = 3;
        r.BaseDelay = TimeSpan.FromSeconds(2);
        r.BackoffType = BackoffType.Exponential;
        r.RetryOnStatusCodes = new HashSet<int> { 408, 429, 500, 502, 503, 504 };
    });

    options.ConfigureCircuitBreaker(cb =>
    {
        cb.FailureRatio = 0.5;
        cb.SamplingDuration = TimeSpan.FromSeconds(30);
        cb.MinimumThroughput = 5;
        cb.BreakDuration = TimeSpan.FromMinutes(1);
    });

    // LoggingHandler（工厂方式自定义级别与体开关）
    options.AddHandler(sp => new LoggingHandler(
        sp.GetRequiredService<ILogger<LoggingHandler>>(),
        requestLogLevel: LogLevel.Information,
        responseLogLevel: LogLevel.Information,
        logRequestBody: false,
        logResponseBody: false));
});

WinForms/控制台（独立模式）

var loggerFactory = LoggerFactory.Create(b =>
{
    b.AddConsole();
    b.SetMinimumLevel(LogLevel.Information);
});
var httpLogger = loggerFactory.CreateLogger<LoggingHandler>();

var manager = StandaloneHttpClientManager.Create(config =>
{
    config.RegisterClient("api", options =>
    {
        options.SetBaseAddress("https://jsonplaceholder.typicode.com")
               .SetTimeout(TimeSpan.FromSeconds(30))
               .ConfigureRetry(r => { r.MaxRetryAttempts = 3; r.BaseDelay = TimeSpan.FromSeconds(1); });

        options.AddHandler(_ => new LoggingHandler(httpLogger,
            requestLogLevel: LogLevel.Information,
            responseLogLevel: LogLevel.Information,
            logRequestBody: false,
            logResponseBody: false));

        options.AddRequestInterceptor(req =>
        {
            req.Headers.TryAddWithoutValidation("X-Trace-Id", Guid.NewGuid().ToString("N"));
        });
    });
});

两种调用方式（并列示例）

原生 HttpClient 与链式 HttpRequestBuilder 均可无缝使用：

// 原生 HttpClient
var client = manager.GetClient("jsonplaceholder");
var post = await client.GetFromJsonAsync<Post>("/posts/1");
await client.PostAsJsonAsync("/posts", new { title = "demo" });

// 链式 HttpRequestBuilder
var posts = await manager
    .CreateRequest("jsonplaceholder", "/posts")
    .WithQuery("_limit", "10")
    .WithHeader("X-Trace-Id", Guid.NewGuid().ToString("N"))
    .GetFromJsonAsync<Post[]>();

// AOT 友好反序列化（JsonTypeInfo<T> 源生成）
var p1 = await manager
    .CreateRequest("jsonplaceholder", "/posts/1")
    .GetFromJsonAsync(typeInfo!);

配置概览

• HttpClientOptions
  • 基本：BaseAddress、Timeout、HttpVersion、DefaultHeaders、UseCookies、AllowAutoRedirect 等
  • 连接：通过 ConfigurePrimaryHandler 使用 SocketsHttpHandler（连接池、Keep-Alive、HTTP/2 多路复用、ConnectTimeout）
• 弹性策略（ResilienceOptions）
  • 重试：MaxRetryAttempts、BaseDelay、BackoffType、UseJitter；基于状态码/范围/异常/ShouldRetry
  • 熔断：FailureRatio、SamplingDuration、MinimumThroughput、BreakDuration
  • 限流：PermitLimit、Window、QueueLimit
  • 超时：客户端级与策略级均可配置
  • 事件：启用后可订阅 RetryEvent、CircuitBreakerEvent、RateLimiterEvent

消息处理器与拦截器

• 处理器（推荐在 DI 模式）：LoggingHandler、CorrelationIdHandler、BearerTokenHandler、CustomHeaderHandler、UserAgentHandler
• 注册方式
  • 泛型：options.AddHandler<THandler>()（构造参数由 DI 解析，适合无自定义运行时参数）
  • 工厂：options.AddHandler(sp => new Handler(...))（推荐，可自定义参数，DI 与独立模式均适用）
• 拦截器：AddRequestInterceptor、AddResponseInterceptorAsync、AddErrorInterceptor；更轻量，适合观测与简单变更
• 提示：避免同时用拦截器与 LoggingHandler 记录同类日志，否则可能重复输出

JSON 配置示例（appsettings.json）

{
  "HttpClients": {
    "github": {
      "BaseAddress": "https://api.github.com",
      "Timeout": "00:00:30",
      "HttpVersion": "2.0",
      "DefaultHeaders": { "User-Agent": "SageHttpDemo/1.0" },
      "Resilience": {
        "EnableRetry": true,
        "Retry": { "MaxRetryAttempts": 3, "BaseDelay": "00:00:02", "BackoffType": "Exponential" },
        "EnableCircuitBreaker": true,
        "CircuitBreaker": { "FailureRatio": 0.5, "SamplingDuration": "00:00:30", "MinimumThroughput": 5, "BreakDuration": "00:01:00" },
        "EnableEvents": true
      }
    }
  }
}

加载：builder.Services.AddHttpClient("github", builder.Configuration.GetSection("HttpClients:github").Get<HttpClientOptions>());

事件订阅

// 特定客户端
_manager.Subscribe<RetryEvent>("github", e => Debug.WriteLine($"Retry {e.AttemptNumber}: {e.RequestUri}"));

// 所有客户端
_manager.Subscribe<HttpClientEvent>(e => Console.WriteLine($"{e.GetType().Name}: {e.ClientName}"));

// 弱引用（避免内存泄漏）
_manager.Subscribe<RetryEvent>("api", OnRetry, useWeakReference: true);

使用场景

• 第三方 API：启用重试与 LoggingHandler，便于排查问题
• 微服务：BearerTokenHandler + CorrelationIdHandler + 熔断与重试
• 批量下载：限流（并发与队列限制）、长超时、响应流式读取

性能与故障排查

• 建议使用 GetClient 复用实例；避免在循环中频繁 CreateClient
• 启用 HTTP/2 与连接池参数优化（SocketsHttpHandler）
• 日志排查：LoggingHandler 的 logRequestBody/logResponseBody 仅在调试场景启用，注意敏感信息脱敏
• 常见问题与更多排查步骤详见 Troubleshooting.md

示例

• src/Examples/AspNetCoreExample.md
• src/Examples/WinFormsExample.md

许可证

Apache-2.0

本项目采用 Apache License 2.0 开源协议。详情见 LICENSE.txt。