ASP.NET webapi HttpResponseMessage with ExecuteReaderAsync C
本文关键字:ExecuteReaderAsync with HttpResponseMessage NET webapi ASP | 更新日期: 2023-09-27 18:28:11
我需要通过WebApi从Sql Server流式传输blob数据。
我不想在web服务器的内存中缓冲blob数据。
我有以下代码,但它不起作用——没有例外。
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()失败:服务器没有返回对此请求的响应。
如何将内容从DB流式传输到http输出流,而不在内存中进行缓冲?
您在ASP.NET MVC完成对流的读取之前就关闭了流。一旦您离开各种使用块,它就会关闭,这发生在return
语句执行之后。
我知道没有简单的方法可以做到这一点。最好的想法是编写一个自定义的Stream
派生类,该类封装ADO.NET返回的流,一旦流耗尽,就处理所有内容(Stream
、读取器、命令和连接)。
这个解决方案意味着您不能使用块之类的。我真的不喜欢它,但我现在想不出更好的了。这些要求很难结合起来:您想要流式行为,并且需要处理您打开的各种资源。