通过 WebAPI 流式传输 SqlFileStream

Question

我已经设置了一个支持 FILESTREAM 的 SQL 数据库，并尝试通过 WebAPI 将使用 SqlFileStream 从数据库中检索到的文件流式传输到浏览器。

由于某种原因它不起作用，但我没有收到正确的错误消息。浏览器只是中止连接，Fiddler 也没有显示任何有用的东西，VS 中似乎没有抛出任何错误。

public HttpResponseMessage Get(Guid id)
{
    if(id == null || id == Guid.Empty)
        return Request.CreateResponse(HttpStatusCode.BadRequest);

    try
    {
        FileStreamContext fsc = null;
        Document document = null;
        using(var transaction = new TransactionScope())
        using (var db = new MyEntities())
        {
            try
            {
                fsc = db.Database.SqlQuery<FileStreamContext>("SELECT [File].PathName() AS InternalPath, GET_FILESTREAM_TRANSACTION_CONTEXT() AS TransactionContext FROM Document WHERE id={0}", id).First();
            }
            catch (Exception e)
            {
                Debug.Print(e.ToString());
            }

            document = db.Documents.Where(doc => doc.ID == id).Single();

            var fileStream = new SqlFileStream(fsc.InternalPath, fsc.TransactionContext, FileAccess.Read);

            HttpResponseMessage response = new HttpResponseMessage();
            response.Content = new StreamContent(fileStream);
            //response.Content.Headers.ContentDisposition = new ContentDispositionHeaderValue("attachment");
            //response.Content.Headers.ContentDisposition.FileName = document.FileName;
            response.Content.Headers.ContentType = MediaTypeHeaderValue.Parse(document.ContentType);
            return response;
        }
    }
    catch (Exception e)
    {
        return Request.CreateResponse(HttpStatusCode.BadRequest);
    }
}

我怀疑 TransactionScope 提前关闭可能是个问题？不知道为什么我没有收到任何错误消息。

通过 WebApi 流式传输 SqlFileStream 的正确方法是什么？

Answer 1

除了将内容设置为StreamContent，您是否尝试过在控制器中读取fileStream，将其放入byte 数组，然后使用ByteArrayContent 设置内容？

var fileStream = new SqlFileStream(fsc.InternalPath, fsc.TransactionContext, FileAccess.Read);
byte[] fileContent = fileStream.ReadFully(); // you will need to implement ReadFully
HttpResponseMessage response = new HttpResponseMessage();
response.Content = new ByteArrayContent(fileContent);

对于ReadFully 的实现，我使用过的here is a link to a Jon Skeet method。

而且我怀疑您对连接关闭太早的说法是正确的。您的 DbContext / ObjectContext 很好地包裹在 using 块中，但我认为这就是问题所在。该上下文在控制器返回HttpResponseMessage 后被释放，但响应只能访问流——它仍然需要读取流并将其转换为byte[]，然后再传递回浏览器或客户端。这通常在您使用MemoryStream 或类似名称时自动发生，因为框架仍然可以访问流以读取其内容。但是，在这种情况下，您将在读取流之前处理您的 SQL 连接。

另一种解决方案可能是为您的DbContext 使用依赖注入，而不是在操作方法中对其进行更新。如果您将 IoC 容器设置为在 HTTP 请求结束时自动处理上下文，那么当框架将 StreamContent 转换为 byte[] 并将其推回时，它应该仍然可用（未处理）通过网络。