7滑动窗口协议模拟

实验8滑动窗口协议模拟一、实验目的1.模拟实现滑窗协议在数据链路层上的数据传输过程，加深对滑窗协议的理解2.掌握滑动窗口协议基本原理与基本算法；二、要求：1.掌握滑动窗口协议的概念、原理与基本算法；2.实现“选择性重传策略或连续自动重传策略（后退N帧）”的滑动窗口协议模拟程序；3.了解传输层和链路层滑动窗口协议的区别与联系及TCP中滑动窗口协议的实现原理。三、实验原理滑窗协议工作原理由于停等协议要为每一个帧进行确认后才继续发送下一个帧，大大降低了信道利用率，因此又提出来回退N帧的滑窗协议。回退N帧协议中，发送方在发送完一个数据帧后，不停下来等待应答帧，而是连续发送若干个数据帧，即使在连续发送过程中收到了接收方发来的应答帧，也可以继续发送。由于减少了等待时间，必然提高通信的吞吐量和信道利用率。回退N帧的滑窗协议（GO-DACK-N）基本原理是，当接收方检测出错的信息帧后，丢弃出错帧后的所有信息帧，而不管这些帧是否正确。待发送方收到对出错帧的否定应答（NAK）时，将重发从出错后的所有数据帧；若应答帧出错，则超时重发。因此，发送方在每发完一个数据帧时都要设置超时计时器。只要在所设置的计时器超时而仍未收到确认帧，就要重发相应的数据帧，若等不到1号帧的确认应答而重发1号数据帧时，虽然发送方已经发送完3号帧，但仍必须将1号帧及其以后的各帧全部进行重传。因此，后退N帧协议一方面因连续发送数据帧而提高了效率，但另一方面，在重传时又必须把原来已正确传送过的数据帧进行重传，这种做法又使传送率降低。四、实验要求1.WindowsXP环境下运行，程序在1~2台PC上运行。2.具体实现的协议可以采用回退N帧技术或者选择性重发技术的协议。3.采用.NET平台中的C#、C++或其他编程语言实现。五、实验内容模拟滑窗协议的实现过程为;（1)程序客户端线程发送连接请求。(2)服务器连接并返回连接信息。（3)客户端发送数据帧（窗口大小自行设定）。(4)服务器对每一个收到数据帧都返回收到信息或者返回数据接收超时信息。(5)客户端根据返回信息确定是否重传数据还是选择重传数据。【实验过程】（实验步骤、记录、数据、分析）客户端的主程序流程图：数据帧传输服务器端的流程图：五、详细代码#includesysinclude.h#includedequeusingnamespacestd;externvoidSendFRAMEPacket(unsignedchar*pData,unsignedintlen);#defineWINDOW_SIZE_STOP_WAIT1#defineWINDOW_SIZE_BACK_N_FRAME4typedefenum{data,ack,nak}frame_kind;typedefstructframe_head{frame_kindkind;//帧类型unsignedintseq;//序列号unsignedintack;//确认号unsignedchardata[100];//数据};typedefstructframe{frame_headhead;//帧头unsignedintsize;//数据的大小};//需要定义另外一个数据结构来存帧和其大小typedefstructmainFrame{frame*f;intsize;};dequemainFramestop_wait_send_queue;//停等式协议发送队列dequemainFramebackn_send_queue;//回退N式协议发送队列dequemainFramechoice_send_queue;//选择性重传式协议发送队列boolfull=false;//标记停等式时窗口是否为空intcurrent_window_size=0;//回退N的当前窗口大小intcurrent_window_size_c=0;//选择性重传式的当前窗口大小/**停等协议测试函数*/intstud_slide_window_stop_and_wait(char*pBuffer,intbufferSize,UINT8messageType){unsignedintack;unsignedintseq;mainFrametemp;mainFramesend;mainFramereceive;if(messageType==MSG_TYPE_SEND){temp.f=newframe;(*temp.f)=*(frame*)pBuffer;temp.size=bufferSize;stop_wait_send_queue.push_back(temp);//将发送数据封装后压入发送队列,下同if(full==false)//窗口不为空时发送{full=true;//关闭窗口send=stop_wait_send_queue.front();SendFRAMEPacket(((unsignedchar*)send.f),send.size);}return0;}if(messageType==MSG_TYPE_RECEIVE){ack=((frame*)pBuffer)-head.ack;if(stop_wait_send_queue.size()!=0){receive=stop_wait_send_queue.front();if(ack==(receive.f)-head.seq)//找到对应ack的帧,关闭该窗口{stop_wait_send_queue.pop_front();if(stop_wait_send_queue.size()!=0){send=stop_wait_send_queue.front();//等待队列中还有数据的话打开新窗口发送SendFRAMEPacket(((unsignedchar*)send.f),send.size);}}}else{full=false;//接收队列为空则打开新窗口}return0;}if(messageType==MSG_TYPE_TIMEOUT){seq=ntohl(*(unsignedint*)pBuffer);send=stop_wait_send_queue.front();//超时重发队列头部的帧if(seq==send.f-head.seq){SendFRAMEPacket(((unsignedchar*)send.f),send.size);}return0;}return0;}/**回退n帧测试函数*/intstud_slide_window_back_n_frame(char*pBuffer,intbufferSize,UINT8messageType){unsignedintack;unsignedintseq;mainFrametemp;mainFramesend;mainFramereceive;intcurrent_frame;inti;if(messageType==MSG_TYPE_SEND){temp.f=newframe;(*temp.f)=*(frame*)pBuffer;temp.size=bufferSize;backn_send_queue.push_back(temp);if(current_window_sizeWINDOW_SIZE_BACK_N_FRAME)//发送窗口未满时继续发送{current_window_size++;send=backn_send_queue.back();SendFRAMEPacket(((unsignedchar*)send.f),send.size);}return0;}if(messageType==MSG_TYPE_RECEIVE){ack=((frame*)pBuffer)-head.ack;for(current_frame=0;current_frameWINDOW_SIZE_BACK_N_FRAME&¤t_framebackn_send_queue.size();current_frame++){receive=backn_send_queue[current_frame];//接受ack及之前的帧if(ack==receive.f-head.seq)break;}if(current_frameWINDOW_SIZE_BACK_N_FRAME&¤t_framebackn_send_queue.size()){for(i=0;i=current_frame;i++)//关闭接收完毕的帧对应的窗口{backn_send_queue.pop_front();current_window_size--;}}for(i=current_window_size;iWINDOW_SIZE_BACK_N_FRAME&&ibackn_send_queue.size()&¤t_window_sizeWINDOW_SIZE_BACK_N_FRAME;i++){current_window_size++;//接收完毕后窗口前移,继续发送send=backn_send_queue[i];SendFRAMEPacket(((unsignedchar*)send.f),send.size);}return0;}if(messageType==MSG_TYPE_TIMEOUT){seq=ntohl(*(unsignedint*)pBuffer);for(current_frame=0;current_frameWINDOW_SIZE_BACK_N_FRAME&¤t_framebackn_send_queue.size();current_frame++){send=backn_send_queue[current_frame];if(seq==send.f-head.seq)//找到重发的帧在队列中的位置break;}for(i=current_frame;iWINDOW_SIZE_BACK_N_FRAME&&ibackn_send_queue.size();i++){send=backn_send_queue[i];//重发其后所有帧SendFRAMEPacket(((unsignedchar*)send.f),send.size);}return0;}return0;}/**选择性重传测试函数*/intstud_slide_window_choice_frame_resend(char*pBuffer,intbufferSize,UINT8messageType){unsignedintack;unsignedintseq;mainFrametemp;mainFramesend;mainFramereceive;intcurrent_frame;inti;if(messageType==MSG_TYPE_SEND)//发送部分和回退n的是一样的{temp.f=newframe;(*temp.f)=*(frame*)pBuffer;temp.size=bufferSize;choice_send_queue.push_back(temp);if(current_window_sizeWINDOW_SIZE_BACK_N_FRAME){current_window_size++;send=choice_send_queue.back();SendFRAMEPacket(((unsignedchar*)send.f),send.size);}return0;}if(messageType==MSG_TYPE_RECEIVE){frame_kindframe_type=(frame_kind)ntohl(((frame*)pBuffer)-head.kind);//获取帧的类型ack=((frame*)pBuffer)-head.ack;if(frame_t