3

我的最终目标是将大型视频文件和流上传到配置为流传输模式的 WCF 服务。我遇到的问题是我的 WCF 客户端仅在流被读取到最后之后才向服务发出请求。

主要用例是将实时流中继到没有预定义结束点的服务，因此在发送任何数据之前完全读取这些流是不切实际的。为了测试这个功能，我创建了一个“无限”流：

public class InfiniteStream : Stream
{
    private Random _random;

    public InfiniteStream()
    {
        _random = new Random(1);
    }

    public override int Read(byte[] buffer, int offset, int count)
    {
        _random.NextBytes(buffer);
        Position += count;
        return count;
    }

    // other unimportant methods
}

并且与我发现的示例一致，用于接收流式上传的 MessageContract：

[MessageContract]
public class ClipUpload : IDisposable
{
    [MessageHeader(MustUnderstand = true)]
    public long MediaId;

    [MessageBodyMember(Order=1)]
    public System.IO.Stream MediaStream;

    // disposable implementaton
}

现在，据我所知，我的服务已针对流传输进行了正确配置，并且可以在服务器端毫无问题地读取流。感兴趣的服务器配置：

<basicHttpsBinding>
    <binding name="A" transferMode="Streamed" maxReceivedMessageSize="4294967296" maxBufferSize="65536">
        <security mode="TransportWithMessageCredential">
            <message clientCredentialType="UserName" />
        </security>
    </binding>
</basicHttpsBinding>

感兴趣的客户端配置：

<basicHttpsBinding>
    <binding name="A" transferMode="Streamed" maxBufferSize="65536">
        <security mode="TransportWithMessageCredential" />
    </binding>
</basicHttpsBinding>

服务器端操作很简单。在我的服务接口中::

[OperationContract(IsOneWay=true)]
void UploadClip(ClipUpload upload);

执行：

public void UploadClip(ClipUpload upload)
{
    using (var stream = new FileStream(@"C:\Temp\temp.mp4", FileMode.Create, FileAccess.Write))
    {
        upload.MediaStream.CopyTo(stream);
    }

客户端也使用了一个简单的调用：

using(var stream = new InfiniteStream())
{
    _service.UploadClip(1, stream);
}

同样，问题是客户端在完全读取流之前不会发送任何流数据，对于 InfiniteStream 来说当然不会出现这种情况。因此，流永远不会到达服务器的 UploadClip 方法。对于非“无限”流，该过程有效，但在客户端似乎正在缓冲所有流内容时存在相当大的延迟。

4

1 回答 1

0

似乎 Fiddler 可能一直在引入自己的缓冲区。关闭 Fiddler 后，流式请求已正确移交给 WCF。

与此相关的是，在 .NET 4.0 及更低版本上，托管在 IIS 中的流式 WCF 服务的服务器端缓冲似乎是不可避免的。ASP.NET 层有自己的缓冲机制，它会等到消息被完全接收到后再将其传递给 WCF。更多细节在这里。

于 2013-06-03T16:03:41.780 回答