ASP.NET Core中间件如何阻止响应启动？解决500降级转发报错

为什么会报错？ #

当你执行await _next(context)后，控制器返回500状态码时，ASP.NET Core已经将响应头写入到了响应流中，此时HttpContext.Response.HasStarted已变为true。一旦响应开始发送，就无法再修改或转发整个请求，这就是你看到The request cannot be forwarded, the response has already started错误的原因。你添加的YARP响应转换配置无效，是因为该配置仅作用于YARP自身处理的反向代理请求，不会影响你的控制器返回的响应。

可行的解决方案 #

方案1：中间件中拦截响应（替换响应流） #

通过将响应流替换为内存流，缓存上游的响应内容，避免提前发送到客户端。在检查到500状态码时，清空响应并转发请求；否则将缓存的内容发送给客户端。

修改FallbackMiddleware.cs：

public async Task InvokeAsync(HttpContext context)
{
    context.Request.EnableBuffering();
    // 保存原始响应流，替换为内存流缓存内容
    var originalResponseBody = context.Response.Body;
    using var responseBuffer = new MemoryStream();
    context.Response.Body = responseBuffer;

    try
    {
        await _next(context);
    }
    catch (Exception)
    {
        // 捕获未处理异常，标记为500
        context.Response.StatusCode = StatusCodes.Status500InternalServerError;
    }

    if (context.Response.StatusCode >= 500 && !context.Response.HasStarted)
    {
        // 重置响应，清除已写入的状态码和头
        context.Response.Clear();
        // 转发请求到降级服务
        await _forwarder.SendAsync(context, "http://localhost:5002", _client);
    }
    else
    {
        // 将缓存的响应内容写入原始流，发送给客户端
        responseBuffer.Seek(0, SeekOrigin.Begin);
        await responseBuffer.CopyToAsync(originalResponseBody);
    }
}

方案2：使用ActionFilter拦截控制器结果 #

在控制器返回结果的阶段直接拦截，如果是500状态码，替换为转发请求的逻辑，避免响应流启动。

创建FallbackFilter.cs：

public class FallbackFilter : IAsyncActionFilter
{
    private readonly IHttpForwarder _forwarder;
    private readonly HttpClient _client;

    public FallbackFilter(IHttpForwarder forwarder, HttpClient client)
    {
        _forwarder = forwarder;
        _client = client;
    }

    public async Task OnActionExecutionAsync(ActionExecutingContext context, ActionExecutionDelegate next)
    {
        var executedContext = await next();
        // 检查控制器返回的是否为500状态码结果
        if (executedContext.Result is StatusCodeResult statusCodeResult 
            && statusCodeResult.StatusCode >= 500)
        {
            // 清空当前结果，避免响应发送
            executedContext.Result = new EmptyResult();
            // 转发请求到降级服务
            await _forwarder.SendAsync(context.HttpContext, "http://localhost:5002", _client);
        }
    }
}

在Program.cs中注册过滤器：

// 全局注册到所有控制器
builder.Services.AddControllers(options =>
{
    options.Filters.Add<FallbackFilter>();
});
// 或者仅注册到特定控制器/Action
builder.Services.AddScoped<FallbackFilter>();

方案3：使用YARP原生降级功能 #

如果你已经在使用YARP，推荐直接用它的内置降级策略，无需自行编写中间件。

1. 配置路由与集群（可以用appsettings.json或代码配置）：

{
  "ReverseProxy": {
    "Routes": {
      "main_route": {
        "ClusterId": "main_cluster",
        "Match": {
          "Path": "{**catch-all}"
        },
        "Metadata": {
          "FallbackPolicy": "500_fallback"
        }
      }
    },
    "Clusters": {
      "main_cluster": {
        "Destinations": {
          "main_service": {
            "Address": "http://localhost:5001"
          }
        }
      },
      "fallback_cluster": {
        "Destinations": {
          "fallback_service": {
            "Address": "http://localhost:5002"
          }
        }
      }
    }
  }
}

2. 在Program.cs中注册降级策略：

builder.Services.AddReverseProxy()
    .LoadFromConfig(builder.Configuration.GetSection("ReverseProxy"))
    .AddFallbackPolicy("500_fallback", policy =>
    {
        policy.HandleStatusCode(StatusCodes.Status500InternalServerError);
        policy.FallbackToCluster("fallback_cluster");
    });

关键结论 #

无法强制阻止已经启动的响应，必须在HttpContext.Response.HasStarted为false的阶段（即响应还未发送到客户端时）进行拦截处理。优先推荐使用YARP原生降级功能，或者通过替换响应流、ActionFilter的方式提前拦截500状态码。

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