我正在使用UDP实现“stop and go”协议。我基本上使用char缓冲区来序列化我发送的任何数据，在需要的地方使用ntoh和hton，并在我的数据到达另一端时进行反序列化。一切都很好，但是当我尝试发送文件时，我在新文件中得到随机的伪造字节。我将尝试总结这个问题的必要信息：
char缓冲区中的第一个字符表示正在发送的数据包类型。我实现了一个小的3次握手来建立连接。服务器只需将特定端口作为arg，客户端获取ip，端口和文件名，然后从服务器请求此文件。服务器响应文件的大小，然后客户端发送最终的ACK数据包，然后发送数据。我使用fread（）一次发送数据〜1kb，使用1kb缓冲区大小。一旦客户端获得此数据包，它就会发送一个确认数据包，然后等待下一个数据包。这是相关代码：
else if (b == 'a')
{
memcpy(&dacpkt.seqNum, buffer+sizeof(char), sizeof(int));
dacpkt.seqNum = ntohl(dacpkt.seqNum); // convert from network to host data
datapkt.pktLen = 1017;
if (dacpkt.seqNum == datapkt.seqNum)
{
++seq;
dacpkt.t = b;
datapkt.seqNum = seq;
fread(datapkt.data, datapkt.pktLen, 1, filereq);
memcpy(buffer, &datapkt.t, sizeof(char)); // data packet type
off = sizeof(char);
datapkt.seqNum = htonl(datapkt.seqNum);
memcpy(buffer + off, &datapkt.seqNum, sizeof(int)); // data packet sequence#
off += sizeof(int);
datapkt.pktLen = htons(datapkt.pktLen);
memcpy(buffer + off, &datapkt.pktLen, sizeof(short)); // data packet size
off += sizeof(short);
memcpy(buffer + off, &datapkt.data, 1017); // data packet payload
n = sendto(sock, buffer, MAX, 0, (struct sockaddr*) &from, fromlen);
if (n < 0)
error("sendto");
}
if(fread(datapkt.data, 1017, 1, filereq) != 1017) // fread hit the end of the file
{
++seq;
dacpkt.t = 'c';
dacpkt.seqNum = seq;
memcpy(buffer, &dacpkt.t, sizeof(char)); // close packet
off = sizeof(char);
dacpkt.seqNum = htonl(dacpkt.seqNum);
memcpy(buffer + off, &dacpkt.seqNum, sizeof(int)); // close packet sequence#
n = sendto(sock, buffer, 5, 0, (struct sockaddr*) &from, fromlen);
}
}
dacpkt是我在从recvfrom（）反序列化char缓冲区时填充的确认数据包，datapkt是我构建的数据包，然后是序列化和发送。我相信我的问题在于我对fread的使用。这是接收代码客户端：
if (b == 'd')
{
//build the response packet and send
memset(buffer, 0, MAX);
//populate struct
dacpkt.t = 'a';
dacpkt.seqNum = htonl(sequence_num);
//copy to buffer
memcpy(buffer, &dacpkt.t, sizeof(char));
off = sizeof(char);
memcpy(buffer + off, &dacpkt.seqNum, sizeof(int));
//send the ACK
n = sendto(sock, buffer, MAX, 0, (struct sockaddr *) &server, length);
if (n < 0)
error("sendto");
//receive as well before exiting while loop
memset(buffer, 0, MAX);
n = recvfrom(sock, buffer, MAX, 0, (struct sockaddr *) &from, &length);
if (n < 0)
error("recvfrom");
datapkt.t = buffer[0];
off = sizeof(char);
memcpy(&datapkt.seqNum, buffer + off, sizeof(int));
datapkt.seqNum = ntohl(datapkt.seqNum);
off += sizeof(int);
memcpy(&datapkt.pktLen, buffer + off, sizeof(short));
datapkt.pktLen = ntohl(datapkt.pktLen);
off += sizeof(short);
strcat(datapkt.data, buffer + off);
//ensures we are receiving the next packet
if (datapkt.seqNum = (sequence_num + 1))
{
n = fputs(datapkt.data, newfile); //we need buffer to be the exact size
if (n < 0)
error("writing to file");
sequence_num = datapkt.seqNum;
}
}
fclose(newfile);
}
//post-receiving the file!
memset(buffer, 0, MAX);
dacpkt.t = 'c';
dacpkt.seqNum = htonl(sequence_num);
memcpy(buffer, &dacpkt.t, sizeof(char));
memcpy(buffer + 1, &dacpkt.seqNum, sizeof(int));
//send the ACK
n = sendto(sock, buffer, MAX, 0, (struct sockaddr *) &server, length);
if (n < 0)
error("sendto");
我很抱歉，如果我提供的信息有点含糊不清，但我相当肯定我的问题在于我的读/写文件。例如，我运行程序试图在600行上传输每行上带字母字符（a-z）的文本文件。原始文件为16200字节，而发送数据创建的新文件仅为3069字节。新文件只有113行，随机字节始终显示如下：
36 abcdefghijklmnopqrstuvwxyz
37 abcdefghijklmnopqrstuvwxyz
38 abcdefghijklmnopqr8ze$ü^?abcdefghijklmnopqrstuvwxyz
39 abcdefghijklmnopqrstuvwxyz
值得注意的是，在文件的末尾：
111 abcdefghijklmnopqrstuvwxyz
112 abcdefghijklmnopqrstuvwxyz
113 abcdefghi8ze$ü^?
我想我不明白fread（）如何工作，关于如何判断何时结束文件传输。如果有人对如何更好地实现这一点有想法，我会全力以赴。我想做的就是一次发送一个kb数据包中的数据，直到我到达文件末尾，此时，我发送这个最终的部分数据包，然后发送信号关闭客户端。
两件事立即发生。
fread返回它读取的项目数。 fread(datapkt.data, 1017, 1, filereq)试图读取一个大小为1017的项目。这个电话不可能返回1017.它可能只返回0或1。
if (fread(....) != 1017)
总是失败。但是，已读取1017个字节，并且由于测试失败，将被丢弃。这解释了巨大的数据丢失。
交换参数的顺序，检查如何读取1字节的项目：
size_t bytes = fread(datapkt.data, 1, 1017, filereq);
并使用此bytes作为有效载荷的大小。 bytes < 1017可能表示文件结束。当然，请致电feof和ferror。 if (dacpkt.seqNum == datapkt.seqNum) {
....
fread(...);
....
}
if (fread(....) != 1017) {
....
}
意味着一旦fread匹配就会有两次调用seqNum，如果没有则调用一次。我无法真正关注数据流，但它确实感到奇怪。服务器不得继续发送新的seqNum，直到收到确认。
无论如何，它不应盲目地发送MAX字节。第一个fread也必须检查它得到了多少字节，并相应地修正memcpy和sendto中的大小。要_detect EOF并同时读取数据，请尝试类似的方法
size_t bytes = fread(datapkt.data, 1, 1017, filereq);
if (bytes == 0 && feof(filereq)) {
handle_end_of_file();
} else {
memcpy(memcpy(buffer + off, &datapkt.data, bytes);
send_the_packet();
}