带HttpMessageHandler的HttpClient数据并发问题求助

问题场景回顾 #

我先梳理下你遇到的情况：

• 你的微服务用类型化HttpClient对接第三方服务，同时注册了一个Transient的HttpMessageHandler，用来从当前请求里提取账号（系统、租户）信息，给第三方请求添加对应头信息
• 流程是：控制器接收请求→调用类型化HttpClient→Handler从当前请求获取账号信息→给第三方请求加头→同时把请求/响应和账号信息存入数据库
• 但生产环境多客户端并发时，出现了账号X的数据被混进账号Y请求里的串数据问题

问题根因分析 #

大概率是你的HttpMessageHandler里错误地把请求级别的状态（比如账号、租户信息）存在了Handler的实例字段里，或者在构造函数里提前获取了请求上下文。

举个典型的错误示例，比如你可能写了这样的Handler代码：

public class AccountHeaderHandler : DelegatingHandler
{
    // 错误：将请求级数据存在实例字段中
    private string _tenantId;
    private readonly IHttpContextAccessor _httpContextAccessor;

    public AccountHeaderHandler(IHttpContextAccessor httpContextAccessor)
    {
        _httpContextAccessor = httpContextAccessor;
        // 错误：在构造函数中获取上下文，此时还未进入请求流程，后续复用Handler时会使用旧数据
        _tenantId = _httpContextAccessor.HttpContext?.Request.Headers["TenantId"];
    }

    protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
    {
        request.Headers.Add("X-Tenant", _tenantId);
        // 日志也使用缓存的实例字段，导致串数据
        LogRequest(_tenantId, request);
        return await base.SendAsync(request, cancellationToken);
    }
}

因为HttpClientFactory会池化Handler管道（即使是Transient的Handler，也可能在短时间内被多个请求复用），一旦实例字段被缓存，并发时不同请求就会覆盖或混用这些数据，最终导致串号问题。

解决办法 #

1. 不在Handler实例中存储请求级状态

所有请求相关的账号、租户信息，必须在SendAsync方法内部，实时从当前请求上下文获取，绝对不要存在Handler的成员变量里。

修正后的Handler代码示例：

public class AccountHeaderHandler : DelegatingHandler
{
    private readonly IHttpContextAccessor _httpContextAccessor;
    private readonly IRequestLogger _requestLogger;

    public AccountHeaderHandler(IHttpContextAccessor httpContextAccessor, IRequestLogger requestLogger)
    {
        _httpContextAccessor = httpContextAccessor;
        _requestLogger = requestLogger;
    }

    protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
    {
        // 实时获取当前请求上下文
        var currentContext = _httpContextAccessor.HttpContext;
        if (currentContext == null)
        {
            throw new InvalidOperationException("无法获取当前请求上下文");
        }

        // 提取账号/租户信息
        currentContext.Request.Headers.TryGetValue("SystemId", out var systemId);
        currentContext.Request.Headers.TryGetValue("TenantId", out var tenantId);
        var accountInfo = new AccountInfo(systemId, tenantId);

        // 给第三方请求添加头信息
        request.Headers.Add("X-System-Id", systemId.ToString());
        request.Headers.Add("X-Tenant-Id", tenantId.ToString());

        // 日志使用当前请求的实时数据
        await _requestLogger.LogOutgoingRequest(accountInfo, request);
        var response = await base.SendAsync(request, cancellationToken);
        await _requestLogger.LogIncomingResponse(accountInfo, response);

        return response;
    }
}

2. 确保服务注册正确

• 首先注册IHttpContextAccessor（ASP.NET Core默认需要手动添加）：

services.AddHttpContextAccessor();

• 将你的Handler注册为Transient或Scoped（绝对不要注册为Singleton，避免状态共享）：

services.AddTransient<AccountHeaderHandler>();

• 类型化HttpClient的注册要关联Handler：

services.AddHttpClient<IThirdPartyServiceClient, ThirdPartyServiceClient>()
    .AddHttpMessageHandler<AccountHeaderHandler>();

3. 检查日志逻辑的并发安全性

如果你的日志组件或存储逻辑里用了共享变量缓存账号信息，也要改成实时传入当前请求的账号数据，不要依赖全局或实例级的缓存。

额外注意点 #

HttpClientFactory的Handler管道默认会缓存2分钟（用于处理DNS更新），所以即使是Transient的Handler，也可能在短时间内被多个请求复用，这也是为什么绝对不能在Handler里存储请求级状态的核心原因——你的Handler实例可能被多个并发请求同时调用。

备注：内容来源于stack exchange，提问作者ykh