粘包问题已经在上一篇博客中写到具体可以看-----------
以下是利用分包解决粘包问题的步骤:
-
消息长度前缀: 在每个数据包前加入消息长度信息。
-
定义协议格式: 明确定义通信协议的格式,包括消息头和消息体。
-
封包: 将数据按照协议格式封装成完整的数据包。
-
解包: 根据协议格式从接收到的字节流中解析出完整的数据包。
-
处理残余数据: 保留可能存在的残余数据,并在下一次接收到数据时继续解析。
-
错误处理: 考虑数据包丢失、损坏或乱序等特殊情况,实现相应的错误处理机制。
-
测试和优化: 进行测试以确保系统在不同条件下正常运行,优化协议和分包处理性能
怎么解决粘包问题呢,其实借鉴一下tcp报文段的组成(分成TCP数据部分和TCP首部),我们也可以把发送的数据分为两个部分,一个是data,一个是data_len,这样有了data_len之后可以保证接收到完整的data数据后不再接受数据,这样就解决了粘包的问题。
看见如下图,client端发送的hi 和 jack没有粘在一块成hijack:
server:
int total_len=0;
int len=0;
char buffer[1024];
while ((len=read(client_sock,buffer+total_len,sizeof(buffer)-total_len))>0)
{
total_len+=len;
while (total_len>=sizeof(int))
{
int data_len=*(int *)buffer;
if(total_len>=sizeof(int)+data_len)
{
char data[1024];
memmove(data,buffer+sizeof(int),data_len);
data[data_len]='\0';
std::cout<<"Received msg :"<<data<<std::endl;
total_len-=sizeof(int)+data_len;
memmove(buffer,buffer+sizeof(int)+data_len,total_len);
}
else{
break;
}
}
}
client:
std::string msg1="hi";
std::string msg2="jack";
char data1[256];
*(int*)(data1)=msg1.length();
int len=sizeof(int);
memmove(data1+len,msg1.c_str(),msg1.length());
if(write(client_sock,data1,len+msg1.length())==-1){
std::cerr<<"Faild to write "<<std::endl;
return -1;
}
char data2[256];
*(int*)(data2)=msg2.length();
int len2=sizeof(int);
memmove(data2+len,msg2.c_str(),msg2.length());
if(write(client_sock,data2,len2+msg2.length())==-1){
std::cerr<<"Faild to write "<<std::endl;
return -1;
}