c - 接收部分在 TCP 套接字编程中不能正常工作
问题描述
我正在做一个 TCP 套接字编程。
客户端:客户端将从服务器接收文件列表 --> 向服务器发送文件名 --> 从服务器接收文件
我的问题:
- 服务器正确发送文件列表。我把所有的都打印出来了,所有的都寄得很好。但是,客户端可以很好地接收它,但是即使服务器发送 while 循环完成,while 循环也没有完成。
[客户]
while ((read_cnt=read(sd, buf, BUF_SIZE)) != 0) {
read_cnt=read(sd, buf, BUF_SIZE);
printf("%s\n", buf);
}
[服务器]
while ((entry=readdir(dir)) != NULL) {
sprintf(buf, "%s\n", entry->d_name);
write(clnt_sd, buf, strlen(buf));
}
- 服务器发送 17 条消息,但客户端收到 15 条消息,并且 while 循环未完成。当 while 循环收到“finish”时,让客户端完成 while 循环 --> 即使服务器发送了 17 条消息,它仍然收到 15 条消息。
[客户]
while (1) {
read_cnt=read(sd, buf, BUF_SIZE);
fwrite((void*)buf, 1, read_cnt, fp);
printf("%s\n", buf);
if (strstr(buf, "fin") != NULL) {
break;
}
total_read += read_cnt;
pcnt = ((total_read/ file_size) * 100.0)/10;
printf("(%.0d %%) Send %.0f / %.0f bytes.\n", pcnt*10, total_read, file_size);
}
[服务器]
FILE *fp;
fp = fopen(file_name, "r");
if (fp == NULL) {
printf("File not Exist");
exit(1);
}
fseek(fp, 0, SEEK_END);
int file_size = ftell(fp);
sprintf(buf, "%d", file_size);
write(clnt_sd, buf, read_cnt);
fseek(fp, 0, SEEK_SET);
while (feof(fp) == 0) {
read_cnt = fread((void*)buf, 1, BUF_SIZE, fp);
write(clnt_sd, buf, read_cnt);
}
fclose(fp);
我尝试了 memset, bzero 使缓冲区为空,但没有奏效。我认为问题出在客户端部分,因为当我使用 print 检查服务器端时,它们发送良好并完成了 while 循环。但我不知道客户端接收过程中的问题是什么。请让我知道是什么问题。
解决方案
服务器发送 17 条消息,但客户端收到 15 条消息
完全正常。
TCP 是流协议,而不是消息传递协议。您在一侧“发送”的内容可能不是另一端接收到的确切字节数。您必须期望消息在 read/recv 调用之间和内部以分块、合并或分段的形式到达。您甚至不能假设您作为 4 字节消息发送的初始“大小”写入是在同一个read
调用中作为整个消息接收的。
实现您的客户端代码以期望read
并recv
返回随机数的字节数,最多为您传入的缓冲区大小。如果您获得的字节数少于预期,则需要再次read/recv
调用以接收其余部分 - 调整您的目标缓冲区指针如所须。或者使用MSG_WAITALL
标志recv
(而不是读取)在一次调用中获取所有数据。您仍然需要检查缓冲区的结果,以确保您获得了预期的字节数,流没有关闭,并验证没有发生错误(-1 返回)。
推荐阅读
- angular - 如何在 ngx-chart-line-chart 工具提示上对值进行排序
- python - 两个类在 HTML 中具有相同的名称,而 BeautifulSoup 只选择第一个类
- javascript - 重构 react/node 如何处理响应
- c++ - 使用可变参数将成员函数绑定到实例
- ms-office - 从头开始检查加载以调试 Excel 加载项
- javascript - 将返回的 api 数据设置为反应状态
- javascript - 换班
- 当每个复选框
- 被检查
- node.js - 控制器引用未定义 node.js 应用程序
- docker - 如何将 Docker 与 GitHub Actions 一起使用?
- r - 第二个 yaxis 不适用