c# - 带有 ExecuteReaderAsync CommandBehavior.SequentialAccess 的 ASP.NET webapi HttpResponseMessage

Question

我需要通过 WebApi 从 Sql Server 流式传输 blob 数据。

我不想在 Web 服务器的内存中缓冲 blob 数据。

我有以下代码，但它不起作用 - 没有异常(exception)。

public class AttachmentController : ApiController
{
    public async Task<HttpResponseMessage> Get(int id)
    {
        using (var connection = new SqlConnection(ConfigurationManager.ConnectionStrings["ConnectionString"].ConnectionString))
        {
            await connection.OpenAsync();

            using (var command = new SqlCommand("SELECT Content FROM [Attachments] WHERE ID = @ID", connection))
            {

                command.Parameters.AddWithValue("ID", id);

                using (SqlDataReader reader = await command.ExecuteReaderAsync(CommandBehavior.SequentialAccess))
                {

                    if (await reader.ReadAsync())
                    {
                        using (Stream data = reader.GetStream(0))
                        {
                            var response = new HttpResponseMessage{Content = new StreamContent(data)};
                            //I get this from the DB else where
                            //response.Content.Headers.ContentType = new MediaTypeHeaderValue(attachment.ContentType);
                            //I get this from the DB else where
                            //response.Content.Headers.ContentLength = attachment.ContentLength;
                            return response;

                        }
                    }
                }
            }

            throw new HttpResponseException(HttpStatusCode.NotFound);
        }
    }
}

Fiddle 将以下错误作为响应写入:[Fiddler] ReadResponse() 失败:服务器未返回此请求的响应。

如何将内容从数据库流式传输到 http 输出流，而不在内存中进行缓冲？

Answer 1

您将在 ASP.NET MVC 完成读取之前关闭流。一旦您离开了 return 语句执行后立即发生的各种 using block ，它将关闭。

我知道没有简单的方法可以完成此任务。最好的想法是编写一个自定义的 Stream 派生类，它包装 ADO.NET 返回的流，一旦流耗尽就会处理所有内容(Stream，阅读器、命令和连接)。

此解决方案意味着您不能使用 using block 等。我真的不喜欢它，但我现在想不出更好的东西。需求很难组合:你想要流式行为，需要处理你打开的各种资源。