内容简介:客户端发送数据时,可以知道数据的大小(长度)。客户端接收数据的时候,可以知道接收到数据的大小(长度)。所以,客户端循环调用read函数,直到接收到的数据总大小(长度)等于发送的数据的大小(长度)时,已完成所有数据的接收。修改的代码:
C++回声服务器_1-简单版本 中的问题出在客户端。客户端通过write函数一次性发送数据,过一段时间再调用一次read函数,期望接收传输的数据。问题在于这段时间到底是多久?理想的客户端应在接收到数据时立即读取数据。
改进
客户端发送数据时,可以知道数据的大小(长度)。客户端接收数据的时候,可以知道接收到数据的大小(长度)。所以,客户端循环调用read函数,直到接收到的数据总大小(长度)等于发送的数据的大小(长度)时,已完成所有数据的接收。
修改的代码:
// 发送的字符串长度、接收字符串的长度、每次read函数接受到字符串的长度 ssize_t str_len, recv_len, recv_cnt; str_len = write(sock, message, strlen(message)); // 向服务器发送数据 recv_len = 0; // 循环调用read函数,直到接收到所有数据为止 while (recv_len < str_len) { recv_cnt = read(sock, message, BUF_SIZE); // 读取来自客户端的服务器 if (recv_cnt == -1) { error_handling("read() error"); } recv_len += recv_cnt; } message[recv_len] = 0;
完整的客户端代码:
#include <cstdio> #include <cstdlib> #include <cstring> #include <unistd.h> #include <arpa/inet.h> #include <sys/socket.h> const int BUF_SIZE = 1024; void error_handling(const char *message); // 接收两个参数,argv[0]为IP地址,argv[1]为端口号 int main(int argc, char *argv[]) { int sock; struct sockaddr_in server_addr; char message[BUF_SIZE]; // 发送的字符串长度、接收字符串的长度、每次read函数接受到字符串的长度 ssize_t str_len, recv_len, recv_cnt; if (argc != 3) { printf("Usage : %s <IP> <port>\n", argv[0]); exit(1); } sock = socket(PF_INET, SOCK_STREAM, 0); if (sock == -1) { error_handling("socket() error"); } // 地址信息初始化 memset(&server_addr, 0, sizeof(server_addr)); server_addr.sin_family = AF_INET; // IPV4 地址族 server_addr.sin_addr.s_addr = inet_addr(argv[1]); // 服务器IP地址 server_addr.sin_port = htons(atoi(argv[2])); // 服务器端口号 // 向服务器发送连接请求 if (connect(sock, (struct sockaddr*)&server_addr, sizeof(server_addr)) == -1) { error_handling("connect() error"); } else { printf("Connect..."); } while (1) { printf("Input message( Q to quit ): "); fgets(message, BUF_SIZE, stdin); // 如果输入q或者Q,则退出 if (!strcmp(message, "q\n") || !strcmp(message, "Q\n")) { break; } str_len = write(sock, message, strlen(message)); // 向服务器发送数据 recv_len = 0; // 循环调用read函数,直到接收到所有数据为止 while (recv_len < str_len) { recv_cnt = read(sock, message, BUF_SIZE); // 读取来自客户端的服务器 if (recv_cnt == -1) { error_handling("read() error"); } recv_len += recv_cnt; } message[recv_len] = 0; printf("Message from server: %s \n", message); } // 关闭连接 close(sock); return 0; }
项目代码
参考
以上所述就是小编给大家介绍的《C++回声服务器_2-修复客户端问题》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!
猜你喜欢:- GoLang 示例:并发回声服务器
- 详解低延时高音质:回声消除与降噪篇
- [C++回声服务器_1]简单版本
- C++回声服务器_3-UDP版本
- 支付宝客户端架构解析:iOS 客户端启动性能优化初探
- 自己动手做数据库客户端: BashSQL开源数据库客户端
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
Android和PHP开发最佳实践
黄隽实 / 机械工业出版社华章公司 / 2013-3-20 / 79.00元
本书是国内第一本同时讲述Android客户端开发和PHP服务端开发的经典著作。 本书以一个完整的微博应用项目实例为主线,由浅入深地讲解了Android客户端开发和PHP服务端开发的思路和技巧。从前期的产品设计、架构设计,到客户端和服务端的编码实现,再到性能测试和系统优化,以及最后的打包发布,完整地介绍了移动互联网应用开发的过程。同时,本书也介绍了Android系统中比较有特色的功能,比如Go......一起来看看 《Android和PHP开发最佳实践》 这本书的介绍吧!
URL 编码/解码
URL 编码/解码
RGB HSV 转换
RGB HSV 互转工具