姓名：班级：学号：教师：1.实验目的运用各种编程语言实现基于Go-Back-N的可靠数据传输软件。

PS：这里使用的是JAVA语言2.实验意义通过本实验，使学生能够对可靠数据传输原理有进一步的理解和掌握。

3.实验背景Go-Back-N的有限状态机模型表示如下图所示：(a)(b)图为Go-Back-N的有限状态机模型（a）发送端(b)接受端4.实验步骤（1）选择合适的编程语言编程实现基于Go-Back-N的可靠数据传输软件。

（2）在实际网络环境或模拟不可靠网络环境中测试和验证自己的可靠数据传输软件。

5.实验环境（1）实验语言：JAVA（2）实验平台：Eclipse（3）引用库函数：.net库、随机（Random）库、计时库（Timer）6.类概览与描述（1）Sender类：继承于Thread（线程）类，模拟发送方的一切功能，主要功能函数有：A．Public void run()——启动函数，标识开始发送数据包B．Sender()——构造函数，分配并初始化窗口值C．Public void getack(in tack)——ACK接收函数，接收接收方返回的ACK并进行验证是否为期待的ACK值（若不是，则重发）D．Public void time()——定时器函数，初始化定时，计时并记录超时与否的状态（2）Receiver类：继承于Thread（线程）类，模拟接收方的一切功能，主要功能函数有：A．Public void run()——启动函数，标识开始等待并接收数据包B．Void Receive(int data,Sender s)——数据包接收函数，功能强大！主要包括：接收数据包，验证数据包，判断与丢弃数据包等C．Public void respond(int ack)——ACK发送函数，发送当前接收到的最后一次正确的数据包对应的ACK（3）Timers类：继承于TimerTask（计时器）类，具有自定义定时与超时提醒的功能，主要功能函数有：A．Public void run()——启动函数，标识开始计时（这里预设的是2秒的时间），超时后提醒并且停止计时器B．Public Timers()——构造函数，清0计时器，等待下一次启动（4）GBN类：继承于Thread（线程）类，是主函数类，具有本程序的核心功能，这里先作一部分简单介绍，主要函数功能有：A．Static void senddelay(int x) throwsInterruptedExceptionPublic Timers()——随机延迟函数，模拟数据包发送传输过程中的随机延迟，常用延迟值分别为：300ms, 750ms,1200ms, 3000ms等B．Public static void main(String[] args)throws IOException, InterruptedException()——主函数，功能强大，主要包含以下几大方面：①开启发送端与接收端（包括计时器）②超时或者ACK不匹配等情况导致的发送方重新发送数据包③（第一次）发送当前窗口内的数据包④随机函数模拟数据包发送过程中的丢包情况⑤实时更新与显示当前窗口内的数据包情况⑥统计每一个数据包被发送过的次数（含重发）并最终显示出来7.代码展示与描述（一）Sender类import java.util.Timer;public class Sender extends Thread{public int windowsize=3; //发送方窗口长度设为3public String[] data={"data1","data2","data3","data4","data5","data6","data7"}; //模拟七个数据包public int sign[]={0,1,2,3,4,5,6}; //为7个数据包标号public int localack=-1; //保存最近收到的ACKpublic Timers litime=null; //定时器（这里定为2秒）public int switches=0; //超时标志，1为超时public int windowsign[]; //当前窗口内待发的数据分组的序号public int acksign=0;//为0表示收到正确ACK，为1表示收到错误的ACK，必须重发！public Sender(){windowsign=new int[windowsize];//给窗口分配指定大小的空间for(int i=0;i<3;i++)windowsign[i]=sign[i]; //窗口初始化时存放前3个序号}public void run(){System.out.println("发送方开始发送分组数据！");}public void getack(int ack){System.out.println("发送方收到了ACK，序号为"+ack+"并且开始加以确认！");if(ack!=localack+1){System.out.println("经验证，这不是发送方正期待的ACK，立刻重发序号为"+(localack+1)+"的数据分组！");acksign=1;}else{localack=ack; //表示正确确认了ACKacksign=0;}}public void time(){switches=0; //标志初始化为0litime=new Timers();Timer limit=new Timer();limit.schedule(litime, 0,100);}}（二）Receiver类import java.util.Random;public class Receiver extends Thread{public int lastdata;public Sender sender;public void run(Sender s){sender=s;System.out.println("接收方开始接收分组数据！");}void receive(int data, Sender s){sender=s; //发送方的参数传递System.out.println("接收方收到了序号为"+data+"的分组！");if(data!=0){if(data==lastdata+1){//数据包序号校验，若连续则是正确/所期待的System.out.println("该数据分组正是接收方所期待的，接收方接受了它并准备回送对应的ACK！");lastdata=data; //更新本地保存的数据包序号变量respond(lastdata); //回送该正确接收的数据包对应的ACK }else{System.out.println("该数据分组不是接收方所期待的，该分组将被丢弃，接收方准备回送最后接受的数据分组对应的ACK！");respond(lastdata);//若不是所期待的数据包则丢弃并且重发上一次的ACK }}else{System.out.println("该数据分组正是接收方所期待的，接收方接受了它并准备回送对应的ACK！");lastdata=data;respond(lastdata); //首次接收数据包并且回送ACK }}void respond(int ack){ //回送指定序号的ACKif(sender.litime.limit<20){ //判断是否超时（2秒）ack=lastdata; //获取本场保存的数据包序号sender.getack(ack);}else{System.out.println("计时超时！！（未丢包但是时间超过2秒）发送方准备重发序号为"+ack+"的数据分组！");sender.switches=1; //如果超时，设置超时状态并显示警告}}}（三）Timers类import java.util.TimerTask;public class Timers extends TimerTask {public int switches;public int limit;public void run(){if(limit<20) limit++; //计时2秒else {switches=-1;this.cancel();} //开关为-1表示超时，并且停止计时器}public Timers(){switches=0; //启动计时器时全部初始化limit=0;}}（四）GBN类import .*;import java.util.Random;import java.io.*;public class GBN extends Thread{static void senddelay(int x) throws InterruptedException{if(x==1) {sleep(300); System.out.println("发送数据分组时发生延迟：300毫秒！"); }else if(x==2) {sleep(750); System.out.println("发送数据分组时发生延迟：750毫秒！");}else if(x==3) {sleep(1200);System.out.println("发送数据分组时发生延迟：1200毫秒！");}else if(x==4) {sleep(3000);System.out.println("发送数据分组时发生延迟：3000毫秒！");}else;}public static void main(String[] args) throws IOException, InterruptedException {Sender s=new Sender();Receiver re=new Receiver();s.start(); //发送端启动re.run(s); //接收端启动sleep(1000); //延迟处理int[] retimes=new int[7];//计算每个分组被发送的次数for(int i=0;i<7;i++) retimes[i]=0; //数据包顺次发送for(int i=0;i<=s.sign.length;i++){while(i>s.localack+1){ //尚有未确认的数据包，重发！System.out.println("发送方开始重新发送序号为"+(s.localack+1)+"的数据分组");retimes[s.localack+1]++;int ran=new Random().nextInt(3);int randelay=new Random().nextInt(5);s.time();senddelay(randelay); //设置随机值，模拟数据传输延迟if(ran!=1) re.receive(s.localack+1,s);//设置随机值，模拟数据丢包过程else System.out.println("序号为"+(s.localack+1)+"的分组在传给接收方途中发生了丢包！");}if(i!=s.sign.length){System.out.println();System.out.println("发送方现在开始第一次发送序号为"+i+"的数据分组");retimes[i]++;if(i!=0){for(int k=0;k<3;k++){//表示至少成功发送并确认了一个数据分组s.windowsign[k]++;//这种情况下滑动窗口向前移动！}}System.out.println();System.out.println("当前窗口内的分组情况为：");//显示当前窗口内数据包情况for(int p=0;p<3;p++){if(s.windowsign[p]<=6)System.out.println("第"+p+"号窗口里面存放的是序号为"+s.windowsign[p]+"的马上待发送的数据分组！");elseSystem.out.println("第"+p+"号窗口已经空了，并且后续窗口、发送方没有要发送的数据分组了！");}System.out.println();int ran=new Random().nextInt(3);int randelay=new Random().nextInt(5);s.time(); //计时开始（2秒时间）senddelay(randelay); //设置随机值，模拟数据传输延迟if(ran!=1) re.receive(s.sign[i],s);//设置随机值，模拟数据丢包过程else System.out.println("序号为"+i+"的分组在传给接收方途中发生了丢包！");}}System.out.println();System.out.println("以下是每个数据分组被发送过的次数的统计结果");for(int i=0;i<7;i++) //显示关于每个数据包发送次数的统计表System.out.println("序号为"+i+"的数据分组被发送过的次数为："+retimes[i]);System.exit(0);}}8.程序运行结果部分截图。