2

我正在从 ServiceStack 服务返回数据流，如下所示。请注意，我需要以这种方式而不是此处概述的方式来执行此操作，因为在将数据写入输出流后我需要执行一些清理。

using (var fs = new FileStream(filePath, FileMode.Open, FileAccess.Read))
{
    fs.WriteTo(Response.OutputStream);
}
Response.EndRequest();
...cleanup code...

通过使用类似于此答案的 ServiceRunner，在返回简单 DTO 的其他服务中处理压缩。但是，上面的流响应永远不会命中该代码，因为其中的响应对象OnAfterExecute始终为空。我可以手动压缩服务方法内部的结果，如下所示，但它需要大量设置来确定是否需要压缩以及需要什么压缩，并手动设置正确的 HTTP 标头（下面省略）。

var outStream = new MemoryStream();
using (var fs = new FileStream(filePath, FileMode.Open, FileAccess.Read))
using (var tinyStream = new GZipStream(outStream, CompressionMode.Compress))
{
    fs.CopyTo(tinyStream);
    outStream.WriteTo(Response.OutputStream);
}
Response.EndRequest();
...cleanup code...

ServiceStack 中是否有一种方法可以为我处理这种压缩，类似于它与ServiceRunner?

4

1 回答 1

2

我不太确定您喜欢 ServiceStack 在 ServiceRunner 中处理压缩的方式。是因为它在 ServiceStack API 中是全局的吗？

对于您的示例，我认为类似下面的内容可以满足您在将数据写入输出流后执行一些清理的需要......

public class FStreamService : Service
{
    public object Get(FStream request)
    {
        var filePath = @"c:\test.xml";
        var compressFileResult = new CompressedFileResult(filePath); //CompressedResult in ServiceStack.Common.Web.CompressedFileResult
        compressFileResult.WriteTo(Response.OutputStream);
        Response.EndRequest();
        //  ...cleanup code...
    }
}

基于上面的评论更新，使用一些 ServiceStack 扩展添加压缩

public object Get(FStream request)
{
    var filePath = @"c:\test.xml";
    using (var fs = new FileStream(filePath, FileMode.Open, FileAccess.Read))
    {
        var compressedBtyes = fs.ToUtf8String().Compress(this.RequestContext.CompressionType);
        new CompressedResult(compressedBtyes).WriteTo(Response.OutputStream);           
    }
    Response.EndRequest();
        //  ...cleanup code...
}

如果你想在 ServiceRunner 中使用它，这样的东西应该可以工作......

public override object OnAfterExecute(IRequestContext requestContext, object response)
{
    var resp = requestContext.Get<IHttpResponse>();
    response = requestContext.ToOptimizedResult(requestContext.Get<IHttpResponse>().OutputStream);       

    return base.OnAfterExecute(requestContext, response);
}

于 2013-09-19T20:47:34.710 回答