前言
前不久遇到一个问题，是公司早期的基础库遇到的，其实很低级，但是还是记录下来。出错点是一个 io 流的写入bug，我们项目会有一种专有的数据格式，这个格式的奇葩点在于如果设置 io 读缓冲区为 2014 字节的时候，整个文件刚好能读完，也就是说其 length 刚好是 1024 的倍数。后来在一次升级中增加了更多的文件格式，并且新的文件格式使用了新的自定义写入流，具有加密和压缩的作用，这样一来，文件的长度就不一定是 1024 的倍数了。
后来通过查看这个基础类的源代码发现因为是 .net 2.0 时代的东西，也没有 stream.copy 的方法，于是当时的程序员手动写了个 stream.copy 的方法，我稍作改动为了更直观将输出流改为输出到文件，代码大概如下：
|
1
2
3
4
5
6
7
8
|
var fs_in = system.io.file.openread(@"c:\3.0.6.apk");var fs_out = system.io.file.openwrite(@"c:\3.0.6.apk.copy");byte[] buffer = new byte[1024];while (fs_in.read(buffer,0,buffer.length)>0){ fs_out.write(buffer, 0, buffer.length);}console.writeline("复制完成"); |
所以一眼就能看出这个方法简直有天大的 bug ，假设文件长度不为 1024 的倍数，永远会在文件尾部多补充上一段的冗余数据。
这里整整多出了 878 字节的数据，导致整个文件都不对了，明显是基础知识都没学好。
增加一个变量保存实际读取到的字节数，改为如下：
|
1
2
3
4
5
6
7
8
9
|
var fs_in = system.io.file.openread(@"c:\迅雷下载\3.0.6.apk");var fs_out = system.io.file.openwrite(@"c:\迅雷下载\3.0.6.apk.copy");byte[] buffer = new byte[1024];int readbytes = 0;while ((readbytes= fs_in.read(buffer, 0, buffer.length)) >0){ fs_out.write(buffer, 0, readbytes);}console.writeline("复制完成"); |
对于处理大型文件，一般都有进度指示，比如处理压缩了百分多少之类的，这里我们也可以加上，比如专门写一个方法用于文件读取并返回 byte[] 和百分比。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
static void readfile(string filename,int bufferlength, action<byte[],int> callback){ if (!system.io.file.exists(filename)) return; if (callback == null) return; system.io.fileinfo finfo = new system.io.fileinfo(filename); long filelength = finfo.length; long totalreadbytes = 0; var fs_in = system.io.file.openread(filename); byte[] buffer = new byte[bufferlength]; int readbytes = 0; while ((readbytes = fs_in.read(buffer, 0, buffer.length)) > 0) { byte[] data = new byte[readbytes]; array.copy(buffer, data, readbytes); totalreadbytes += readbytes; int percent = (int)((totalreadbytes / (double)filelength) * 100); callback(data, percent); }} |
调用就很简单了：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
static void main(string[] args){ string filename = @"c:\3.0.6.apk"; var fs_in = system.io.file.openread(filename); long ttc = 0; readfile(filename, 1024, (byte[] data, int percent) => { ttc += data.length; console.setcursorposition(0, 0); console.write(percent+"%"); }); console.writeline("len:"+ttc); console.readkey();} |
这是基于文件读取的，稍微改一下就可以改成输入流输出流的，这里就不贴出来了。文件读写非常耗时，特别是大文件，io 和 网络请求都是 “重操作”，所以建议大家 io 都放在单独的线程去执行。c# 中可以使用 task、thread、如果同时有多个线程需要执行就用 threadpool 或 task，java 或 android 中用 thread 或线程池，以及非常流行的 rxjava 等等 ...
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对服务器之家的支持。
原文链接：https://www.jianshu.com/p/33ed9e665620
