C#读文件为什么结束不了啦，大家帮忙看看代码

Question

String path = @"D://TDDOWNLOAD//Ju-on.2000.2in1.DVDRip-AVC.mkv";            //Open the stream and read it back.
            FileStream fs = File.OpenRead(path);
            FileStream fo = File.OpenWrite(@"E://Ju-on.2000.2in1.DVDRip-AVC.mkv");
            byte[] b = new byte[1024 * 1024];
            while (fs.Read(b,0,b.Length) >= 0) 
            {
                fo.Write(b,0,b.Length);
                fo.Flush();
            }
            fo.Close();
            fs.Close();这是按照帮助文档上写的读写文件，刻个文件一共2G，可是一直结束不了，会多出几个G出来。byte写1024的话就没有问题，些1024 * 1024 就有问题了。

Answer 1

byte[] 最大能多大啊？在线等。

Answer 2

这里有两个错误，另一个错误你还不容易发现
1 fs.Read 如果遇到文件结束，会返回 0 ，但你并不退出循环，这就是问题
2 fo.Write 的长度你写错了，应该用 fs.Read 返回的长度，这样会导致文件比原来的长，多出来的部分内容是最后第二次读取的，导致文件长度变成数组长度的整数倍。

Answer 3

嗯，byte 里面写1024 就没有问题，写大了就会一直读。原来我是写的>0 ,也有问题，后来我修改成>=0 ,一样的效果。

Answer 4

我觉得第一个 问题是不存在的，while（）不满足条件的时候自己就退出了。第二个问题存在，我还不知道怎么修改，我看MSDN中也是这么写的。我就照抄过来了。

Answer 5

我试了一下，你将等号去掉，就好了，虽然会出现你上面说的那个问题，但是多出来的大小不会大于你定义的一个byte的大小的，因为只有在最后读取的一个byte里面才会出现内容不足的情况

Answer 6

我把等号去掉了，读写文件也没问题，文件比之前的大一点，但是网路发送会变大。            FileStream fs = File.OpenRead(@"D://TDDOWNLOAD//Ju-on.2000.2in1.DVDRip-AVC.mkv");
            Byte[] sendByte = new Byte[1024 * 1024 * 10];
            //Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
            
            while (fs.Read(sendByte, 0, sendByte.Length) > 0)
            {
                clientSocket.Send(sendByte);
            }
            fs.Close();
            

Answer 7

byte[] 最大能多大啊？在线等。
肯定比你这个1024*1024这个大！

Answer 8

为什么不用File.Copy，多好，别人一看就知道那干嘛用的

Answer 9

我是用在socket中的，用socket传输文件。

Answer 10

用StreamReader流读取，EndOfStream属性就能判断是否结束！

Answer 11

StreamReader 是字符型的，我测试也不是很快。

Answer 12

因为用了Socket网络传输，所以就快不了！

Answer 13

有简单的做法，为什么要弄那么复杂呢？
            System.IO.FileStream fs = System.IO.File.OpenRead(@"G:\音乐\杰子 - 玫瑰花儿开.mp3");
            fs.CopyTo(System.IO.File.OpenWrite(@"G:\音乐\杰子 - 玫瑰花儿开1.mp3"));

Answer 14

如果想一次读完，有简单方法
var fs = System.IO.File.OpenRead()
using(var ms = new MemoryStream(fs))
    byte[] datas = ms.ToArray();不过大文件一般都是分块发送

Answer 15

while (fs.Read(b,0,b.Length) >= 0) 
            {
                fo.Write(b,0,b.Length);
                fo.Flush();
            }
问题出在这里！

Answer 16

String path = @"D://TDDOWNLOAD//Ju-on.2000.2in1.DVDRip-AVC.mkv";
 
            //Open the stream and read it back.
            FileStream fs = File.OpenRead(path);
            FileStream fo = File.OpenWrite(@"E://Ju-on.2000.2in1.DVDRip-AVC.mkv");
            byte[] b = new byte[1024 * 1024];
            while (fs.Read(b,0,b.Length) >= 0) <-问题出在这知道没
            {
                fo.Write(b,0,b.Length);
                fo.Flush();
            }
            fo.Close();
            fs.Close();           //改成这样
         String path = @"D://TDDOWNLOAD//Ju-on.2000.2in1.DVDRip-AVC.mkv";
            //Open the stream and read it back.
            FileStream fs = File.OpenRead(path);
            FileStream fo = File.OpenWrite(@"E://Ju-on.2000.2in1.DVDRip-AVC.mkv");
            byte[] b = new byte[1024 * 1024];
            int reLen=0;
            while ((reLen=fs.Read(b,0,b.Length))>= 0)  //<--这里要这样
            {
                fo.Write(b,0,reLen); 《-这里要这样
                fo.Flush();
            }
            fo.Close();
            fs.Close();

