0

我在 WCF 和我的客户端代码中进行开发，我用一个文件创建文件流以传输到服务（通过将其作为消息中的流发送）。服务收到流后，他和平阅读并写入新文件；服务从客户端下载文件给他，仅此而已。

我重写了文件流中的方法Read，这样我就可以知道在客户端下载服务时读取了多少内容。

public class FileStreamEx : FileStream
    {
        public long _ReadUntilNow { get; private set; }
        public FileStreamEx(string path, FileMode mode, FileAccess access, FileShare share)
            : base(path, mode, access, share)
        {
            this._ReadUntilNow = 0;
        }
        public override int Read(byte[] array, int offset, int count)
        {
            int ReturnV = base.Read(array, offset, count);
            _ReadUntilNow += ReturnV;
            return ReturnV;
        }
    }

我的目标是从客户端了解服务每秒读取了多少内容。这可以通过简单地从客户端查看 _ReadUntilNow 值来实现，因为服务仅使用对 FileStreamEx 对象的引用。

我的问题是，在服务甚至开始读取我给他的流之前，_ReadUntilNow 值 = 文件的大小。解决这个问题的唯一方法是在我这样做之前调用我的重写方法 Read。

我的问题是谁为我调用了 Read，为什么以及我可以做些什么来防止它？

我的客户：

public static void CallService()
        {
            ServiceReference1.IJob Service1 = new ServiceReference1.JobClient(new InstanceContext(new CCBImplement()));
            DLL.FileStreamEx TheStream TheStream = new DLL.FileStreamEx(@"C:\Uploadfiles\Chat.rar", FileMode.Open, FileAccess.Read, FileShare.None);
            ServiceReference1.RemoteFile RemoteFile1=new ServiceReference1.RemoteFile("Chat.rar", TheStream.Length, @"C:\Uploadfiles\Chat.rar", TheStream);
            Service1.UselessMethod1(RemoteFile1);
            new Thread(new ThreadStart(Check_Only_ReadUntilNow_Every_Second)).Start();
        }

服务代码：

public void UselessMethod1(RemoteFile RemoteFile)
        {
            Stream MyStream = RemoteFile.FileByteStream;
            using (FileStream fs = new FileStream(@"C:\Upload\"+RemoteFile.FileName, FileMode.Create))
            {
                int bufferSize = 1 ; // 1 MB buffer
                byte[] buffer = new byte[bufferSize];
                int totalBytes = 0;
                int bytes = 0;
                while ((bytes = MyStream.Read(buffer, 0, bufferSize)) > 0)
                {
                    fs.Write(buffer, 0, bytes);
                    fs.Flush();
                    totalBytes += bytes;
                }
            }
        }

远程文件类：

[MessageContract]
    public class RemoteFile : IDisposable
    {
        [MessageHeader]
        public string FileName;

        [MessageHeader]
        public string Path;

        [MessageHeader]
        public long Length;

        [MessageBodyMember]
        public Stream FileByteStream;
        public RemoteFile() { }
        public RemoteFile(string FileName, string Path, long Length, Stream FileByteStream)
        {
            this.Path = Path;
            this.FileName = FileName;
            this.Length = Length;
            this.FileByteStream = FileByteStream;
        }
        public void Dispose()
        {
            if (FileByteStream != null)
            {
                FileByteStream.Close();
                FileByteStream = null;
            }
        }
    }
4

1 回答 1

1

我认为他的问题是：在 A 方，有一个服务主机，它具有以流模式读取文件的方法。在 B 侧，有一个客户端使用此服务发送文件。

他扩展了 FileStream 类以添加一个变量，该变量保存从文件中读取的字节数。

他在 A 端调用服务，但在它到达方法之前 - 额外的变量保存了整个文件的大小......这意味着整个文件已被读取。

问题是为什么。

于 2012-05-11T19:40:05.020 回答