ASP.NET Core 6中Unexpected end of request content异常排查与屏蔽

一、该异常是否为纯客户端问题？ #

是的，绝大多数情况下这是客户端引发的问题。这个异常由Kestrel服务器抛出，触发场景包括：

• 客户端在发送带Body的POST/PUT请求过程中突然断开连接（比如用户关闭浏览器、网络中断）
• 客户端代码bug导致请求内容未完全发送就终止
• 恶意请求故意构造不完整的请求内容

由于异常发生在Kestrel解析请求的阶段，还未进入你的业务代码执行流程，所以堆栈跟踪不会指向你代码中的有效位置。

二、如何仅屏蔽该特定异常，不影响其他异常？ #

可以通过自定义异常处理逻辑，精准捕获并处理这个特定异常，同时让其他异常正常流转。以下是两种可行方案：

方案1：自定义中间件捕获异常 #

创建专门的中间件，放在请求管道靠前位置，针对性处理该异常：

public class IncompleteRequestHandlerMiddleware
{
    private readonly RequestDelegate _next;
    private readonly ILogger<IncompleteRequestHandlerMiddleware> _logger;

    public IncompleteRequestHandlerMiddleware(RequestDelegate next, ILogger<IncompleteRequestHandlerMiddleware> logger)
    {
        _next = next;
        _logger = logger;
    }

    public async Task InvokeAsync(HttpContext context)
    {
        try
        {
            await _next(context);
        }
        catch (BadHttpRequestException ex) when (ex.Message.Equals("Unexpected end of request content", StringComparison.Ordinal))
        {
            // 记录警告日志，避免污染错误日志
            _logger.LogWarning(ex, "客户端请求内容不完整，已终止处理");
            
            // 返回400错误给客户端
            context.Response.StatusCode = StatusCodes.Status400BadRequest;
            context.Response.ContentType = "text/plain";
            await context.Response.WriteAsync("请求内容不完整，请检查后重试");
        }
        // 其他异常继续向上传递，由后续逻辑处理
    }
}

在Program.cs中注册该中间件（需放在UseRouting和UseExceptionHandler之前）：

var builder = WebApplication.CreateBuilder(args);
// ... 其他服务注册 ...

var app = builder.Build();

// 注册自定义中间件
app.UseMiddleware<IncompleteRequestHandlerMiddleware>();

// 保留原有异常处理逻辑
app.UseExceptionHandler("/Error");
// ... 其他中间件配置 ...

app.Run();

方案2：在全局异常处理中过滤 #

如果已经使用UseExceptionHandler，可以在其处理逻辑中添加判断：

app.UseExceptionHandler(errorApp =>
{
    errorApp.Run(async context =>
    {
        var exceptionFeature = context.Features.Get<IExceptionHandlerPathFeature>();
        var exception = exceptionFeature?.Error;

        if (exception is BadHttpRequestException ex 
            && ex.Message.Equals("Unexpected end of request content", StringComparison.Ordinal))
        {
            context.Response.StatusCode = StatusCodes.Status400BadRequest;
            context.Response.ContentType = "text/plain";
            await context.Response.WriteAsync("请求内容不完整，请检查后重试");
            
            var logger = context.RequestServices.GetRequiredService<ILogger<Program>>();
            logger.LogWarning(ex, "客户端发送不完整请求");
        }
        else
        {
            // 处理其他异常的原有逻辑，比如返回500错误页面
            context.Response.StatusCode = StatusCodes.Status500InternalServerError;
            context.Response.ContentType = "text/html";
            await context.Response.WriteAsync("<html><body><h1>服务器内部错误</h1></body></html>");
            
            var logger = context.RequestServices.GetRequiredService<ILogger<Program>>();
            logger.LogError(exception, "服务器未处理异常");
        }
    });
});

注意事项 #

• 不要完全吞掉该异常，至少记录警告日志，便于监控是否有大量此类请求（比如恶意扫描或客户端批量问题）
• 选择400状态码是合理的，因为请求本身不符合HTTP规范，属于客户端错误
• 如果需要更精准判断，可以结合异常的StatusCode属性（BadHttpRequestException包含对应HTTP状态码的属性）

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