WCF流 - 限制速度

Question

在我的申请中,这是一个严重的问题,几个月没有找到任何好的解决方案.我注意到C#管理Stream类在WCF中流式传输的方式,而不考虑我的配置.

首先,我有一个继承自FileStream的类,因此我可以随时观察从客户端读取的内容:

public class FileStreamWatching : FileStream
    {
        /// <summary>        
        /// how much was read until now        
        /// </summary>        
        public long _ReadUntilNow { get; private set; }
        public FileStreamWatching(string Path, FileMode FileMode, FileAccess FileAccess)
            : base(Path, FileMode, FileAccess)
        {
            this._ReadUntilNow = 0;
        }
        public override int Read(byte[] array, int offset, int count)
        {
            int ReturnV = base.Read(array, offset, count);
            //int ReturnV = base.Read(array, offset, count);
            if (ReturnV > 0)
            {
                _ReadUntilNow += ReturnV;
                Console.WriteLine("Arr Lenght: " + array.Length);
                Console.WriteLine("Read: " + ReturnV);
                Console.WriteLine("****************************");
            }
            return ReturnV;
        }
    }

其次,下面是我读取包含该文件的客户端流的服务方法.我的主要问题是FileStreamWatching.Read每次从下面的方法中召唤它时都没有启动,而是FileStreamWatching.Read每次X调用它启动一次.奇怪.

*稍后看看输出

    public void Get_File_From_Client(Stream MyStream)
    {
        using (FileStream fs = new FileStream(@"C:\Upload\" + "Chat.rar", FileMode.Create))
        {
            byte[] buffer = new byte[1000];
            int bytes = 0;
            while ((bytes = MyStream.Read(buffer, 0, buffer.Length)) > 0)
            {
                fs.Write(buffer, 0, bytes);
                fs.Flush();
            }
        }
    }

这是每次激活FileStreamWatching.Read时客户端的输出:(重新启动缓冲区长度仅为1000!)

Arr Lenght:256,阅读:256

---

Arr Lenght:4096,阅读:4096

---

Arr Lenght:65536,阅读:65536

---

Arr Lenght:65536,阅读:65536

---

Arr Lenght:65536,阅读:65536

---

Arr Lenght:65536,阅读:65536

---

....直到文件传输完成.

问题:

1. 我带到读取方法的缓冲区的长度不是256/4096/65536.这是1000.
2. 每次从服务中调用时,FileStreamWatching类中的Read都不会启动.

我的目标:

1. 控制每次读取从客户端重新开始的数量.

2. FileStreamWatching.Read将在每次从服务中调用它时启动.

我的客户端配置:

<configuration>
    <system.serviceModel>
        <bindings>
            <basicHttpBinding>
                <binding name="BasicHttpBinding_IJob" transferMode="Streamed"/>
            </basicHttpBinding>
        </bindings>
        <client>
            <endpoint address="http://localhost:8080/Request2" binding="basicHttpBinding"
                bindingConfiguration="BasicHttpBinding_IJob" contract="ServiceReference1.IJob"
                name="BasicHttpBinding_IJob" />
        </client>
    </system.serviceModel>
</configuration>

我的服务配置(此处没有配置文件):

        BasicHttpBinding BasicHttpBinding1 = new BasicHttpBinding();
        BasicHttpBinding1.TransferMode = TransferMode.Streamed;
        //
        BasicHttpBinding1.MaxReceivedMessageSize = int.MaxValue;
        BasicHttpBinding1.ReaderQuotas.MaxArrayLength = 1000;
        BasicHttpBinding1.ReaderQuotas.MaxBytesPerRead = 1000;
        BasicHttpBinding1.MaxBufferSize = 1000;
        //
        ServiceHost host = new ServiceHost(typeof(JobImplement), new Uri("http://localhost:8080"));
        //
        ServiceMetadataBehavior behavior = new ServiceMetadataBehavior();
        behavior.HttpGetEnabled = true;
        //
        host.Description.Behaviors.Add(behavior);
        ServiceThrottlingBehavior throttle = new ServiceThrottlingBehavior();
        throttle.MaxConcurrentCalls = 1;
        host.Description.Behaviors.Add(throttle);
        //
        //
        host.AddServiceEndpoint(typeof(IJob), BasicHttpBinding1, "Request2");
        host.Open();

Answer 1

回复：为什么是 256/4K/65535？

我看到这里有两种可能性：

• 底座FileStream正在做自己的内部缓冲。它可能会在内部调用read(array,offset,length)来填充其内部缓冲区，然后传回您要求的部分。内部调用最终会递归，直到读取整个文件。然后您的覆盖将停止显示任何内容。
• 还有其他stream.read()签名您没有显示为被覆盖。如果任何代码路径最终调用其他read方法之一，那么您的计数将会关闭。

回复：MyStream 并非每次都重新开始

争论已经解决了吗MyStream？或者它被重用于新的流？您的代码仅在构造函数中“重新启动”，因此当您更改传入流时，请确保该对象已被释放并重新构造。

您可以通过在达到 EOF 时显示一些内容来测试递归 EOF 情况。

如果添加统计应用程序调用MyStream.Read和方法进入/退出的静态变量，则可以测试意外递归。如果它们不匹配，则FileStream进行内部（意外递归）调用。

-杰西