《TCP协议开发》PPT课件.ppt

第10章TCP协议开发,10.1相关概念10.2定义与获取主机信息10.3同步套接字编程10.4同步套接字开发举例简单聊天程序10.5使用TcpClient和TcpListener简化TCP编程10.6异步套接字编程10.7异步套接字开发举例,10.1基本概念,基本概念（相关概念）同步发送方将数据包发送到网络上以后，不等接收方响应，就接着发送下一个数据包。异步发送方将数据包发送到网络上以后，等接收方做出响应后，才接着发送下一个数据包。,-同步套接字在通过Socket进行连接、接收、发送操作时，客户机或服务器会暂停当前工作，处于等待状态，即一直等到有数据时才继续执行下面的语句。一般在阻塞方式下使用这种方式。可见，同步套接字适用于网络传输量不太大的情况。当网络传输量很大时，长时间的等待可能会让用户无法忍受。-异步套接字在通过Socket进行连接、接收、发送操作时，客户机或服务器不会暂停当前工作，而是利用callback机制进行连接、接收和发送处理。异步套接字适用于需要在网络上进行大量数据传输的应用程序，比如有几万客户同时传输的情况。,10.2定义与获取主机信息,定义主机对象IPEndPoint类IPAddress类获取主机信息Dns类中常用方法Dns.GetHostName()Dns.GetHostByName(stringhostname)Dns.GetHostByAddress(address)Dns.Resolve(),1.定义主机对象IPEndPoint类包含应用程序连接到主机上的服务所需的主机和端口信息。通过组合服务的主机IP地址和端口号，IPEndPoint类形成到服务的连接点。常用的方法原型：publicIPEndPoint(IPAddressaddress,intport);说明：address：IP地址port：端口号功能：初始化IPEndPoint类的实例。用法举例：IPAddressmyServerIP=newIPAddress.Parse(“”);IPEndPointmyServer=newIPEndPoint(myServerIP,13);,2.主机解析程序实例Dns.Resolve()的使用usingSystem;usingSystem.Net;publicclassTestFileStreamstaticvoidMain()Console.Write(输入主机名或者IP地址：);stringstr=Console.ReadLine();IPHostEntryhost=Dns.Resolve(str);for(inti=0;i0)intrecv=netStream.Read(message,start,dataleft);start+=recv;dataleft-=recv;his.richTextBoxAccept.Rtf=System.Text.Encoding.Unicode.GetString(message);catchthis.listBoxState.Items.Add(与客户断开连接);break;,“停止监听”的Click事件代码。privatevoidbuttonStop_Click(objectsender,System.EventArgse)this.buttonStart.Enabled=true;trysocket.Shutdown(SocketShutdown.Both);socket.Close();if(clientSocket.Connected)clientSocket.Close();thread.Abort();catchMessageBox.Show(监听尚未开始，关闭无效!);,添加“发送信息”的Click事件代码。privatevoidbuttonSend_Click(objectsender,System.EventArgse)stringstr=this.richTextBoxSend.Rtf;inti=str.Length;if(i=0)return;else/因为str为Unicode编码，每个字符占2字节，所以实际字节数应*2i*=2;bytedatasize=newbyte4;datasize=System.BitConverter.GetBytes(i);bytesendbytes=System.Text.Encoding.Unicode.GetBytes(str);tryNetworkStreamnetStream=newNetworkStream(clientSocket);netStream.Write(datasize,0,4);netStream.Write(sendbytes,0,sendbytes.Length);netStream.Flush();this.richTextBoxSend.Rtf=;catchMessageBox.Show(无法发送!);,窗口关闭前触发的事件代码。privatevoidForm1_Closing(objectsender,System.ComponentModel.CancelEventArgse)trysocket.Shutdown(SocketShutdown.Both);socket.Close();if(clientSocket.Connected)clientSocket.Close();thread.Abort();catch,客户端编程创建windows应用程序项目TestSyncClient，设计画面如图所示：控件属性参见表10-2,“请求连接”的Click事件代码。privatevoidbuttonRequest_Click(objectsender,System.EventArgse)IPAddressip=IPAddress.Parse(this.textBoxIP.Text);IPEndPointserver=newIPEndPoint(ip,Int32.Parse(this.textBoxPort.Text);socket=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);trysocket.Connect(server);catchMessageBox.Show(与服务器连接失败！);return;this.buttonRequest.Enabled=false;this.listBoxState.Items.Add(与服务器连接成功);Threadthread=newThread(newThreadStart(AcceptMessage);thread.Start();,privatevoidAcceptMessage()while(true)tryNetworkStreamnetStream=newNetworkStream(socket);bytedatasize=newbyte4;netStream.Read(datasize,0,4);intsize=System.BitConverter.ToInt32(datasize,0);Bytemessage=newbytesize;intdataleft=size;intstart=0;while(dataleft0)intrecv=netStream.Read(message,start,dataleft);start+=recv;dataleft-=recv;this.richTextBoxReceive.Rtf=System.Text.Encoding.Unicode.GetString(message);catchthis.listBoxState.Items.Add(“服务器断开连接。”);break;,“关闭连接”的Click事件代码。privatevoidbuttonClose_Click(objectsender,System.EventArgse)trysocket.Shutdown(SocketShutdown.Both);socket.Close();this.listBoxState.Items.Add(与主机断开连接);thread.Abort();catchMessageBox.Show(尚未与主机连接，断开无效!);this.buttonRequest.Enabled=true;,关闭窗口前触发的事件代码。privatevoidForm1_Closing(objectsender,System.ComponentModel.CancelEventArgse)trysocket.Shutdown(SocketShutdown.Both);socket.Close();catch,“发送信息”的Click事件代码。privatevoidbuttonSend_Click(objectsender,System.EventArgse)stringstr=this.richTextBoxSend.Rtf;inti=str.Length;if(i=0)return;elsei*=2;/因为str为Unicode编码，每个字符占2字节，所以实际字节数应*2bytedatasize=newbyte4;datasize=System.BitConverter.GetBytes(i);bytesendbytes=System.Text.Encoding.Unicode.GetBytes(str);tryNetworkStreamnetStream=newNetworkStream(socket);netStream.Write(datasize,0,4);netStream.Write(sendbytes,0,sendbytes.Length);netStream.Flush();this.richTextBoxSend.Text=;catchMessageBox.Show(无法发送!);,10.5使用TcpClient和TcpListener类简化TCP编程,TcpClient类TcpClient()TcpClient(IPEndPointiep)TcpClient(stringhost,intport)常用属性和方法（表103、表104）TcpListener类TcpListener(intport)TcpListener(IPAddressaddress,intport)TcpListener(IPEndPointiep)常用方法（表105）,10.6异步套接字编程,异步套接字及其常用方法（表106）BeginAccept()方法和EndAccept()方法异步Socket中使用BeginAccept方法开始接收新的连接请求，其方法原型为：publicIAsyncResultBeginAccept(AsyncCallbackcallback,Objectstate)其中：参数1为AsyncCallback类型的委托，委托提供的方法用于接收连接并且调用EndAccept()；参数2为Object类型，用于将状态信息传递给委托提供的方法。Socketsocket=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);IPEndPointiep=newIPEndPoint(IPAddress.Any,6788);socket.Bind(iep);socket.Listen(10);socket.BeginAccept(newAsyncCallback(ClientConnected),socket);,BeginAccept()方法和EndAccept()方法EndAccept()的格式为：SocketEndAccept(IAsyncResultar)IAsyncResult对象将IAsyncResult值从关联的BeginAccept()方法传递到EndAccept()方法。ClientConnected()方法的使用形式为：privatevoidClientConnected(IAsyncResultar)Socketserver=(Socket)ar.AsyncState;Socketclient=server.EndAccept(ar);参数中的IAsyncResult类型表示异步操作的状态，ar是socket.BeginAccept()得到的返回值。,BeginAccept()方法和EndAccept()方法在ClientConnected()方法中，首先根据BeginAccept()方法传递的原始Socket对象得到一个新的Socket对象，然后根据这个对象创建客户端Socket对象，一旦创建了客户端Socket对象，就可以使用同步或者异步的方法与客户端进行通信。使用BeginAccept方法时，类型为Object的状态参数可以用一个类来实现，例如：publicclassStateObjectpublicSocketworkSocket=null;publicconstintbufferSize=1024;publicbytebuffer=newbytebufferSize;publicStringBuildersb=newStringBuilder();然后通过创建该类的实例提供连接请求的状态。,BeginConnect()方法和EndConnect()方法异步套接字编程中，客户端使用BeginConnect()方法连接到远程主机，其格式为：IAsyncResultBeginConnect(EndPointep,AsyncCallBackcallback,Objectstate)其中第一个参数是远程主机的EndPoint对象，第二个参数用于和远程主机连接成功后执行委托调用的方法，最后一个参数是状态对象，用于