使用HttpClient向MultipartFormDataContent传递大文件流的问题咨询

问题根因 #

你遇到的IOException报错是因为ASP.NET Core默认的表单模型绑定逻辑会在控制器动作执行前提前读取Request.Body的全部内容，等到你通过MultipartReader主动读取流时，流已经处于结束位置。

第一步：修复后端API报错 #

你需要禁用目标接口的表单模型绑定，避免系统提前消费请求流：

1. 先实现禁用表单绑定的特性：

[AttributeUsage(AttributeTargets.Class | AttributeTargets.Method)]
public class DisableFormValueModelBindingAttribute : Attribute, IResourceFilter
{
    public void OnResourceExecuting(ResourceExecutingContext context)
    {
        // 移除表单相关的值提供工厂，阻止系统提前解析表单内容
        var factoriesToRemove = context.ValueProviderFactories
            .Where(f => f is FormValueProviderFactory or JQueryFormValueProviderFactory)
            .ToList();
        foreach (var factory in factoriesToRemove)
        {
            context.ValueProviderFactories.Remove(factory);
        }
    }

    public void OnResourceExecuted(ResourceExecutedContext context)
    {
    }
}

2. 给接收大文件的接口加上这个特性：

[HttpPost]
[DisableRequestSizeLimit]
[DisableFormValueModelBinding] // 新增这行
public async Task<IActionResult> ReceiveLargeFile()
{
    // 保留你原有逻辑即可
}

修改完成后你现有的集成测试就可以正常通过，不会再抛出流被提前读取的异常。

第二步：前端API实现零内存占用流式转发 #

不需要在前端API侧解析、重新打包multipart/form-data内容，直接透传原始请求流即可实现全程流式传输，不会把整个文件加载到内存，也不会生成临时磁盘文件：

1. 前端API的转发接口同样需要加上[DisableFormValueModelBinding]特性，避免请求流被提前读取。
2. 编写转发逻辑：

[HttpPost]
[DisableRequestSizeLimit]
[DisableFormValueModelBinding]
public async Task<IActionResult> ForwardFile([FromServices] IHttpClientFactory httpClientFactory)
{
    var originRequest = HttpContext.Request;
    // 校验请求格式合法性
    if (!originRequest.HasFormContentType
        || !MediaTypeHeaderValue.TryParse(originRequest.ContentType, out var mediaType)
        || string.IsNullOrEmpty(mediaType.Boundary.Value))
    {
        return new UnsupportedMediaTypeResult();
    }

    // 构造转发请求，直接复用原始请求流
    using var forwardReq = new HttpRequestMessage(HttpMethod.Post, "后端接收大文件接口的完整地址");
    forwardReq.Content = new StreamContent(originRequest.Body);
    // 透传原始Content-Type头，保证boundary值和原始请求一致
    forwardReq.Content.Headers.TryAddWithoutValidation("Content-Type", originRequest.ContentType);

    using var client = httpClientFactory.CreateClient();
    // 指定ResponseHeadersRead，不用等待完整响应返回就释放连接，减少内存占用
    var backendResp = await client.SendAsync(forwardReq, HttpCompletionOption.ResponseHeadersRead);

    // 可根据需要透传后端响应到前端
    return StatusCode((int)backendResp.StatusCode, await backendResp.Content.ReadAsStringAsync());
}

内容的提问来源于stack exchange，提问作者Piotr