[转]c# Stream的问题

Star

转自：http://dev.csdn.net/author/Knigh ... 2e82863cbddb78.html
' a7 a7 z4 y, J; q5 G
IO操作基本上需要用到Stream相关的子类，因此这类问题在CSDN问得也是比较多。其实对于Stream来说，操作起来比较简单，只要对细节的处理稍微注意一下，相信在使用它的时候也会得心应手。

  d. [  b7 q9 f; e  X对于Stream相关的问题，大致分如下几类。
) H! H+ ]9 K  W, s9 S4 z
7 T& z* n5 X) e问题一，基本操作的问题；
# v6 B" g0 F, r9 D# k
' N  r0 C& `' ^9 I8 r! x; U( o问题二，编码的问题；

; c( _7 t. Z% {' Y问题三，尾部处理问题；
. ^  `8 N3 s  y- ]* j2 }+ w
问题四，Stream缓存问题；

问题五，资源释放问题；

最后一个问题，说说如何使用Stream来更新大文件部分数据。

对于问题一，基本操作的问题，主要是读写问题，主要是出现在文件数据比较大，需要循环写或者读的时候。此时正确读的形式如下。
) t2 Y9 B8 F0 X/ o1 i
" P/ o4 ^7 m: A! U( R+ V    // Open a file to read
( I$ X2 C9 u/ _3 A% W
    using( FileStream fs = new FileStream( yourFile,
% U' D8 z3 R% |1 V
                FileMode.Open, FileAccess.Read,

                FileShare.None ) )

    {
5 o: p5 n% @& I! x; X/ X0 G
        int nRealRead = 0;

        byte[] bBuffer = new byte[1024];

        do
4 j- h. K+ [9 M  v& ]5 b4 X; C
% ?* p; \9 G. Y* ?  T9 J        {

7 E3 W: ~4 E  d: W* u+ G; t            // Read data
6 `+ Q5 u7 ^8 K1 ]9 ^
            nRealRead = fs.Read( bBuffer, 0, 1024 );

            // Output data
- E; d) R: e) X+ r
5 t' @0 ]2 @- {            Debug.WriteLine( Encoding.Default.GetString( bBuffer, 0, nRealRead ) );

7 `, k# }# w( |- k# w        }while( nRealRead == 1024 );

    }
" [( R/ O" T3 p! C
* M+ N6 r# b% t" K可是大多数人第一次完成这样操作的时候，都会在“nRealRead = fs.Read( bBuffer, 0, 1024 );”这一句犯错误。认为第二个参数的偏移量对于Stream而设的，所以认为应该用累加的值，也就是目前总共读了多少的字节数。这里需要理解一下Stream的操作，当进行读或者写操作的时候，Stream的游标会根据所读或者所写得字节而自动向前跟进；其次Stream.Read或者Stream.Write这两个方法中第二个参数是针对第一个Buffer参数而言的，而不是对于Stream的，因此不要在这个地方犯错误。

- H# ?( V- ^  k# |3 a6 k基本问题还牵扯的就是文件打开的方式。有人经常问，如何同时用两个Stream打开同一个文件。其实默认的Stream打开方式是独享的，因此当不指明文件为访问共享的时候，后打开文件操作就会出现异常，因此需要向我上面所写的那样。还有，如果需要指定当前Stream的起始位置，可以通过Seek方法或者设置Position属性来完成。
8 y+ T8 }4 w6 R' W% [$ z9 p+ n
( P2 y( K- ?" c# @2 D( i1 M对于问题二，编码问题。有人使用Stream的子类，例如StreamReader之类来打开一个文本文件，发现读出来的数据是乱码，造成这个原因大多数由于文件中含有中文字符，同时打开文件的时候没有指明编码方式。由于英文和中文的编码方式不同，因此在不指明编码的时候有时会造成读取中文错误。此时只要使用StreamReader类型中含有Encoding参数的构造函数即可，例如：
1 ?) P$ K' C3 K" b8 W6 Y
$ Z8 K5 a: E& \/ S# V  s; busing( StreamReader sr = new StreamReader( yourFile, Encoding.Default ) )
1 X7 l" D. U# [1 I( E
. w) ?+ h! L9 k. V% C这里只是采用系统默认的编码方式，但有可能不太适合你文件的编码方式，因此需要在实际应用去调试和变换这个参数。

4 w0 o/ ~' h% N2 A- W  M6 S# r1 R9 e问题三是，Stream尾部处理问题。此类问题所展现的现象如，复制文件的时候文件会增大。因此在使用Stream.Read和Stream.Write的时候，要通过方法的返回值，来标明真正读和写的字节数，就像前面所写的那样。
2 _7 H$ z; p  t# v) t" [) K( W
    // Read data

    nRealRead = fs.Read( bBuffer, 0, 1024 );
/ A7 o7 U( ^, X: m9 ?+ l0 D) Z
    // Output data

    Debug.WriteLine( Encoding.Default.GetString( bBuffer, 0, nRealRead ) );

此时在输出的时候用的不是“1024”，而是“nRealRead”做为字节有效标示。
0 [) w/ Q1 B* T. v# M
/ ^/ S/ n- i' `对于问题四，Stream缓存的问题，这主要表现在写的时候。为了避免频繁操作IO而降低效率，大多数Stream采用异步写的方式，也就是Stream对象要配备有一定的缓存，来暂时保存写的数据。但缓存是有限的，当缓存已满后会造成后续写的数据不能写入，从而导致数据丢失。那么此时需要显示的调用Stream.Flush方法，来把缓存的数据写入到文件中并清空缓存。其实这并不是唯一方法，在一些Stream的子类中还提供了设置BufferSize的方法，或者提供了设置AutoFlush属性来实现自动写入等等，因此这里大家可以根据不同需要而选择不同方法来完成。
" n* |" H% d2 F" {9 m% B, R9 Q
对于Stream的释放问题，这可能不单单是使用Stream的问题，可能是使用C#编程而造成的不良习惯。虽说C#的资源是受托管的，但是对于Stream来说，如果不及时释放，那么当其他线程或者进程使用此文件的时候就会造成无法打开的现象（由于Stream大多数都是以独享方式打开），而且没有及时关闭，所占用的Buffer无法及时释放。对于资源释放问题，我为此专门写过一篇文章，如果有兴趣的话不妨看看。
8 d8 Y3 a+ u/ b5 {& ^, L
' a0 G) j3 n- v/ Whttp://blog.csdn.net/Knight94/archive/2006/08/05/1023352.aspx

& S, U8 h0 ]# V# x! Z因此养成一个好的习惯至关重要。其实释放Stream很简单，要么显示的调用其的Close和Dispose这两个方法，要么使用using程序块，就像我前面所写的那样。
3 u5 w# ~4 y" x% t& h
最后一个就是如何使用Stream来更新大文件。比较常见的就是，当文件比较大，但是需要修改的部分很少，因此想要通过Stream直接在某个位置进行类似于删除、插入或者替换等操作。
0 p: ]/ D" a8 @/ |. |2 a
对于一个文件的更新操作，大致分为三种，这里主要是考虑更新的位置和更新数据长度。
8 e7 Z4 Y5 ?" P$ w( p
4 \% _! R: Q% Z$ T8 R1 H. l3 D& |第一种对于文件尾扩展的操作，内容长度不限；
0 x# O* F, w0 c3 k: [
第二种等字节的替换操作，位置不限；

