c# - ServiceStack流压缩

Question

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

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

压缩是在返回简单 DTO 的其他服务中通过使用类似于 this answer 的 ServiceRunner 来处理的。 。但是，上面的流响应永远不会命中该代码，因为 OnAfterExecute 中的响应对象始终为 null。我可以按如下方式在服务方法内部手动压缩结果，但需要进行大量设置来确定是否需要压缩以及需要什么压缩，并手动设置正确的 HTTP header (下面省略)。

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 的方式？

Answer 1

我不太确定您对 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);
}

<罢工>