1

我正在为 web-api 应用程序进行一些压缩/解压缩。

由于网络上的多篇文章和此处发布的问题，我已经实现了大部分。

然而，我仍然被困在一个甚至还没有受到质疑的问题上。

简而言之，我需要支持大量数据的流式传输，包括响应和请求，并且都是压缩的。我已经实现DelegatingHandler并创建了 2 个HttpContent类，一个用于压缩内容（响应），另一个用于解压缩内容（请求）。

使用以下代码压缩响应完美

protected override Task SerializeToStreamAsync(System.IO.Stream stream, System.Net.TransportContext context)
{
    Stream compressionStream = this.Compressor.CreateCompressionStream(stream);

    return this.OriginalContent.CopyToAsync(compressionStream).ContinueWith(task =>
    {
        if (compressionStream != null)
        {
            compressionStream.Dispose();
        }
    });
}

我创建了一个压缩流并将原始内容复制到压缩流中。但是，在解压缩请求时，我目前正在使用以下代码。

protected override Task SerializeToStreamAsync(System.IO.Stream stream, System.Net.TransportContext context)
{
    Stream compressionStream = 
      this.Compressor.CreateDecompressionStream(
                                       this.OriginalContent.ReadAsStreamAsync().Result);

    return compressionStream.CopyToAsync(stream).ContinueWith(task =>
    {
        if (compressionStream != null)
        {
            compressionStream.Dispose();
        }
    });
}

如您所见，我有义务将原始请求作为流读取，然后再将其复制到解压缩流并将其进一步发送到管道中。

当大量数据发布到服务时，这可能不是一个好的做法。那么现在的问题是，这是正确的方法吗？我一直在寻找一种无缝的方式来做到这一点。

我正在考虑实现一个阻塞流（适应新的 TAP），但我再次陷入困境，因为 HttpContent 完全是 TAP，这意味着一切都返回一个任务对象，我需要一个实际流的句柄。

4

1 回答 1

0

我可以回答你的部分问题。到您调用时this.OriginalContent.ReadAsStreamAsync()，您的请求内容已经被缓冲了。这是因为默认情况下 Web API 会缓冲所有传入请求。但是，是的，对于较大的请求，不使用这种缓冲模式是有意义的。但是，您可以更改此默认缓冲区策略。

下面的示例（如果您使用的是 WebHost。这不适用于 Selfhost）：

config.Services.Replace(typeof(IHostBufferPolicySelector), new CustomBufferPolicySelector());

public class CustomBufferPolicySelector : WebHostBufferPolicySelector
{
    // This method gets called for every incoming request. You can inspect the HttpContextBase instance
    // to decide whether you would want buffered/non-buffered way of handling individual requests.
    public override bool UseBufferedInputStream(object hostContext)
    {
        HttpContextBase contextBase = hostContext as HttpContextBase;

        //by default, this returns 'true'  
        return base.UseBufferedInputStream(hostContext);
    }

    // just fyi
    public override bool UseBufferedOutputStream(HttpResponseMessage response)
    {
        return base.UseBufferedOutputStream(response);
    }
}

现在，在拥有上述自定义策略之后，当您执行 a 时this.OriginalContent.ReadAsStreamAsync()，您将收到一个未缓冲的流。

于 2013-06-18T17:28:54.210 回答