最后一种就是位置不固定，字节数不确定。

上面所说的前两种，进行处理比较简单。对于第一种，只要设置FileMode的时候增加Append标示即可。而对于等字节的替换，就更简单了，直接通过Stream.Seek找到指定的位置，然后调用Stream.Write即可。

$ n7 W( [% g% K& _( M而最后一个，是最麻烦的。比较简单的解决方式，创建一个临时文件，然后一边读一边写，遇到需要修改的，先读出来再修改最后再写入。等全部写完了，删除旧文件，修改临时文件的名称为原来名字。
6 x( v' ]/ t; i) O3 H
比较麻烦的解决方式，就是通过Share方式，用一个读Stream和一个写Stream直接操纵源文件。这里需要注意的是，为了保证新写的数据不要冲掉还没读出来的数据，也就是说要控制写Stream所写的位置不要超过要读的位置。举例说，目前需要读的位置是文件的800字节处，也就是说800字节以后还没读出来处理，此时写Stream在写完数据后，Stream的位置不能超过800字节，如果写采用的是缓存，那么超过800位置的数据不要立刻通过Flush进行提交。总的来说，通过两个Stream来操作同一个文件，对于这一点要特别注意，处理不好要造成死循环。

Stream的问题相对比较简单，大多数人操作的时候不注意细节。所以我这里只是稍加说明，不做特别细的说明。

Star

EB_EXP中Stream读写（大）文件的应用

/ ?1 h% ~3 p! P2 [读文件

1.       
   
2.                 WebRequest webReq = WebRequest.Create(updateFileUrl);
   
3.                 WebResponse webRes = webReq.GetResponse();
   8 u4 l$ U* V( Y4 v: B( ~# v8 B0 p
4.                 fileLength = webRes.ContentLength;
   
5. 
   $ m. N; W$ G% _
6.                 lbState.Text = "正在下载更新文件,请稍后...";
   
7.                 pbDownFile.Value = 0;
   
8.                 pbDownFile.Maximum = (int)fileLength;
   
9. 
   9 u1 ^! u! J3 M* z/ @3 R, Z  h
10.                 Stream srm = webRes.GetResponseStream();
    , U& k8 ^5 p- D9 O' A+ c6 m/ S
11.                 StreamReader srmReader = new StreamReader(srm);
    5 e; ^( A& t1 \, ^7 m
12.                 byte[] bufferbyte = new byte[fileLength];
    
13.                 int allByte = (int)bufferbyte.Length;
    # P  t1 [# Q0 X9 `' i
14.                 int startByte = 0;
    
15.                 while (allByte > 0)
    
16.                 {
    
17.                     Application.DoEvents();//让系统在百忙之中来响应其他事件
    1 w2 R0 \2 H( ~- g3 i
18.                     int downByte = srm.Read(bufferbyte, startByte, allByte);//此方式不能传输大文件
    0 k# f( L1 a0 X- b0 ~
19.                     if (downByte == 0) { break; };
    3 F# w+ b* x, k/ ^
20.                     startByte += downByte;
    
21.                     allByte -= downByte;
    $ u5 Y" X/ c' a) Y7 E( F
22.                         
    
23.                 }

复制代码

写文件

1.          
   + E3 `. I$ C4 F0 R& T
2.                     string tempPath = tempUpdatePath + UpdateFile;
   
3.                     CreateDirtory(tempPath);
   ; l+ P4 L$ e  M6 |: T8 H( P) Y1 L
4.                     FileStream fs = new FileStream(tempPath, FileMode.OpenOrCreate, FileAccess.Write);
   ' M! E! x) T8 k0 W1 ?0 |
5.                     fs.Write(bufferbyte, 0, bufferbyte.Length);
   ' G; t* `+ r( h6 H
6.                     srm.Close();
   # X& m/ m" h: M4 f
7.                     srmReader.Close();
   9 u. E: H4 S( v0 ~4 ^( b
8.                     fs.Close();

复制代码