我的最终目标是启用将大型视频文件和流上传到配置为流式传输模式的WCF服务。我遇到的问题是我的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方法。对于非“无限”流,该过程起作用,但是在客户端似乎缓冲了所有流内容的情况下存在相当大的延迟。