大众的网站建设,厂字型布局网站例子,网上书店网站开发代码,金融投资网站模板文章目录TCP分包和粘包TCP分包TCP 粘包分包和粘包解决方案#xff1a;TCP分包和粘包
TCP分包
场景#xff1a;发送方发送字符串”helloworld”#xff0c;接收方却分别接收到了两个数据包#xff1a;字符串”hello”和”world”发送端发送了数量较多的数据#xff0c;接…
文章目录TCP分包和粘包TCP分包TCP 粘包分包和粘包解决方案TCP分包和粘包
TCP分包
场景发送方发送字符串”helloworld”接收方却分别接收到了两个数据包字符串”hello”和”world”发送端发送了数量较多的数据接收端读取数据时候数据分批到达造成一次发送多次读取
造成分包的原因 TCP是以段Segment为单位发送数据的,建立TCP链接后,有一个最大消息长度MSS.如果应用层数据包超过MSS,就会把应用层数据包拆分,分成两个段来发送. 这个时候接收端的应用层就要拼接这两个TCP包才能正确处理数据。 相关的,路由器有一个MTU 最大传输单元一般是1500字节,除去IP头部20字节,留给TCP的就只有MTU-20字节。所以一般TCP的MSS为MTU-201460字节 当应用层数据超过1460字节时,TCP会分多个数据包来发送。
TCP 粘包
场景发送方发送两个字符串”hello”和”world”接收方却接收到了字符串”helloworld”发送端发送了几次数据接收端一次性读取了所有数据造成多次发送一次读取通常是网络流量优化把多个小的数据段集满达到一定的数据量从而减少网络链路中的传输次数
造成TCP粘包的原因
TCP为了提高网络的利用率,会使用一个叫做Nagle的算法.该算法是指,发送端即使有要发送的数据,如果很少的话,会延迟发送.如果应用层给TCP传送数据很快的话,就会把两个应用层数据包“粘”在一起,TCP最后只发一个TCP数据包给接收端.
分包和粘包解决方案
发送数据前给数据附加的长度
粘包解决方案传入数据长度告诉服务器我本次发送的数据只有这么多你可别读多了。分包解决方案传入数据长度告诉服务器我本次发送的数据有这么多你可别读少了。 特殊标识 包头部的特殊标识用来标识包的开始 自定义数据长度数据包的大小固定长度,2、4 或者8字节。数据内容数据内容长度为数据头定义的长度大小。一旦接收方发现标识FBEB,代表接下来N个字节代表数据长度
实际操作如下 a客户端先发送包表示和长度再发送数据内容。 b服务端先解析本次数据包获取数据大小N再读取N个字节这N个字节就是一个完整的数据内容。 程序由回声服务器修改而来 客户端发送小写字母 服务端接收后把他转化为大写字母发送给客户端 先上结果
echo_sever.c
#include stdio.h
#include unistd.h
#include sys/types.h
#include sys/socket.h
#include string.h
#include ctype.h
#include arpa/inet.h#define SERVER_PORT 9999const int DATA_LEN_BYTES 4; // 长度字段定义为两个字节
const char *TAG ABCD;// 标志位int read_package(int client_sock , char *buf){int tag_len strlen(TAG);// 读取前8个字节 即读取标志位和数据长度int readLen read(client_sock , buf , tag_len DATA_LEN_BYTES);int data_len 0;if(strncmp(buf ,TAG , 4) 0){// 有标志位 那么就要读取数据长度data_len *((int* )(buf tag_len));int count 0;// 当前已经读取的字节数int len 0;// 本次读取的字节数// 把标志位和数据长度清空放数据memset(buf,0,tag_len DATA_LEN_BYTES);while(count data_len){// 数据量比较大的话有可能一次读不完要读取很多次// 直到读取的数据长度为data_len// 每次期望读取data_len - count 实际读取为len// len read(client_sock , buf count , data_len - count);// 读取数据写1是为了模拟多次读取len read(client_sock , buf count , 2);printf(本次读取数据量为 %d\n , len);count len;}}else{/*如果没有标志位表示传过来的是普通数据这里先不做处理*/}return data_len;
}int main(void)
{int sock; // 代表信箱struct sockaddr_in server_addr;// 1.美女创建信箱sock socket(AF_INET, SOCK_STREAM, 0);// 2.清空标签写上地址和端口号bzero(server_addr, sizeof(server_addr));server_addr.sin_family AF_INET; // 选择协议族IPV4server_addr.sin_addr.s_addr htonl(INADDR_ANY); // 监听本地所有IP地址server_addr.sin_port htons(SERVER_PORT); // 绑定端口号// 实现标签贴到收信得信箱上bind(sock, (struct sockaddr *)server_addr, sizeof(server_addr));// 3.把信箱挂置到传达室这样就可以接收信件了listen(sock, 128);// 万事俱备只等来信printf(等待客户端的连接\n);int done 1;while (done){struct sockaddr_in client;int client_sock, len, i;char client_ip[64];char buf[256];socklen_t client_addr_len;client_addr_len sizeof(client);client_sock accept(sock, (struct sockaddr *)client, client_addr_len);// 打印客服端IP地址和端口号printf(client ip: %s\t port : %d\n,inet_ntop(AF_INET, client.sin_addr.s_addr, client_ip, sizeof(client_ip)),ntohs(client.sin_port));/*读取客户端发送的数据*/len read_package(client_sock , buf);buf[len] \0;printf(receive[%d]: %s\n, len, buf);// 转换成大写for (i 0; i len; i){buf[i] toupper(buf[i]);}len write(client_sock, buf, len);printf(finished. len: %d\n, len);close(client_sock);}close(sock);return 0;
}echo_client.c
#include stdio.h
#include stdlib.h
#include string.h
#include unistd.h
#include sys/socket.h
#include netinet/in.h#define SERVER_PORT 9999
#define SERVER_IP 127.0.0.1const int DATA_LEN_BYTES 4; // 长度字段定义为两个字节
const char *TAG ABCD;// 标志位int main(int argc, char *argv[]){int sockfd;char *message;struct sockaddr_in servaddr;int n;char *buf NULL;if(argc ! 2){fputs(Usage: ./echo_client message \n, stderr);exit(1);}message argv[1];printf(message: %s\n, message);sockfd socket(AF_INET, SOCK_STREAM, 0);memset(servaddr, \0, sizeof(struct sockaddr_in));servaddr.sin_family AF_INET;inet_pton(AF_INET, SERVER_IP, servaddr.sin_addr);servaddr.sin_port htons(SERVER_PORT);connect(sockfd, (struct sockaddr *)servaddr, sizeof(servaddr));/**********************************************/// 组装数据包int ms_len strlen(message);int tag_len strlen(TAG);// 标志位 数据长度 数据 \0buf (char *)malloc(tag_len DATA_LEN_BYTES ms_len);strcpy(buf , TAG);// 标志位*((int*)(buf tag_len)) ms_len;// 数据长度memcpy(buf tag_len DATA_LEN_BYTES , message , ms_len);//数据// 发送数据write(sockfd , buf , tag_len DATA_LEN_BYTES);// 发送标志位和数据长度sleep(1);write(sockfd , buf tag_len DATA_LEN_BYTES , ms_len);// 发送数据n read(sockfd, buf, sizeof(buf)-1);if(n0){buf[n]\0;printf(receive: %s\n, buf);}else {printf(read error\n);}printf(finished.\n);close(sockfd);return 0;
}