Answer 17

byte[] b = new byte[1024 * 1024];
红色字建议改为何4096或8192
while (fs.Read(b,0,b.Length) >4096或8192) 

Answer 18

感谢大家的回答，我想问题还是出在byte[] 上。
我不想一次传输完成，因为文件的大小是不固定的。这个>=我已经修改了，读写本地的文件没有问题，发送到网路就有问题了。
String path = @"D://TDDOWNLOAD//Ju-on.2000.2in1.DVDRip-AVC.mkv";
 
            //Open the stream and read it back.
            FileStream fs = File.OpenRead(path);
            FileStream fo = File.OpenWrite(@"E://Ju-on.2000.2in1.DVDRip-AVC.mkv");
            byte[] b = new byte[1024 * 1024];
            while (fs.Read(b,0,b.Length) >= 0) <-问题出在这知道没
            {
                fo.Write(b,0,b.Length);
                fo.Flush();
            }
            fo.Close();
            fs.Close();           //改成这样
         String path = @"D://TDDOWNLOAD//Ju-on.2000.2in1.DVDRip-AVC.mkv";
            //Open the stream and read it back.
            FileStream fs = File.OpenRead(path);
            FileStream fo = File.OpenWrite(@"E://Ju-on.2000.2in1.DVDRip-AVC.mkv");
            byte[] b = new byte[1024 * 1024];
            int reLen=0;
            while ((reLen=fs.Read(b,0,b.Length))>= 0)  //<--这里要这样
            {
                fo.Write(b,0,reLen); 《-这里要这样
                fo.Flush();
            }
            fo.Close();
            fs.Close();好的，我试试。
这个应该不影响的，还是感谢的回答。

Answer 19

你是为了传输文件？那要做分块。。写个文件分块类。。看你结贴率高，就给你一个我项目上用的文件传输分块的类，你一下就明白了。public class FileReader
    {
        
        private long _partCount;
        private long _length;
        private int _partSize = 4096 * 4;//每个块容量
        private string _md5;
        private object _tag;
        private byte[] _partBuffer;
        private int readPartIndex;
        private string _filePath;
        private DateTime _LastReadTime;
        private string _fileName;        public DateTime LastReadTime { get { return _LastReadTime; } }
        public bool IsTimeout
        {
            get
            {
                return (DateTime.Now - _LastReadTime).TotalMinutes > 5;
            }
        }        public string Key { get; set; }        /// <summary>
        /// 块数量
        /// </summary>
        public long PartCount
        {
            get { return _partCount; }
        }        /// <summary>
        /// 文件长度
        /// </summary>
        public long Length
        {
            get { return _length; }
        }        /// <summary>
        /// 每块容量
        /// </summary>
        public int PartSize
        {
            get { return _partSize; }
        }
        /// <summary>
        /// 文件路径
        /// </summary>
        public string FilePath
        {
            get { return _filePath; }
        }        /// <summary>
        /// 文件名
        /// </summary>
        public string FileName
        {
            get { return _fileName; }
        }        /// <summary>
        /// MD5码
        /// </summary>
        public string MD5
        {
            get { return _md5; }
        }
        public object Tag
        {
            get
            {
                return _tag;
            }
            set
            {
                _tag = value;
            }
        }
        public FileReader(string filePath)
        {            this._filePath = filePath;
            this._fileName = Path.GetFileName(filePath);
            this._partBuffer = new byte[_partSize];
            InitReader();
        }        public FileReader(string filePath, int partSize)
        {
            this._filePath = filePath;
            this._fileName = Path.GetFileName(filePath);
            this._partSize = partSize;
            this._partBuffer = new byte[_partSize];
            InitReader();
        }
        private void InitReader()
        {
            _LastReadTime = DateTime.Now;
            using (FileStream _fileStream = CreateReader())
            {
                _length = _fileStream.Length;
                _partCount = _length / _partSize;
                if (_length % _partSize != 0)
                {
                    _partCount++;
                }
                _md5 = MD5Helper.CretaeMD5(_fileStream);
                _fileStream.Close();
            }
        }        private FileStream CreateReader()
        {
            FileStream fileStream = new FileStream(_filePath, FileMode.Open, FileAccess.Read, FileShare.Read, _partSize * 10, false);
            return fileStream;
        }        public byte[] Read(long index)
        {
            _LastReadTime = DateTime.Now;            if (index >= _partCount || index < 0)
                return null;            int size = _partSize;            if (_length - _partSize * index < _partSize)
            {
                size = (int)(_length - _partSize * index);
            }            using (FileStream _fileStream = CreateReader())
            {
                _fileStream.Position = index * _partSize;
                int len = _fileStream.Read(this._partBuffer, 0, size);
                byte[] buffer = new byte[len];
                Buffer.BlockCopy(_partBuffer, 0, buffer, 0, len);
                _fileStream.Close();
                return buffer;
            }
        }    }

