如何在中间件中高效流式传输HttpResponseMessage内容至响应体

要实现无额外内存拷贝的流式传输，核心是直接将远程响应的流对接至客户端响应流，避免中间缓冲。你的代码里的CopyToAsync本身是流式操作，但可以通过调整HttpClient的请求模式，进一步优化实现真正的零缓冲流式传输：

优化步骤 #

• 使用HttpCompletionOption.ResponseHeadersRead模式发起请求，让HttpClient拿到响应头后立即返回，而非等待整个响应体下载完成
• 直接将远程响应的原始流复制到context.Response.Body，无需额外的PipeWriter包装
• 正确传递响应头信息，同时适配远程响应的状态码

优化后的代码 #

public class MonMiddleware(
    RequestDelegate next,
    HttpClient client)
{
    public async Task InvokeAsync(HttpContext context)
    {
        if (context.Request.Path == "/media")
        {
            // 仅读取响应头就返回，不缓冲整个响应体
            using var response = await client.GetAsync("https://corporatelorem.kovah.de/api/2", 
                HttpCompletionOption.ResponseHeadersRead);

            if (response.IsSuccessStatusCode)
            {
                // 传递Content-Type，兜底默认类型
                context.Response.ContentType = response.Content.Headers.ContentType?.ToString() ?? "application/octet-stream";
                // 若远程返回ContentLength则传递，否则不设置（自动启用分块传输）
                if (response.Content.Headers.ContentLength.HasValue)
                {
                    context.Response.ContentLength = response.Content.Headers.ContentLength;
                }

                // 直接对接远程流与客户端响应流，逐块传输无中间缓冲
                await using var remoteStream = await response.Content.ReadAsStreamAsync();
                await remoteStream.CopyToAsync(context.Response.Body);
                
                return;
            }

            // 直接返回远程响应的状态码，而非固定404
            context.Response.StatusCode = (int)response.StatusCode;
            return;
        }

        await next(context);
        // 请求末尾的处理逻辑
    }
}

关键说明 #

1. HttpCompletionOption.ResponseHeadersRead：这是实现真正流式的核心，默认GetAsync会把整个响应体加载到内存缓冲，该选项让HttpClient在接收到响应头后就返回，响应流直接与远程服务器连接挂钩
2. 流直接对接：ReadAsStreamAsync获取的是远程响应的原始流，直接复制到客户端响应流的过程是逐块传输，不会将整个内容加载到内存
3. 响应头处理：传递ContentLength可让客户端感知下载进度；若远程未返回该头，不设置即可自动启用分块传输编码

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