010-数据流

流（stream）是对串行传输的数据（以字节为单位）的一种抽象表示，底层的设备可以是文件、外部设备、主存、网络套接字等。

image.png

流提供三种基本操作：

• 写入：将数据从内存缓冲区传输到外部源。
• 读取：将数据从外部源传输到内存缓冲区。
• 查找：重新设置流的当前位置，以便随机读写。需要注意的是，并不是所有的流类型都能够支持查找，例如，网络流没有当前位置的统一概念，因此一般不支持查找。

说明：Stream类提供有多种操作流的方法，其中Read和Write方法是Stream类及其派生类都提供的实现，可支持在字节级别上对数据进行读写。实际的程序开发中，仅支持字节级别的数据处理会给开发人员带来不便。

提供字符串或二进制方式读取或写入流。
优点：
方法更灵活
部分方法可解决TCP消息通信无边界问题

image.png

FileStream类

FileStream类继承于Stream类，一个FileStream类的实例实际上代表一个磁盘文件，使用FileStream类可以对文件系统上的文件进行读取、写入、打开和关闭操作。

1、创建FileStream实例

(1)常用的构造函数具有三个参数，例如：

FileStream(string path,FileMode mode   FileAccess access)

• FileMode值用于指定当文件不存在时是否创建该文件，并确定是保留还是改写现有文件的内容

  
  image.png

• FileAccess值是枚举的一个成员，它控制对文件的访问权限。表4-10列出了FileAccess所有的枚举形式

  
  image.png

(2)File和FileInfo类也提供了创建FileStream对象的方法。

其中，OpenRead方法返回只读文件流，OpenWrite方法返回只写文件流。
例如：FileStream fs= File.OpenRead("C:\File1.txt");

2. 读文件

在获取FileStream实例之后，可利用FileStream对象的Read方法读取文件中的数据。该方法用于从流中读取字节块并将该数据写入给定字节数组中。其语法形式为：

  public override int Read(byte[] array,int offset,int count)

array : 存储从文件流中读取的数据。
offset : array字节数组中开始写入数据的下标，一般为0。
size : 要从文件流中读出字节的大小
返回值: 从FileStream中读取的字节数。

3. 写文件

Stream类及其所有子类都提供了Write方法，FileStream类也不例外。该方法可将字节数组写入流。语法形式为

    public override void Write (
    byte[] buffer,    //包含要写入流的数据
    int offset,       // buffer中开始写入数据的位置
    int size         //要写入流的字节数
    )

MemoryStream类

MemoryStream类表示的是保存在内存中的数据流。由内存流封装的数据可以在内存中直接访问。
MemoryStream类的构造函数具有多种重载形式，常用的构造函数有：
（1）MemoryStream ()
该构造函数初始分配的容量大小为0，随着数据的不断写入容量可以不断扩展。
（2）MemoryStream (Byte[])
该构造函数获取的MemoryStream实例根据Byte[]字节数组进行初始化，并且实例容量大小固定即为字节数组的长度。由于实例的容量不能扩展，该构造函数一般用于数据不发生变化的场合。

  String testdata = "测试数据";
  char[] chars = testdata.ToCharArray();
  Byte[] bytes = new Byte[encoder.GetByteCount(chars, 0, chars.Length, true)];
  MemoryStream mem = new MemoryStream(bytes);

（3）MemoryStream (int capacity)
通过该构造函数创建初始容量大小为capacity的实例，并且实例容量大小可扩展。

网络流

在System.Net.Sockets名称空间中有一个NetworkStream类，用于通过网络套接字发送和接收数据。
NetworkStream类支持对网络数据的同步或异步访问，它可被视为在数据来源端和接收端之间架设了一个数据通道.
只用于面向连接的数据传输

image.png

写入操作是指从来源端内存缓冲区到网络上的数据传输；
读取操作是从网络上到接收端内存缓冲区（如字节数组）的数据传输。

image.png
NetworkStream的用法
1、构造NetworkStream：
（1）利用TcpClient获取网络流对象，例如：

    TcpClient tcpClient=new TcpClient();
    tcpClient.Connect("www.abcd.com", 51888);
    NetworkStream networkStream = client.GetStream();

（2）利用Socket获取网络流对象，例如：

    NetworkStream myNetworkStream = new NetworkStream(mySocket);

2、发送数据

 public override void Write (byte[] buffer,int offset,int size )

image.png

3、接收数据

public override int Read ([InAttribute] [OutAttribute] byte[] buffer,int offset,int size) 

