.NET 8进程内与dotnet-isolated模式下HttpRequest Body读取行为差异

问题现象 #

在.NET Isolated模式的Azure Functions中，直接将HttpRequestData.Body包装成StreamContent作为新HttpRequestMessage的内容转发到后端服务器时，后端会识别请求体为空。但完全相同的转发逻辑，在.NET 8进程内模式的Functions中可以正常工作。改用StringContent先读取整个请求体再转发，就能消除该问题。

根本原因 #

.NET Isolated模式与进程内模式的请求体流实现存在核心差异：

• 进程内模式的HttpRequest.Body通常是可重新定位、支持回退的流（如MemoryStream），即使流位置被移动，也能通过Seek回到起始位置重新读取。
• Isolated模式的HttpRequestData.Body是单向、不可回退的管道流（如PipeStream），函数运行时可能在绑定阶段已经读取过该流，或者该流本身不支持多次读取/位置重置。当HttpClient尝试读取这个流时，流的位置已经处于末尾，导致后端接收到空请求体。

解决方案 #

方案1：读取请求体为字符串后用StringContent转发（适合文本类请求） #

先将请求体完整读取为字符串，再用StringContent包装，确保转发的内容是完整且可重复读取的：

using System;
using System.IO;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using System.Threading;
using System.Net.Http;
using System.Net;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Http;

namespace FunctionApp1
{
    public class Function1
    {
        [Function("Function1")]
        public async Task<IActionResult> GeneratePdfAsync(
        [HttpTrigger(AuthorizationLevel.Function, "post", Route = "documents/{tenant}/{engine}/{template}")] HttpRequestData req,
        string engine,
        string tenant,
        string template,
        CancellationToken ct)
        {
            using var client = new HttpClient() { BaseAddress = new Uri("https://my-backend-func.azurewebsites.net/api/") };
            using var request = new HttpRequestMessage(HttpMethod.Post, new Uri($"pdf/{Uri.EscapeDataString(tenant)}/{Uri.EscapeDataString(template)}", UriKind.Relative));
            
            // 先读取完整请求体到字符串
            var requestBody = await new StreamReader(req.Body).ReadToEndAsync(ct);
            // 用StringContent包装，保持原请求的编码和媒体类型
            request.Content = new StringContent(requestBody, req.ContentType?.Encoding, req.ContentType?.MediaType);
            
            using var response = await client.SendAsync(request, ct);
            if (response.StatusCode == HttpStatusCode.OK)
                return new FileStreamResult(await response.Content.ReadAsStreamAsync(ct), "application/pdf");
            else
                return new BadRequestObjectResult(await response.Content.ReadAsStringAsync(ct));
        }
    }
}

方案2：复制流到可回退的MemoryStream（适合大文件/二进制请求） #

如果请求体是大文件或二进制数据，避免内存占用过高，可以将原流复制到MemoryStream（支持位置重置）后再转发：

using System;
using System.IO;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using System.Threading;
using System.Net.Http;
using System.Net;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Http;

namespace FunctionApp1
{
    public class Function1
    {
        [Function("Function1")]
        public async Task<IActionResult> GeneratePdfAsync(
        [HttpTrigger(AuthorizationLevel.Function, "post", Route = "documents/{tenant}/{engine}/{template}")] HttpRequestData req,
        string engine,
        string tenant,
        string template,
        CancellationToken ct)
        {
            using var client = new HttpClient() { BaseAddress = new Uri("https://my-backend-func.azurewebsites.net/api/") };
            using var request = new HttpRequestMessage(HttpMethod.Post, new Uri($"pdf/{Uri.EscapeDataString(tenant)}/{Uri.EscapeDataString(template)}", UriKind.Relative));
            
            // 复制原流到MemoryStream
            var memoryStream = new MemoryStream();
            await req.Body.CopyToAsync(memoryStream, ct);
            memoryStream.Position = 0; // 重置流位置到起始处
            
            request.Content = new StreamContent(memoryStream);
            // 复制原请求的Content-Type头
            if (req.ContentType != null)
            {
                request.Content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue(req.ContentType);
            }
            
            using var response = await client.SendAsync(request, ct);
            if (response.StatusCode == HttpStatusCode.OK)
                return new FileStreamResult(await response.Content.ReadAsStreamAsync(ct), "application/pdf");
            else
                return new BadRequestObjectResult(await response.Content.ReadAsStringAsync(ct));
        }
    }
}

注意事项 #

• 转发时记得复制原请求的Content-Type等相关头信息，避免后端解析请求体时出现错误。
• 对于超大文件，建议考虑流式处理的替代方案（如直接通过Blob存储中转），避免内存溢出。

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