WebApi返回SQL数据库流时如何在传输完成后正确关闭DbConnection

问题根因 #

你当前的实现存在两个隐藏问题：

1. 你手动通过DbContext.Database.OpenConnectionAsync()打开的连接确实不会被EF Core自动关闭：EF Core的默认连接管理规则是仅自动释放由EF自身打开的连接，用户手动打开的连接会被认为需要自行管理生命周期，长期运行下会出现连接池耗尽的问题。
2. 控制器方法内的await using修饰的command、reader会在方法返回FileStreamResult后立即触发释放，此时HTTP响应还没开始向客户端传输流内容，你观察到的"运行正常"仅在文件体积足够小、刚好在资源释放前完成传输的场景下成立，大文件必然会出现传输中断的问题。

解决方案 #

我们只需要把数据库相关资源的释放时机绑定到HTTP响应完全发送完成的节点即可，ASP.NET Core原生提供了注册待释放资源的接口，不需要自己封装流。
另外读取大体积varbinary(max)字段时必须加CommandBehavior.SequentialAccess，否则DataReader会默认把整个二进制字段加载到内存中，失去流式传输的意义。

修正后的原生ADO.NET实现（兼容所有EF Core版本） #

public async Task<IActionResult> GetFile(Guid fileId)
{
    var query = @$"SELECT FileBinary
                  FROM {SchemaName}.{TableName} 
                  WHERE {GetSqlColumnName(nameof(Id))} = @id";

    var idParameter = new SqlParameter("id", fileId) { DbType = DbType.Guid };
    var command = DbContext.Database.GetDbConnection().CreateCommand();
    command.CommandText = query;
    command.CommandType = CommandType.Text;
    command.Parameters.Add(idParameter);

    await DbContext.Database.OpenConnectionAsync().ConfigureAwait(false);
    // 关键：加上SequentialAccess开启流式读取，加上CloseConnection让Reader关闭时自动关闭连接
    var reader = await command.ExecuteReaderAsync(
        CommandBehavior.SequentialAccess | 
        CommandBehavior.SingleRow | 
        CommandBehavior.CloseConnection
    ).ConfigureAwait(false);
    
    await reader.ReadAsync();
    var stream = reader.GetStream(0);

    // 关键：把Reader、Command都注册到HTTP上下文，响应发送完成后自动释放
    HttpContext.Response.RegisterForDispose(reader);
    HttpContext.Response.RegisterForDispose(command);
    // 也可以用异步释放的重载：RegisterForDisposeAsync

    return new FileStreamResult(stream, "application/pdf");
}

这个实现下：

• 响应传输完成后，ASP.NET Core会自动先关闭从DataReader拿到的流，再释放你注册的reader、command
• CommandBehavior.CloseConnection会在reader释放时自动关闭关联的数据库连接，不需要你手动操作
• SequentialAccess确保DataReader不会提前加载整个二进制字段到内存，真正实现流式传输

EF Core 7+ 更简化的实现 #

EF Core 7.0开始新增了二进制属性的原生流式读取支持，不需要自己写ADO.NET代码：
首先你需要确保实体类上对应varbinary(max)的属性已经正常映射为byte[]类型，然后直接用GetStreamAsync扩展方法即可：

public async Task<IActionResult> GetFile(Guid fileId)
{
    var fileStream = await DbContext.Set<你的文件实体类>()
        .Where(f => f.Id == fileId)
        .Select(f => f.FileBinary)
        .GetStreamAsync();

    return File(fileStream, "application/pdf");
}

EF Core内部已经处理了所有资源的生命周期管理，不需要你手动管理连接、Reader的释放，也默认开启了流式读取逻辑。

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