TCP粘包拆包原因拆解:1. 发送数据太大装不下 → 拆包你可以把 TCP 发送缓冲区 理解成一个小快递箱子。你一次性塞了超大一堆数据箱子装不下系统只能强行分成好几箱分批发货 对应你发的数据 发送缓冲区大小 拆包2. 发送数据太小系统攒一攒再发 → 粘包还是快递箱子你每次只发一点点小数据箱子还空很大直接发太浪费快递费浪费网络资源操作系统很聪明先憋着不发等你多发几次装满箱子一起发结果你发的 3 条消息被合成 1 条发到对面。 这就是粘包3. 网络硬件有最大限制MSS/MTU→ 拆包马路有宽度限制货车载货长度不能超标网络里每一个「数据包」也有法定最大长度你发的数据包太长超过网络规定上限必须切碎成小段才能正常在路上传输简单对应MTU整条路最大允许的货车总长MSS货车里能装的纯货物最大长度数据超标 → 强制切碎 → 拆包4. 接收方读数据太慢 → 粘包换接收端视角对方发过来的数据会先放到电脑的临时缓存区仓库你的程序如果偷懒、读数据很慢新的数据不断进来全都堆在仓库里挤在一起等你终于来读的时候一次性读出好几条混在一起的数据 前面的没拿走后面的堆上来 粘包TCP 粘包/拆包 三种最简单解决方案:方案一固定长度原理:规定每条消息固定多少字节比如统一每条 1024 字节。优缺点:✅ 逻辑超简单代码好写❌ 浪费流量短消息也要占满固定长度适用情景:消息永远很短比如验证码、指令、状态长度永远固定比如 4 字节数字、8 字节 ID绝对不能用于聊天消息长文本文件图片动态长度数据方案二首尾分隔符原理在每条消息的末尾加特殊分隔符比如 \n、#、要求分隔符不能出现在正常业务数据里。例子两条消息今天吃饭#明天上课#哪怕 TCP 粘包拼成今天吃饭#明天上课#接收端不断读数据只要读到 #就截取前面当成一条完整消息。优缺点✅ 实现简单文本协议聊天、HTTP常用❌ 二进制数据文件、图片不适合容易和分隔符冲突为什么二进制数据不可以呢?二进制文件是纯机器编码没有 “冷门” 一说任何单字节、多字节组合都有概率天然出现在文件内容里。方案三消息头 数据长度原理:每条数据分为两部分消息头固定字节存「后面数据的长度」消息体真实要发送的数据流程:发送先计算消息体有多少字节把「长度」写到数据包开头长度 真实数据 一起发出去接收第一步先读取固定长度的消息头解析出「本次消息有多长」第二步根据长度精准读取对应字节的消息体读完一条再循环取下一条例子要发数据hello world假设用 4 字节存长度数据长度11发送内容[长度11] hello world接收先读 4 字节 →string recvMsg(int fd){ //1读取长度头 int netlen0; int retrecv(fd,netlen,HEADER_LEN,0); if(ret0) return ; //2转回本机字节序 int datalenntohl(ret); //3按需读取完整数据 char buf[1024]{0}; recv(fd,buf,datalen,0); return string(buf); }知道要收 11 个字节 → 精准只读 11 字节完美拆分。优缺点✅ 不浪费流量、二进制 / 文本都能用、工业级标准方案❌ 比前两种多一点点代码但是最通用代码实现简单socket功能程序1:attempt_client.cpp程序2:attempt_server.cppg attempt_server.cpp -o attempt_serverg attempt_client.cpp -o attempt_client先跑服务端./attempt_server再开一个窗口跑客户端./attempt_clientattempt_client.cpp#include bits/stdc.h #include sys/socket.h #include arpa/inet.h using namespace std; const int HEADER_LEN4; void sendMsg(int fd,string msg){ //1获取数据长度 int lenmsg.size(); //2先发固定的4个字节长度(网络字节序) int netLenhtonl(len); send(fd, netLen, HEADER_LEN, 0); //3发数据 send(fd,msg.c_str(),len,0); return; } string recvMsg(int fd){ //1读取长度头 int netlen0; int retrecv(fd,netlen,HEADER_LEN,0); if(ret0) return ; //2转回本机字节序 int datalenntohl(ret); //3按需读取完整数据 char buf[1024]{0}; recv(fd,buf,datalen,0); return string(buf); } int main(){ //1创建socket int clientFdsocket(AF_INET,SOCK_STREAM,0); //2连接服务端 127.0.0.1:8888 sockaddr_in serAddr; // ① 创建一个“地址信息”变量 serAddr.sin_family AF_INET; // ② 用IPv4地址固定写法 serAddr.sin_port htons(8888); // ③ 端口号8888 serAddr.sin_addr.s_addr inet_addr(127.0.0.1); // ④ IP本机 connect(clientFd, (sockaddr*)serAddr, sizeof(serAddr)); // ⑤ 发起连接 cout连接服务端成功endl; string input; while(1){ cout请输入信息endl; getline(cin,input); sendMsg(clientFd,input);//发 string resrecvMsg(clientFd); cout服务端回复resendl; } close(clientFd); return 0; }attempt_server.cpp#include bits/stdc.h #include sys/socket.h #include arpa/inet.h using namespace std; const int HEADER_LEN4; void sendMsg(int fd,const string msg){ //1获取数据长度 int lenmsg.size(); //2先发固定的4个字节长度(网络字节序) int netLenhtonl(len); send(fd,netLen,HEADER_LEN,0); //3发数据 send(fd,msg.c_str(),len,0); return ; } string recvMsg(int fd){ //1读取长度头 int netlen0; int retrecv(fd,netlen,HEADER_LEN,0); if(ret0) return ; //2转回本机字节序 int datalenntohl(ret); //3按需读取完整数据 char buf[1024]{0}; recv(fd,buf,datalen,0); return string(buf); } int main(){ //1创建socket int listenFdsocket(AF_INET,SOCK_STREAM,0); // sockaddr_in serAddr; serAddr.sin_family AF_INET; serAddr.sin_port htons(8888); serAddr.sin_addr.s_addr INADDR_ANY; //3 bind绑定 bind(listenFd,(sockaddr*)serAddr,sizeof(serAddr)); //4 listen监听 listen(listenFd, 5); // 最多排队5个连接 cout 服务端启动监听8888...\n; //5 accept等待客户端连接 int connFdaccept(listenFd,NULL,NULL); while(1){ string resrecvMsg(connFd); cout收到客户端消息:resendl; sendMsg(connFd, 已收到 res); } close(connFd); close(listenFd); return 0; }函数解释htonl()在attempt_client.cpp中,发送长度时,用到htonl().其目的是,转为网络字节序.那么,为什么进行这一操作?因为不同电脑的 “字节存储顺序” 不一样不转成统一的网络字节序接收方读到的长度会变成乱数直接解析失败。不同电脑字节存储顺序不同,如何理解?简单说多字节数字在内存里是从左往右存还是从右往左存有两种小端序主机字节序大端序网络字节序socket()1 作用:创建一个网络插座,让程序有收发网络数据功能2 返回值:成功:返回文件描述符fd失败:-13 参数:socket(协议族/地址族, 数据传输方式,0);决定使用什么网络类型 TCP/UDP常用:socket(AF_INET,SOCK_STREAM,0)connect()1 作用:客户端用它去连接指定IP和端口的服务器,即主动 “打电话” 连接服务器2 前提:用socket创建好fd3 返回值:成功0,失败-14 参数:connect(fd,(sockaddr*)serAddr,sizeof(serAddr))fd:文件描述符(sockaddr*)serAddr:结构体指针存服务器的IP地址端口号因此,在写connect之前,要有:sockaddr_in serAddr; serAddr.sin_familyAF_INET; serAddr.sin_porthtons(xxxx);//服务器端口 serverAddr.sin_addr.s_addrinet_addr(x.x.x.x); //服务器IP常见形式://2连接服务端 127.0.0.1:8888 sockaddr_in serAddr; // ① 创建一个“地址信息”变量 serAddr.sin_family AF_INET; // ② 用IPv4地址固定写法 serAddr.sin_port htons(8888); // ③ 端口号8888 serAddr.sin_addr.s_addr inet_addr(127.0.0.1); // ④ IP本机 connect(clientFd, (sockaddr*)serAddr, sizeof(serAddr)); // ⑤ 发起连接send()1 作用:往TCP连接里“发数据”,把数据从本机发送到已经连接好的对端2 返回值:成功返回发送的字节数失败返回-13 参数:send(fd,要发送的数据的内存地址,len,0)要发送的数据的内存地址:如果是int netLen ,则为 netLen如果是string s,则为 s.c_str()len:要发送的字节数如果是int netLen ,则为 4如果是string s,则为 s.size()recv()1 作用:从TCP连接里 “收数据”.读取已连接socket上收到的数据阻塞时会一直等待直到有数据到来2 返回值:成功返回读到的字节数断开连接返回 0失败返回 -13 参数:与send类似,len的意义变为,最多可以接受的字节数常用:char buf[1024]{0};recv(fd,buf,datalen,0);流程客户端完整流程:plaintextsocket() → 创建客户端插座connect() → 【连接服务器】send() → 发数据你最开始的函数recv() → 收数据close() → 关闭连接