Azure Functions隔离模式：如何在中间件中获取HttpResponseData

问题原因 #

1. 流位置操作顺序错误：函数通过WriteStringAsync写入响应体后，HttpResponseData.Body的流指针处于末尾位置，直接读取会返回空内容；且原代码中重置流位置的操作在读取之后，完全颠倒了正确顺序。
2. 流可查找性限制：部分场景下HttpResponseData.Body可能是不可查找的流（CanSeek=false），直接设置Position会抛出异常，无法正常读取内容。

修复后的中间件代码 #

调整中间件中读取响应体的逻辑，修正流操作顺序并兼容不可查找的流：

public class HistoryLogMiddleware : IFunctionsWorkerMiddleware
{
    public HistoryLogMiddleware() { }

    public async Task Invoke(FunctionContext context, FunctionExecutionDelegate next)
    {
        var requestData = await context.GetHttpRequestDataAsync();
        var body = await new StreamReader(requestData.Body).ReadToEndAsync();

        Console.WriteLine($"Request Body: {body}");

        // 重置请求流位置，确保后续函数能正常读取
        requestData.Body.Position = 0;

        await next(context);   
        
        var responseData = context.GetInvocationResult();
        if(responseData != null && responseData.Value is HttpResponseData responseFormat) 
        {
            string responseBody;

            if (responseFormat.Body.CanSeek)
            {
                // 可查找流：先重置位置到开头再读取
                responseFormat.Body.Position = 0;
                responseBody = await new StreamReader(responseFormat.Body).ReadToEndAsync();
                // 读完后再次重置位置，保证后续流程正常读取响应
                responseFormat.Body.Position = 0;
            }
            else
            {
                // 不可查找流：复制到内存流处理
                using var memoryStream = new MemoryStream();
                await responseFormat.Body.CopyToAsync(memoryStream);
                memoryStream.Position = 0;
                responseBody = await new StreamReader(memoryStream).ReadToEndAsync();
                
                // 将内存流内容写回响应流并重置位置
                memoryStream.Position = 0;
                responseFormat.Body.SetLength(0);
                await memoryStream.CopyToAsync(responseFormat.Body);
                responseFormat.Body.Position = 0;
            }

            Console.WriteLine($"Response Body: {responseBody}");
        }
    }
}

额外优化建议 #

示例函数中WriteStringAsync的调用可简化，去掉多余的ToString()（JsonConvert.SerializeObject已返回字符串）：

// 原代码
await response.WriteStringAsync(JsonConvert.SerializeObject(respDomain).ToString(), Encoding.UTF8);

// 简化后
await response.WriteStringAsync(JsonConvert.SerializeObject(respDomain), Encoding.UTF8);

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