socket编程UDP-文件传输模拟TCP建立连接脱离连接#xff08;进阶篇#xff09;_udp

socket发送-CSDN博客

sock…在下面博客中我介绍了利用UDP模拟TCP连接、按数据包发送文件的过程并附上完整源码。

socket编程UDP-文件传输模拟TCP建立连接脱离连接进阶篇_udp

socket发送-CSDN博客

socket编程UDP-实现滑动窗口机制与累积确认GBN-CSDN博客

本篇博客我将在此基础上实现停等机制完成客户端发送的接收确认、超时重传。

1.实现思路

每次客户端发送的数据包有唯一的序列号seq随着数据包的发送不断递增

如果服务器端收到新的数据包会发送对应的ack.(比如收到seq1就会发送ack1,收到seq2就会发送ack2).

所谓停等机制就是发送方每轮只发送一个数据包直到收到期待的ack(即与序列号对应的ack)才会发送下一个数据包。

如果发送方在定时器时间内没有收到期待的ack,将会重传这一数据包。

正如图中发送端重传seq2)

1.实现思路

‘sendFile‘方法负责逐个发送数据包并在每次发送后调用‘waitForAck‘等待接收

ACK

确认。

每个数据包都包含一个序列号‘seqNum‘用于标识数据的顺序和确认接收的正确性。

发送数据包后

‘ackReceived‘标志被设置为

‘waitForAck‘方法使用条件变量和超时机制如果在设定的超时时间内未收到正确的

ACK

‘false‘触发重传逻辑如果收到了正确ack,则会返回true.

2.核心源码

std::chrono::milliseconds(TIMEOUT),

[this,

ackPacket(SERVER_PORT,ROUTER_PORT);socklen_t

len

reinterpret_castchar*(ackPacket),

sizeof(ackPacket),

(ackPacket.validateChecksum(clientAddr.sin_addr.S_un.S_addr,

routerAddr.sin_addr.S_un.S_addr)

ackPacket.ack

lock(mtx);std::cout收到ACKackackPacket.ackstd::endl;ackReceived

void

packet(CLIENT_PORT,ROUTER_PORT);packet.seq

static_castint(file.gcount());packet.flag

数据包ackReceived

seqNum;//1.创建接收线程避免第三次握手时ACK的丢包Datagram

AckPacket(SERVER_PORT,ROUTER_PORT);if(seqNum3){std::thread

ackThread1(Sender::receivePacket,this,

std::ref(AckPacket));std::this_thread::sleep_for(std::chrono::milliseconds(TIMEOUT));

//休眠等一会儿ackThread1.detach();//修改}while

(true)

2seqNum3AckPacket.validateChecksum(clientAddr.sin_addr.S_un.S_addr,

routerAddr.sin_addr.S_un.S_addr))//2.如果此时又收到了SYN-ACK{std::cout

ackPacket(CLIENT_PORT,ROUTER_PORT);ackPacket.flag

ACKsendPacket(ackPacket);std::cout

重新发送ACK包连接建立成功\n;std::this_thread::sleep_for(std::chrono::milliseconds(TIMEOUT));

//休眠等一会儿AckPacket.flag1;}sendPacket(packet);std::cout

发送数据包.SEQ

packet.checksumstd::endl;std::this_thread::sleep_for(std::chrono::milliseconds(5*TIMEOUT));

//休眠等一会儿if

https://github.com/yeyeyeyeye-zhang/Computer-Network/tree/main/lab3-1/codes

三、运行演示