各参数的含义:
buffer :内存中用于存储从NetworkStream读取的数据的位置。
offset:buffer 中开始将数据存储到的位置。
Size:要从NetworkStream中读取的字节数。
返回值 :
实际从NetworkStream中读取的字节数。

Write方法：

• NetworkStream对象的Write方法的返回值为void，该对象之所以不返回实际发送的字节数，是因为能保证字节数组中的数据全部发送到TCP发送缓冲区中。
• 在使用NetworkStream对象的Write方法前最好先检测NetworkStream对象的Writeable属性是否为True。
• 如果发送的全部是单行文本信息，创建NetworkStream对象后，使用StreamReader和StreamWriter的ReadLine和WriteLine方法更简单。

Read方法：

• 调用NetworkStream类的Read方法前应确保NetworkStream对象的CanRead属性值有效
• 由于有可能TCP接收缓冲区还没有接收到对方发送过来的指定长度的数据，所以Read方法有一个整型的返回值。
• 如果远程主机关闭了套接字连接，并且此时有效数据已经被完全接收，那么Read方法的返回值将会是0字节。

使用NetworkStream对象时，需要注意：
（1）通过DataAvailable属性，可以迅速查看在缓冲区中是否有数据等待读出。
（2）网络流没有当前位置的概念，因此它不支持对数据流的查找和随机访问，NetworkStream对象的CanSeek属性始终返回false，读取Position属性和调用Seek方法时，都会引发NotSupportedException异常。
（3）网络数据传输完成后，不要忘记用Close方法关闭NetworkStream对象。

StreamWriter与StreamReader类

可以看到所有的NetworkStream、MemoryStream、FileStream类都提供了以字节为基本单位的读写方法，但是这种方法需要首先将待写入的数据转化为字节数组后才能够进行读写，当操作的是使用字符编码的文本数据时，给开发人员带来了不便。
StreamReader类主要完成以一种特定的编码从流中读取字符的功能，一般用于对文本数据的读取操作；
StreamWriter类则主要以特定的编码向流中写入字符，一般用于对文本数据的写操作。

1、创建StreamWriter实例

（1）StreamWriter (String path)
根据文件路径创建以UTF-8编码StreamWriter对象。例如：
StreamWriter sw= new StreamWriter ("C:\file1.txt");
（2）File及FileInfo类提供的CreateText方法。例如：
StreamWriter sw = File.CreateText ("C:\file1.txt");
（3）StreamWriter (Stream stream)
直接使用流对象创建StreamWriter对象。例如：
FileStream fs = new FileStream(filePath, FileMode.Open, FileAccess.ReadWrite);
StreamWriter sw = new StreamWriter (fs);
如果已经有了网络流对象，同样可以直接对网络流对象进行封装。
NetworkStream networkStream = client.GetStream();
StreamWriter sw = new StreamWriter (networkStream);

2、写入文本

利用StreamWriter类将以一种特定的编码向流中写入字符。常见方法如下所示：
Write()：向数据流写入数据。Write()方法只是把传送给它的字符串写入流，但不追加换行符，因此可以使用Write()语句写入完整的句子或段落。
WriteLine()：向数据流写入指定数据和一个换行符。
Close()：关闭流。

3.创建StreamReader实例

（1）SteamReader (Stream stream)
利用流对象创建SteamReader对象。例如：
NetworkStream networkStream = client.GetStream();
SteamReader sr = new SteamReader (networkStream)
（2）SteamReader (String path)
如果需要处理的是文件流，则可以根据文件路径创建一个以UTF8编码的SteamReader对象。例如：
SteamReader sr = new SteamReader ("C:\file1.txt");

４．读取文本

利用StremReader将以一种特定的编码从流中读取字符。常用方法有：
ReadLine()：读取数据直到遇到换行符（Unix）或者回车换行（Windows）为止。
ReadToEnd()：读取到文件尾的全部数据。
Peek()：返回数据中下一个可用字符的编码值，如到达文件末尾则Peek()方法的值为-1。
Close()：关闭流，使用StreamReader之后，需要调用Close方法关闭流。

BinaryReader和BinaryWriter类

提供了BinaryReader和BinaryWriter类，用于以二进制模式读写流。
它们提供的一些读写方法是对称的，比如针对不同的数据结构，BinaryReader提供了ReadByte、ReadBoolean、ReadInt、ReadInt16、ReadDouble、ReadString等方法，与之对应BinaryWriter则提供了多个重载Write方法。例如当Write方法传递的参数为Int32类型时，BinaryWriter类的Write方法将Int32类型数据转化为长度为4的字节数组，并将字节流传递给一个Stream对象。