Answer 20

你是为了传输文件？那要做分块。。写个文件分块类。。看你结贴率高，就给你一个我项目上用的文件传输分块的类，你一下就明白了。public class FileReader
    {
        
        private long _partCount;
        private long _length;
        private int _partSize = 4096 * 4;//每个块容量
        private string _md5;
        private object _tag;
        private byte[] _partBuffer;
        private int readPartIndex;
        private string _filePath;
        private DateTime _LastReadTime;
        private string _fileName;        public DateTime LastReadTime { get { return _LastReadTime; } }
        public bool IsTimeout
        {
            get
            {
                return (DateTime.Now - _LastReadTime).TotalMinutes > 5;
            }
        }        public string Key { get; set; }        /// <summary>
        /// 块数量
        /// </summary>
        public long PartCount
        {
            get { return _partCount; }
        }        /// <summary>
        /// 文件长度
        /// </summary>
        public long Length
        {
            get { return _length; }
        }        /// <summary>
        /// 每块容量
        /// </summary>
        public int PartSize
        {
            get { return _partSize; }
        }
        /// <summary>
        /// 文件路径
        /// </summary>
        public string FilePath
        {
            get { return _filePath; }
        }        /// <summary>
        /// 文件名
        /// </summary>
        public string FileName
        {
            get { return _fileName; }
        }        /// <summary>
        /// MD5码
        /// </summary>
        public string MD5
        {
            get { return _md5; }
        }
        public object Tag
        {
            get
            {
                return _tag;
            }
            set
            {
                _tag = value;
            }
        }
        public FileReader(string filePath)
        {            this._filePath = filePath;
            this._fileName = Path.GetFileName(filePath);
            this._partBuffer = new byte[_partSize];
            InitReader();
        }        public FileReader(string filePath, int partSize)
        {
            this._filePath = filePath;
            this._fileName = Path.GetFileName(filePath);
            this._partSize = partSize;
            this._partBuffer = new byte[_partSize];
            InitReader();
        }
        private void InitReader()
        {
            _LastReadTime = DateTime.Now;
            using (FileStream _fileStream = CreateReader())
            {
                _length = _fileStream.Length;
                _partCount = _length / _partSize;
                if (_length % _partSize != 0)
                {
                    _partCount++;
                }
                _md5 = MD5Helper.CretaeMD5(_fileStream);
                _fileStream.Close();
            }
        }        private FileStream CreateReader()
        {
            FileStream fileStream = new FileStream(_filePath, FileMode.Open, FileAccess.Read, FileShare.Read, _partSize * 10, false);
            return fileStream;
        }        public byte[] Read(long index)
        {
            _LastReadTime = DateTime.Now;            if (index >= _partCount || index < 0)
                return null;            int size = _partSize;            if (_length - _partSize * index < _partSize)
            {
                size = (int)(_length - _partSize * index);
            }            using (FileStream _fileStream = CreateReader())
            {
                _fileStream.Position = index * _partSize;
                int len = _fileStream.Read(this._partBuffer, 0, size);
                byte[] buffer = new byte[len];
                Buffer.BlockCopy(_partBuffer, 0, buffer, 0, len);
                _fileStream.Close();
                return buffer;
            }
        }    }
多谢！我去试试！感谢大家。先结贴了，如果我解决这个问题，我会把答案写在这里的。！

Answer 21

byte[] 最大能多大啊？在线等。byte 是0到255吧····