Stream篇（1）

最近在看一个写的很好的博客，为了加深记忆，把自认为重要的东西，一边看，一边记在这里

博客地址：http://www.cnblogs.com/JimmyZheng/archive/2012/03/17/2402814.html

一、什么是流、字节序列、字节

一条河中有一条鱼游过，这条鱼就是一个字节，这个字节包括眼睛、嘴巴等8组成8个二进制的位，而这条河就是流。

字节按照一定的顺序进行排序组成了字节序列。

二、Stream

它有一个protected类型的构造函数，但是它是个抽象类无法直接像如下这样使用：

Stream stream=new Stream();

重要的属性：

1、CanRead：只读，判断该流是否能够读取

2、CanSeek：只读，判断该流是否支持跟踪查找

3、CanWrite：只读，判断该流是否可写

4、Length:流的长度

5、Position：非常重要，在文件或图片上传中，可能会遇到这样的事：Stream对象被缓存了，导致了Position属性在流中无法找到正确的位置。一种方法是每次使用流前将该属性设置为0.但如果想从根本解决这个问题，最好的方法是用Using语句将流对象包裹起来，用完后关闭回收即可。

重要方法：

1、void Flush()：

使用流写文件时，数据会先进入到缓冲区中，而不会立刻写入文件。当执行这个方法后，缓冲区的数据流会立刻注入基础流。

2、abstract int Read(byte[] buffer, int offset,int count)

缓冲字节数组，位偏移量，读取的字节个数

返回一个缓冲区中的总字节数，int类型。

3、abstract long Seek(long offset,SeekOrigin origin)

定位流中的一个位置

SeekOrigin.Begin/Current/End

offset可为负0正

4、abstract int Write(byte[] buffer, int offset,int count)

5、virtual void Close()

如果不用using，那记得使用这个方法

三、例子

非原创，呵呵

static void Main(string[] args)
        {
            byte[] buffer = null;

            string testString = "Stream!Hello world";
            char[] readCharArray = null;
            byte[] readBuffer = null;
            string readString = string.Empty;
            //关于MemoryStream 我会在后续章节详细阐述
            using (MemoryStream stream = new MemoryStream()) 
            {
                Console.WriteLine("初始字符串为：{0}", testString);
                //如果该流可写
                if (stream.CanWrite)
                {
                    //首先我们尝试将testString写入流中
                    //关于Encoding我会在另一篇文章中详细说明，暂且通过它实现string->byte[]的转换
                    buffer = Encoding.Default.GetBytes(testString);
                    //我们从该数组的第一个位置开始写，长度为3，写完之后 stream中便有了数据
                    //对于新手来说很难理解的就是数据是什么时候写入到流中，在冗长的项目代码面前，我碰见过很
                    //多新手都会有这种经历，我希望能够用如此简单的代码让新手或者老手们在温故下基础
                    stream.Write(buffer, 0,3);

                    Console.WriteLine("现在Stream.Postion在第{0}位置",stream.Position+1);

                    //从刚才结束的位置（当前位置）往后移3位，到第7位
                    long newPositionInStream =stream.CanSeek? stream.Seek(3, SeekOrigin.Current):0;

                    Console.WriteLine("重新定位后Stream.Postion在第{0}位置", newPositionInStream+1);
                    if (newPositionInStream < buffer.Length)
                    {
                        //将从新位置（第7位）一直写到buffer的末尾，注意下stream已经写入了3个数据“Str”
                        stream.Write(buffer, (int)newPositionInStream, buffer.Length - (int)newPositionInStream);
                    }

                    
                    //写完后将stream的Position属性设置成0，开始读流中的数据
                    stream.Position = 0;

                    // 设置一个空的盒子来接收流中的数据，长度根据stream的长度来决定
                    readBuffer = new byte[stream.Length];


                    //设置stream总的读取数量 ，
                    //注意！这时候流已经把数据读到了readBuffer中
                    int count = stream.CanRead?stream.Read(readBuffer, 0, readBuffer.Length):0;
         

                    //由于刚开始时我们使用加密Encoding的方式,所以我们必须解密将readBuffer转化成Char数组，这样才能重新拼接成string

                    //首先通过流读出的readBuffer的数据求出从相应Char的数量
                    int charCount = Encoding.Default.GetCharCount(readBuffer, 0, count);
                    //通过该Char的数量 设定一个新的readCharArray数组
                    readCharArray = new char[charCount];
                    //Encoding 类的强悍之处就是不仅包含加密的方法，甚至将解密者都能创建出来（GetDecoder()），
                    //解密者便会将readCharArray填充（通过GetChars方法，把readBuffer 逐个转化将byte转化成char，并且按一致顺序填充到readCharArray中）
                    Encoding.Default.GetDecoder().GetChars(readBuffer, 0, count, readCharArray, 0);
                    for (int i = 0; i < readCharArray.Length; i++)
                    {
                        readString += readCharArray[i];
                    }
                    Console.WriteLine("读取的字符串为：{0}", readString);
                }

                stream.Close();
            }

            Console.ReadLine();

        }

四、实现异步

几个关键方法：

异步读取
public virtual IAsyncResult BeginRead(byte[] buffer,int offset,int count,AsyncCallback callback,Object state)
异步写
public virtual IAsyncResult BeginWrite( byte[] buffer, int offset, int count, AsyncCallback callback, Object state )
结束异步读取
public virtual int EndRead( IAsyncResult asyncResult ) 
结束异步写
public virtual void EndWrite( IAsyncResult asyncResult )

在复杂的情况下，避免类似于阻塞问题的出现。
感谢该博主的辛勤劳动，受益匪浅了。