.NET6 Kestrel如何先返回响应再执行后台长耗时任务

• 技术栈：基于Kestrel搭建的.NET 6控制台程序，未使用ASP.NET模板
• 原有逻辑：业务包含执行时长超8秒的长耗时函数，逻辑全部执行完成后才会向客户端返回生成的ID
• 目标效果：服务端收到请求后立即生成ID返回，客户端收到响应判定请求完成，服务端在后台继续执行剩余处理逻辑，不阻塞响应
• 异常表现：注释掉长耗时Routing方法调用时客户端响应极快；只要调用Routing，无论是否await、无论把响应写逻辑放在委托什么位置，客户端都会等待Routing执行完成才能收到响应

public void Configure(IApplicationBuilder app)
{
    app
        .UseMaxConcurrentRequests()
        .Run(async (context) =>
        {
            try
            {
                // Generated id
                string gid = GlobalMethods.GetUniqueKey(14);
                
                var url = context.Request.Path.Value;

                /*
                Bunch of url manipulation
                */

                // Long running task that I expect calling
                // Task.Run would send it away
                // But for some reason the client still waits here till this finishes
                Task.Run(() => Routing(segments, requestFromBody, gid));
    
                // I know this is what sends the response
                // Back to the client and I even tried
                // To put this at the very top of the method
                // But it still waits for routing to finish
                await context.Response.WriteAsync(gid);
            }
            catch (Exception ex)
            {
                Logger.Instance.ErrorLogBuffer.Add($"{ex.Message}{Environment.NewLine}{Environment.NewLine}{ex.StackTrace}");
            }
        });
}

1. 没有主动调用await context.Response.CompleteAsync()标记响应完成，Kestrel默认会追踪当前请求执行上下文关联的所有未完成任务（包括用Task.Run启动、捕获了请求上下文的后台任务），等所有关联任务执行完才会完成响应收尾，客户端自然会一直等待。
2. 未手动设置响应的Content-Length时，Kestrel会默认使用分块传输编码，必须等请求处理流程完全结束才会写入分块终止标记，客户端会一直等待连接结束判定响应完成。
3. 如果在Routing方法里直接引用了HttpContext、Request、Response或者从请求DI容器解析的服务，这些对象在请求生命周期结束后会被释放，不仅会导致等待，还可能触发对象已释放的异常。

按照以下顺序调整逻辑即可实现立即返回效果：

1. 提前拷贝所有需要的参数：在写响应之前，把长耗时任务需要的所有数据从请求上下文中全部读取、拷贝成本地变量，绝对不要在后台任务中引用任何和HttpContext绑定的对象。比如请求体必须提前读完存为字节数组/字符串，路由片段提前计算完成，需要的服务提前解析或者后续单独开DI作用域获取。
2. 优先写入并提交响应：设置明确的Content-Length，写入返回的ID之后，主动调用await context.Response.CompleteAsync()，该方法会立刻将所有响应数据刷到客户端，正式终止当前HTTP请求，此时客户端会立刻收到响应。
3. 响应完成后再启动后台任务：等请求完全提交后再启动长耗时任务，注意后台任务必须内部捕获所有异常，.NET 6+中未捕获的后台任务异常会直接终止进程。

修正后代码 #

public void Configure(IApplicationBuilder app)
{
    app
        .UseMaxConcurrentRequests()
        .Run(async (context) =>
        {
            try
            {
                // 第一步：生成ID，提前准备好所有后台任务需要的参数
                string gid = GlobalMethods.GetUniqueKey(14);
                var url = context.Request.Path.Value;

                /*
                原有URL处理、segments计算逻辑，全部在这里执行完
                */
                var segments = /* 你的segments计算逻辑 */;
                
                // 提前读取完请求体，不要在后台任务中访问context.Request.Body
                byte[] requestBodyBytes;
                using (var ms = new MemoryStream())
                {
                    await context.Request.Body.CopyToAsync(ms);
                    requestBodyBytes = ms.ToArray();
                }

                // 第二步：写入响应并主动提交，立即返回给客户端
                context.Response.ContentType = "text/plain";
                byte[] responseData = Encoding.UTF8.GetBytes(gid);
                context.Response.ContentLength = responseData.Length;
                await context.Response.Body.WriteAsync(responseData);
                // 关键：主动完成响应，立刻刷数据到客户端，终止当前请求
                await context.Response.CompleteAsync();

                // 第三步：请求已返回，启动后台长耗时任务
                _ = Task.Run(() =>
                {
                    try
                    {
                        // 传入提前拷贝好的参数执行逻辑，禁止访问任何HttpContext相关对象
                        Routing(segments, requestBodyBytes, gid);
                    }
                    catch (Exception bgEx)
                    {
                        // 后台任务必须自行处理所有异常，避免进程崩溃
                        Logger.Instance.ErrorLogBuffer.Add($"{bgEx.Message}{Environment.NewLine}{Environment.NewLine}{bgEx.StackTrace}");
                    }
                }, CancellationToken.None);
            }
            catch (Exception ex)
            {
                Logger.Instance.ErrorLogBuffer.Add($"{ex.Message}{Environment.NewLine}{Environment.NewLine}{ex.StackTrace}");
                if (!context.Response.HasStarted)
                {
                    context.Response.StatusCode = 500;
                }
            }
        });
}

• 这种直接在内存中启动的即发即弃任务没有持久化保障，如果应用重启、进程崩溃，正在执行的任务会直接丢失，对可靠性要求高的场景建议用持久化任务队列+独立后台服务消费的方案实现。
• 后台任务如果需要依赖注入服务，不要直接使用请求上下文中的服务实例，应该在后台任务中通过IServiceScopeFactory创建独立的DI作用域解析服务，避免访问已释放的对象。
• 不要给后台任务传入关联请求生命周期的CancellationToken，请求结束后该Token会被标记为取消，会导致后台任务意外终止。

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