.NET 7 Minimal API自定义中间件无法修改状态码问题求助

问题根源 #

你的核心问题是执行await next(context)后，后续管道中的中间件/控制器已经向响应流写入了内容（比如那个requestId），此时response.HasStarted为true：

1. 无法修改StatusCode（会触发"StatusCode cannot be set because the response has already started"错误）；
2. 再次调用response.WriteAsync会把错误内容追加到已输出的响应后面，导致JSON格式错乱、状态码保持原200。

解决方案一：缓冲响应流，拦截并替换响应 #

通过替换响应流为内存流，先捕获后续管道的输出，再根据通知状态决定返回错误响应还是原响应。修改后的代码如下：

public async Task InvokeAsync(HttpContext context, RequestDelegate next)
{
    var originalResponseBody = context.Response.Body;
    using var responseBuffer = new MemoryStream();
    context.Response.Body = responseBuffer;

    var statusCode = (int)HttpStatusCode.InternalServerError;
    context.Response.ContentType = "application/json";

    try
    {
        await next(context);

        if (_notificationContext.HasNotifications)
        {
            // 重置响应：清空已写入的内容、重置状态码和头
            context.Response.Clear();
            context.Response.StatusCode = (int)HttpStatusCode.BadRequest;

            var resultNotifications = new Result<Notification> { Errors = _notificationContext.Notifications.ToList() };
            await context.Response.WriteAsync(System.Text.Json.JsonSerializer.Serialize(resultNotifications));
        }
        else
        {
            // 无通知，将缓冲的原响应写回输出流
            responseBuffer.Seek(0, SeekOrigin.Begin);
            await responseBuffer.CopyToAsync(originalResponseBody);
        }
    }
    catch (Exception exception)
    {
        var correlationId = context.Response.Headers["X-Correlation-ID"].FirstOrDefault() ?? string.Empty;
        Result<Notification> resultNotifications = null;

        if (_notificationContext.HasNotifications)
        {
            statusCode = (int)HttpStatusCode.BadRequest;
            resultNotifications = new Result<Notification> { Errors = _notificationContext.Notifications.ToList() };
            using (LogContext.PushProperty("Notifications", resultNotifications.Errors, true))
            {
                Log.Error(exception, "There are validation notifications to be analyzed.");
            }
        }
        else
        {
            Log.Error(exception, "An error occurred with the request. See the log for more details.");
        }

        if (!context.Response.HasStarted)
        {
            context.Response.Clear();
            context.Response.StatusCode = statusCode;
            await context.Response.WriteAsync(System.Text.Json.JsonSerializer.Serialize(resultNotifications ?? GetErrorMessage(correlationId)));
        }
    }
    finally
    {
        // 恢复原响应流
        context.Response.Body = originalResponseBody;
    }
}

关键改动说明 #

• 用MemoryStream替换原响应流，缓冲后续管道的输出；
• 检查到通知时，调用context.Response.Clear()重置响应（清空已写入的内容、响应头），再写入错误响应；
• 无通知时，将缓冲的原响应内容复制回原输出流，保证正常响应不受影响；
• finally块恢复原响应流，避免资源泄漏。

解决方案二：调整中间件注册顺序 #

如果你的requestId是由其他中间件（比如日志中间件）写入的，将当前通知中间件注册在所有会输出响应的中间件之前。这样await next(context)执行完成后，响应流还未被写入内容，此时可以直接修改状态码并写入错误响应，不会出现内容拼接问题。

例如在Program.cs中：

// 先注册通知中间件
app.UseMiddleware<NotificationMiddleware>();
// 再注册其他会输出响应的中间件（如requestId、日志中间件）
app.UseRequestIdMiddleware();
app.UseRouting();
// ...其他中间件

额外注意事项 #

• 确保_notificationContext是请求域的实例（比如用Scoped生命周期注册），避免不同请求之间的通知串扰；
• 可以封装响应序列化逻辑为单独方法，避免代码重复；
• 若使用ASP.NET Core 3.1+，可以考虑用IHttpResponseFeature来更安全地操作响应状态。

内容的提问来源于stack exchange，提问作者alexandro.lopes