java Tcp协议验证

package com.ouc.tcp.test; import java.io.BufferedWriter; import java.io.File; import java.io.FileWriter; import java.io.IOException; import com.ouc.tcp.client.TCP_Receiver_ADT; import com.ouc.tcp.message.*; import com.ouc.tcp.tool.TCP_TOOL; public class TCP_Receiver extends TCP_Receiver_ADT { private TCP_PACKET ackPack; //回复的ACK报文段 /*构造函数*/ public TCP_Receiver() { super(); //调用超类构造函数 super.initTCP_Receiver(this); //初始化TCP接收端 } @Override //接收到数据报：设置回复的ACK报文段 public void rdt_recv(TCP_PACKET recvPack) { //生成ACK报文段（设置确认号） tcpH.setTh_ack(recvPack.getTcpH().getTh_seq()); ackPack = new TCP_PACKET(tcpH, tcpS, recvPack.getSourceAddr()); //回复ACK报文段 reply(ackPack); //将接收到的正确有序的数据插入data队列，准备交付 dataQueue.add(recvPack.getTcpS().getData()); //交付数据（每20组数据交付一次） if(dataQueue.size() == 20) { deliver_data(); } System.out.println(); } @Override //交付数据（将接收到的正确有序的数据写入文件） public void deliver_data() { File fw = new File("recvData.txt"); BufferedWriter writer; try { writer = new BufferedWriter(new FileWriter(fw, true)); //循环检查data队列中是否有新交付数据 while(!dataQueue.isEmpty()) { int[] data = dataQueue.poll(); //将数据写入文件 for(int i = 0; i < data.length; i++) { writer.write(data[i] + "\n"); } writer.flush(); //清空输出缓存 } writer.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } @Override //回复ACK报文段 public void reply(TCP_PACKET replyPack) { //设置错误控制标志 tcpH.setTh_eflag((byte)0); //eFlag=0，信道无错误 //发送数据报 client.send(replyPack); } }