好得很程序员自学网

<tfoot draggable='sEl'></tfoot>

C#文件流读写和进度回调示例详解

前言

前不久遇到一个问题,是公司早期的基础库遇到的,其实很低级,但是还是记录下来。出错点是一个 io 流的写入bug,我们项目会有一种专有的数据格式,这个格式的奇葩点在于如果设置 io 读缓冲区为 2014 字节的时候,整个文件刚好能读完,也就是说其 length 刚好是 1024 的倍数。后来在一次升级中增加了更多的文件格式,并且新的文件格式使用了新的自定义写入流,具有加密和压缩的作用,这样一来,文件的长度就不一定是 1024 的倍数了。

后来通过查看这个基础类的源代码发现因为是 .net 2.0 时代的东西,也没有 stream.copy 的方法,于是当时的程序员手动写了个 stream.copy 的方法,我稍作改动为了更直观将输出流改为输出到文件,代码大概如下:

?

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 字节的数据,导致整个文件都不对了,明显是基础知识都没学好。

增加一个变量保存实际读取到的字节数,改为如下:

?

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[] 和百分比。

?

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);

  }

}

调用就很简单了:

?

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://HdhCmsTestjianshu测试数据/p/33ed9e665620

dy("nrwz");

查看更多关于C#文件流读写和进度回调示例详解的详细内容...

  阅读:50次