.NET Core 3.1异步HttpClient请求体交叉污染问题排查及代码优化咨询

你好，针对你遇到的这个偶发请求体交叉的问题，结合你的代码场景和技术栈，我来帮你梳理下可能的原因、修复方案，以及解答你关于调用流程的疑问：

先说说你代码里的明显问题 #

首先看到你的Service层代码有个致命的笔误：

public async Task<ResponseModel> Exec (Request model)
{
    return await _service.Exec(model);
}

这里你调用了_service.Exec(model)，相当于递归调用自身，运行起来肯定会栈溢出。应该改成调用Dal层的实例方法，比如return await _dal.Exec(model);，记得要在Service的构造函数里注入Dal层的实例哦。

偶发请求体交叉的核心原因分析 #

你提到千次请求里有2次出现Register A和B的请求体互相污染的情况，而且是在网络故障时首次出现，这大概率和你每次请求都新建HttpClient及HttpClientHandler的用法有关：

• .NET里的HttpClient设计是要复用的，频繁创建实例会导致底层Socket资源无法及时释放，在高并发或网络异常场景下，很容易引发请求上下文的混乱。虽然HttpClient本身是线程安全的，但频繁创建Handler和Client的反模式，会带来各种不可预期的并发问题，包括你遇到的请求体交叉污染。
• 另外你代码里的Uti应该是Uri的笔误，这个小错误可能会导致代理配置失败，间接加重网络异常时的请求混乱。

代码优化方案（推荐使用IHttpClientFactory） #

.NET Core 3.1官方推荐用IHttpClientFactory来管理HttpClient的生命周期，既避免了单例HttpClient的DNS缓存问题，又解决了频繁创建实例的资源浪费。具体优化步骤如下：

1. 在Startup.cs中注册HttpClient和依赖服务

public void ConfigureServices(IServiceCollection services)
{
    // 注册带代理配置的HttpClient实例
    services.AddHttpClient("MyApiClient", client =>
    {
        client.BaseAddress = new Uri("你的endpoint_uri"); // 设置接口基础地址
        client.DefaultRequestHeaders.Add("Authorization", "your token auth"); // 配置默认授权头
    })
    .ConfigurePrimaryHttpMessageHandler(() =>
    {
        var handler = new HttpClientHandler();
        handler.UseProxy = true;
        handler.Proxy = new WebProxy
        {
            Address = new Uri("你的proxy_uri"),
            BypassProxyOnLocal = false,
            UseDefaultCredentials = true
        };
        return handler;
    });

    // 注册你的业务层和数据访问层
    services.AddScoped<IService, Service>();
    services.AddScoped<IDal, Dal>();
}

2. 改造Dal层，注入IHttpClientFactory复用实例

public class Dal : IDal
{
    private readonly IHttpClientFactory _httpClientFactory;

    // 通过构造函数注入IHttpClientFactory
    public Dal(IHttpClientFactory httpClientFactory)
    {
        _httpClientFactory = httpClientFactory;
    }

    public async Task<ResponseModel> Exec(RequestModel model)
    {
        var httpClient = _httpClientFactory.CreateClient("MyApiClient");
        
        // 序列化请求体（注意指定编码，避免乱码）
        string jsonStr = JsonSerializer.Serialize(model);
        var content = new StringContent(jsonStr, Encoding.UTF8, "application/json");
        
        // 发送请求（因为已经配置了BaseAddress，这里传相对路径即可）
        var response = await httpClient.PostAsync("", content);
        
        // 可选：确保请求成功，否则抛出异常
        response.EnsureSuccessStatusCode();
        
        return await response.Content.ReadFromJsonAsync<ResponseModel>();
    }
}

3. 修复Service层的递归问题

public class Service : IService
{
    private readonly IDal _dal;

    public Service(IDal dal)
    {
        _dal = dal;
    }

    public async Task<ResponseModel> Exec(RequestModel model)
    {
        // 调用Dal层的方法，而非递归调用自身
        return await _dal.Exec(model);
    }
}

关于控制器调用Exec的疑问 #

你的Controller层代码是完全正确的：

[HttpPost()]
public async Task<ActionResult<ResponseModel>> Exec(RequestModel model)
{
    return await _service.Exec(model);
}

只要你在Controller的构造函数中正确注入了Service层的实例，这个分层调用流程（Controller → Service → Dal）是符合WebAPI的最佳实践的。

额外建议 #

1. 添加请求日志：因为问题是偶发的，建议在Dal层记录每次请求的请求体、响应体和请求ID，方便后续排查问题。
2. 避免手动管理HttpClient：永远不要在每次请求中新建HttpClient或HttpClientHandler，复用才是正确的打开方式。
3. 处理异常场景：可以在Dal层添加网络异常捕获，比如HttpRequestException，做重试或降级处理，提升系统稳定性。

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