《套接字与数据流》PPT课件.ppt

第4章 套接字与数据流,4.1 套接字 4.1.1 面向连接的套接字 4.1.2 无连接的套接字 4.2 数据流 4.2.1 文件流 4.2.2 内存流 4.2.3 网络流 4.2.4 StreamWriter与StreamReader类 4.2.5 BinaryReader与BinaryWriter类,本章教学目的 学习套接字编程的基本方法，以及数据流相关类的用法。 本章教学要求 （1）掌握套接字的概念及Socket类用法； （2）掌握面向连接套接字编程、无连接套接字编程基本步骤 （3）掌握FileStream、MemoryStream、NetworkStream类的用法； （4）掌握StreamReader、StreamWriter、BinaryReader、 BinaryWriter类的基本用法。,本章重点,4.1 套接字,一个连接由它的两个端点标识，这样的端点称为套接字。,4.1 套接字（续),套接字是支持TCP/IP协议的网络通信的基本操作单元。可以将套接字看作不同主机间的进程进行双向通信的端点。 上图连接1的一对套接字为： （3，5000）和（22，8888） 上图连接2的一对套接字为： （3，5001）和（22，8888） 对于UDP协议尽管两个进程之间没有建立连接，但是也同样存在发送端点，和接收端点，也同样使用套接字的概念。,4.1 套接字（续),套接字的类型有： 流式套接字：提供了面向连接的、可靠的、数据无错并且无重复的数据发送服务，而且接收数据的顺序和发送数据的顺序是相同的。 数据报套接字：提供了面向无连接的服务,它以独立的数据包形式发送数据(数据包长度不能大于32KB)，不提供正确性检查，也不保证各数据包的发送顺序和接收顺序相同 ，因此，可能出现数据的重发、丢失等现象。 原始套接字：用于直接访问协议的较低层。常用于检验新的协议实现或访问现有服务中配置的新设备，一般不提倡直接使用原始套接字。,4.1 套接字（续),Socket类包含在System.Net.Sockets命名空间中。 一个Socket实例包含了一个本地或者一个远程端点的套接字信息。 使用Socket类编程，由于很多细节都需要自己考虑，相对来说复杂一些，易出错。一般对套接字编程比较熟悉的人，或者使用非标准协议（自定义的新协议）进行编程的时候，才使用Socket类。 Socket类的构造函数为： public Socket( AddressFamily addressFamily, /网络类型 SocketType socketType, /套接字类型 ProtocolType protocolType); /使用的协议,4.1 套接字（续),参数含义： （1）addressFamily addressFamily表示网络类型，该参数使用AddressFamily枚举指定Socket使用的寻址方案 例如AddressFamily.InterNetwork表示IP版本4的地址。,4.1 套接字（续),4.1 套接字（续),（2）socketType socketTyp指定Socket的类型，该参数使用SocketType枚举指定使用哪种套接字。例如: SocketType.Stream表明连接是基于流套接字的 SocketType.Dgram表示连接是基于数据报套接字 SocketType.Raw表示连接基于原始套接字； 详细见课本表4-2,4.1 套接字（续),（3）protocolType protocolType指定Socket使用的协议，该参数使用ProtocolType枚举指定使用哪种协议。例如: ProtocolType.Tcp表明连接协议是TCP ProtocolType.Udp表明连接协议是UDP 详细见课本表4-3,4.1 套接字（续),Socket构造函数的三个参数中，对于网络上的IP通信来说，AddressFamily总是使用AddressFamily.InterNetwork枚举值。而SocketType参数则与ProtocolType参数配合使用，不允许其他的匹配形式，也不允许混淆匹配。下表列出了可用于IP通信的组合。,4.1.1 面向连接的套接字,IP连接领域有两种通信类型： 面向连接的（connection-oriented） 无连接的（connectionless）。 根据连接启动的方式以及本地套接字要连接的目标，套接字之间的连接过程可以分为三个步骤： 服务器监听 客户端请求 连接确认,4.1.1 面向连接的套接字,服务器监听：是指服务器套接字并不定位具体的客户端套接字，而是处于等待连接的状态，实时监控网络状态。 客户端请求：是指由客户端的套接字提出连接请求，要连接的目标是服务器的套接字。为此，客户端的套接字必须首先描述它要连接的服务器的套接字，指出服务器套接字的地址和端口号，然后再向服务器套接字提出连接请求。 连接确认：是指当服务器套接字监听到客户端套接字的连接请求时，它就响应客户端套接字的请求，把服务器套接字的信息发给客户端，一旦客户端确认了此信息，连接即可建立。而服务器套接字继续监听其他客户端套接字的连接请求。,4.1.1 面向连接的套接字,4.1.1 面向连接的套接字,同步TCP编写服务器端程序的一般步骤为： 1) 创建一个包含采用的网络类型、数据传输类型和协议类型的本地套接字对象，并将其与服务器的IP地址和端口号绑定。这个过程可以通过Socket类。 2) 在指定的端口进行监听，以便接受客户端连接请求。 3) 一旦接受了客户端的连接请求，就根据客户端发送的连接信息创建与该客户端对应的Socket对象。 4) 根据创建的Socket对象，分别与每个连接的客户进行数据传输。 5) 根据传送信息情况确定是否关闭与对方的连接。,4.1.1 面向连接的套接字,使用同步TCP编写客户端程序的一般步骤为： 1) 创建一个包含传输过程中采用的网络类型、数据传输类型和协议类型的Socket对象。 2) 与远程服务器建立连接。 3) 与服务器进行数据传输。 4) 完成工作后，向服务器发送关闭信息，并关闭与服务器的连接。,4.1.1 面向连接的套接字（续）,1.建立连接（服务器） IPEndPoint iep = new IPEndPoint(local.AddressList0, 1180); Socket localSocket = new Socket( AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); localSocket.Bind(iep); locatSocket.Listen(10); Socket clientSocket = localSocket.Accept();,4.1.1 面向连接的套接字（续）,1.建立连接（客户端） IPAddress remoteHost = IPAddress.Parse(““); PEndPoint iep = new IPEndPoint(remoteHost, 1180); Socket localSocket = new Socket( AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); localSocket.Connect(iep);,4.1.1 面向连接的套接字（续）,2. 发送、接收信息（服务器） Socket clientSocket = localSocket.Accept(); /建立连接后，利用Send方法向客户端发送信息 clientSocket.Send(Encoding.ASCII.GetBytes(“server send Hello“); /接收客户端信息 byte myresult = new Byte1024; int receiveNum = clientSocket.Receive(myresult); Console.WriteLine(“接收客户端消息：0“, Encoding.ASCII.GetString(myresult);,4.1.1 面向连接的套接字（续）,2. 发送、接收信息（客户端） /建立连接成功后，向服务器发送信息 string sendMessage = “client send Message Hello“+DateTime.Now; localSocket.Send(Encoding.ASCII.GetBytes(sendMessage); Console.WriteLine(“向服务器发送消息:0“, sendMessage); /接收服务器信息 byte result = new Byte1024; localSocket.Receive(result); Console.WriteLine(“接收服务器消息：0“, Encoding.ASCII.GetString(result);,4.1.1 面向连接的套接字（续）,3.关闭连接 通信完成后，必须先用Shutdown方法停止会话，然后关闭Socket实例 。 例如： sock.Shutdown(SocketShutdown.Both); sock.Close();,4.1.2 无连接的套接字,UDP使用无连接的套接字，无连接的套接字不需要在网络设备之间发送连接信息。 注意: 必须使用Bind方法将套接字绑定到一个本地地址和端口之后才能使用ReceiveFrom方法接收数据，如果只发送而不接收，则不需要使用Bind方法。,4.1.2 无连接的套接字,第4章 套接字与数据流,4.1 套接字 4.1.1 面向连接的套接字 4.1.2 无连接的套接字 4.2 数据流 4.2.1 文件流 4.2.2 内存流 4.2.3 网络流 4.2.4 StreamWriter与StreamReader类 4.2.5 BinaryReader与BinaryWrite类,4.2 数据流,流（stream）是对串行传输的数据（以字节为单位）的一种抽象表示，底层的设备可以是文件、外部设备、主存、网络套接字等。,4.2 数据流,流提供三种基本操作： 写入：将数据从内存缓冲区传输到外部源。 读取：将数据从外部源传输到内存缓冲区。 查找：重新设置流的当前位置，以便随机读写。需要注意的是，并不是所有的流类型都能够支持查找，例如，网络流没有当前位置的统一概念，因此一般不支持查找。 说明：Stream类提供有多种操作流的方法，其中Read和Write方法是Stream类及其派生类都提供的实现，可支持在字节级别上对数据进行读写。实际的程序开发中，仅支持字节级别的数据处理会给开发人员带来不便。,4.2 数据流,提供字符串或二进制方式读取或写入流。 优点： 方法更灵活 部分方法可解决TCP消息通信无边界问题,4.2.1 FileStream类,FileStream类继承于Stream类，一个FileStream类的实例实际上代表一个磁盘文件，使用FileStream类可以对文件系统上的文件进行读取、写入、打开和关闭操作。 1、创建FileStream实例 (1)常用的构造函数具有三个参数，例如： FileStream(string path, FileMode mode, FileAccess access),4.2.1 FileStream类,FileMode值用于指定当文件不存在时是否创建该文件，并确定是保留还是改写现有文件的内容,4.2.1 FileStream类,FileAccess值是枚举的一个成员，它控制对文件的访问权限。表4-10列出了FileAccess所有的枚举形式 (2)File和FileInfo类也提供了创建FileStream对象的方法。其中，OpenRead方法返回只读文件流，OpenWrite方法返回只写文件流。 例如：FileStream fs= File.OpenRead(“C:File1.txt“);,4.2.1 FileStream类,2. 读文件 在获取FileStream实例之后，可利用FileStream对象的Read方法读取文件中的数据。该方法用于从流中读取字节块并将该数据写入给定字节数组中。其语法形式为： public override int Read(byte array,int offset, int count) array : 存储从文件流中读取的数据。 offset : array字节数组中开始写入数据的下标，一般为0。 size : 要从文件流中读出字节的大小 返回值: 从FileStream中读取的字节数。 【例3-2】利用FileStream的Read方法从一个文本文件中读取内容并显示在屏幕上。,4.2.1 FileStream类,3. 写文件 Stream类及其所有子类都提供了Write方法，FileStream类也不例外。该方法可将字节数组写入流。语法形式为 public override void Write ( byte buffer, /包含要写入流的数据 int offset, / buffer中开始写入数据的位置 int size /要写入流的字节数 ) 【例3-3】利用FileStream的Write方法向文本文件中追加数据。,4.2.2 MemoryStream类,MemoryStream类表示的是保存在内存中的数据流。由内存流封装的数据可以在内存中直接访问。 MemoryStream类的构造函数具有多种重载形式，常用的构造函数有： （1）MemoryStream () 该构造函数初始分配的容量大小为0，随着数据的不断写入容量可以不断扩展。 （2）MemoryStream (Byte) 该构造函数获取的MemoryStream实例根据Byte字节数组进行初始化，并且实例容量大小固定即为字节数组的长度。由于实例的容量不能扩展，该构造函数一般用于数据不发生变化的场合。,4.2.2 MemoryStream类,String testdata = “测试数据“; char chars = testdata.ToCharArray(); Byte bytes = new Byteencoder.GetByteCount(chars, 0, chars.Length, true); MemoryStream mem = new MemoryStream(bytes); （3）MemoryStream (int capacity) 通过该构造函数创建初始容量大小为capacity的实例，并且实例容量大小可扩展。 【例3-4】利用MemoryStream暂存数据。,4.2.3 网络流,在System.Net.Sockets名称空间中有一个NetworkStream类，用于通过网络套接字发送和接收数据。 NetworkStream类支持对网络数据的同步或异步访问，它可被视为在数据来源端和接收端之间架设了一个数据通道. 只用于面向连接的数据传输,写入操作是指从来源端内存缓冲区到网络上的数据传输； 读取操作是从网络上到接收端内存缓冲区（如字节数组）的数据传输。,4.2.3 网络流（续）,4.2.3 网络流（续）,NetworkStream的用法 1、构造NetworkStream： （1）利用TcpClient获取网络流对象，例如： TcpClient tcpClient=new TcpClient(); tcpClient.Connect(““, 51888); NetworkStream networkStream = client.GetStream(); （2）利用Socket获取网络流对象，例如： NetworkStream myNetworkStream = new NetworkStream(mySocket);,4.2.3 网络流（续）,2、发送数据 public override void Write (byte buffer,int offset,int size ),4.2.3 网络流（续）,3、接收数据 public override int Read ( InAttribute OutAttribute byte buffer, int offset, int size) 各参数的含义: buffer :内存中用于存储从NetworkStream读取的数据的位置。 offset:buffer 中开始将数据存储到的位置。 Size:要从NetworkStream中读取的字节数。 返回值 : 实际从NetworkStream中读取的字节数。,4.2.3 网络流（续）,Write方法： NetworkStream对象的Write方法的返回值为void，该对象之所以不返回实际发送的字节数，是因为能保证字节数组中的数据全部发送到TCP发送缓冲区中。 在使用NetworkStream对象的Write方法前最好先检测NetworkStream对象的Writeable属性是否为True。 如果发送的全部是单行文本信息，创建NetworkStream对象后，使用StreamReader和StreamWriter的ReadLine和WriteLine方法更简单。 Read方法： 调用NetworkStream类的Read方法前应确保NetworkStream对象的CanRead属性值有效 由于有可能TCP接收缓冲区还没有接收到对方发送过来的指定长度的数据，所以Read方法有一个整型的返回值。 如果远程主机关闭了套接字连接，并且此时有效数据已经被完全接收，那么Read方法的返回值将会是0字节。,4.2.3 网络流（续）,使用NetworkStream对象时，需要注意： （1）通过DataAvailable属性，可以迅速查看在缓冲区中是否有数据等待读出。 （2）网络流没有当前位置的概念，因此它不支持对数据流的查找和随机访问，NetworkStream对象的CanSeek属性始终返回false，读取Position属性和调用Seek方法时，都会引发NotSupportedException异常。 （3）网络数据传输完成后，不要忘记用Close方法关闭NetworkStream对象。,4.2.4 StreamWriter与StreamReader类,可以看到所有的NetworkStream、MemoryStream、FileStream类都提供了以字节为基本单位的读写方法，但是这种方法需要首先将待写入的数据转化为字节数组后才能够进行读写，当操作的是使用字符编码的文本数据时，给开发人员带来了不便。 StreamReader类主要完成以一种特定的编码从流中读取字符的功能，一般用于对文本数据的读取操作； StreamWriter类则主要以特定的编码向流中写入字符，一般用于对文本数据的写操作。,4.2.4 StreamWriter与StreamReader类,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“);,4.2.4 StreamWriter与StreamReader类,1、创建StreamWriter实例（续） （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);,4.2.4 StreamWriter与StreamReader类,2、写入文本 利用StreamWriter类将以一种特定的编码向流中写入字符。常见方法如下所示： Write()：向数据流写入数据。Write()方法只是把传送给它的字符串写入流，但不追加换行符，因此可以使用Write()语句写入完整的句子或段落。 WriteLine()：向数据流写入指定数据和一个换行符。 Close()：关闭流。 【例3-5】利用StreamWriter类向C盘中的文本文件file1.txt中写入一行数据。,4.2.4 StreamWrit