目录

前言：

场景：

原因：

解决：

方案2具体细节：

纯C++服务端处理如下：

Qt客户端处理如下：

---

前言：

        tcp协议里面，除了心跳检测是关于长连接操作的处理，这个在前一篇已经提到过了，这一篇将会对tcp本身的一个问题，进行处理：那就是做网络通信大概率会遇到的问题，粘包、拆包问题，碰到这类问题对于新手来说都是比较棘手的，需要好好处理一下。

场景：

        使用tcp协议的时候：

        1、我明明发单个小包，都很正常呀，没啥问题呀，怎么我对单个小包多发几次，频率快一些，就会数据错乱了；

        2、我明明发小包都好着，怎么发打包就不行了，很奇怪呢？

        其实这2个场景你用抓包工具一抓，分析一下封包内容，就会一目了然。

原因：

        最本质的原因是tcp协议发送数据的时候，是不会告诉对方当前发送的数据包有多大的，这是协议头决定的，如果接收端用一个很大的缓冲区来接收发送端的小包的时候，就有可能一下子接收到多个小包，从而导致粘包现象；如果用一个较小的缓冲区来接收发送端的较大的数据包，也会导致一个包收不完，得分好多次才能接收完，导致拆包现象；

解决：

        要解决粘包或者拆包问题， 有如下几个方案；

        方案1：可以给数据包前后加上一些特殊标识，用来区分头尾，这个方案的缺陷是必须找好特殊标识，万一数据内容也包含特殊标识，就会导致解包错误；

        方案2：可以给数据包加上一个数据头，在数据头里面加上一个长度信息来表示整个封包的长度，通过长度来进行收包和解包；这个方案的操作是把整个包看成两部分，数据头+数据体；先收数据头，取出长度来开辟指定长度的缓冲区，先把数据头拷贝到缓冲区，接着再把剩余的数据体内容接收到缓冲区剩余区域里即可。

        方案3：可以把方案1、方案2结合起来，不过方案还是过于复杂，但也相对安全。

下面就以方案2来进行代码演示：

方案2具体细节：

        1、由于是C++实现的，可以给应用层封装一个私有协议，那就使用结构体来作为私有协议。

结构体声明如下：

enum TypeInfo
{HEART_CHECK_REQ, // 心跳检测请求HEART_CHECK_RES, // 心跳检测响应LOGIN_REQ, // 登录请求LOGIN_RES, // 登录响应UPLOAD_REQ, // 文件上传请求UPLOAD_RES, // 文本上传响应
};struct Head
{int flag;int type;int len;
};struct HeartCheckReq
{Head head;HeartCheckReq(){head.flag = 0; // 0 表示软件客户端，1表示硬件客户端head.type = HEART_CHECK_REQ;head.len = sizeof(HeartCheckReq);}
};struct HeartCheckRes
{Head head;HeartCheckRes() {head.flag = 0;head.type = HEART_CHECK_RES;head.len = sizeof(HeartCheckRes);}
};

纯C++服务端处理如下：

收包线程函数代码：

void ServerSocket::recvAndSendThread(SOCKET client)
{// 循环收发包，保存长连接通信while (true){/*char buffer[1024] = { 0 };int len_recv = recv(client, buffer, sizeof(buffer), 0);cout << "len_recv:" << len_recv << endl;if (len_recv <= 0) {cout << "socket收包异常:" << WSAGetLastError() << endl;break;}*/// 解决粘包或拆包问题char *head_buffer = new char[sizeof(Head)];int len_recv = recv(client, head_buffer, sizeof(Head), 0);int head_rest = sizeof(Head) - len_recv;while (head_rest > 0) { // 还有没收完的len_recv = recv(client, head_buffer+ (sizeof(Head) - head_rest),head_rest , 0);head_rest -= len_recv;}// 表示结构体头收完了,可以拿出总长度int len_total = ((Head*)head_buffer)->len;char *buffer = new char[len_total];memcpy(buffer, head_buffer, sizeof(Head)); // 先把数据头拷贝进去int len_rest = len_total - sizeof(Head); // 算出剩余长度while (len_rest > 0) {len_recv = recv(client, buffer + (len_total - len_rest), len_rest, 0);len_rest -= len_recv;}// 正常m_clientSockets[client] = HEART_CHECK_TIMES; // 重置心跳阈值cout << "buffer:" << buffer << endl;int type = ((Head*)buffer)->type;if (type == 100) {Data *d = (Data*)buffer;cout << "收到内容:" << d->data << endl;}else if (type == HEART_CHECK_REQ) {// 收到心跳包// 回一个响应包cout << "收到心跳请求包" << endl;HeartCheckRes res;send(client, (char*)&res, res.head.len, 0);}else if (type == UPLOAD_REQ) {// 上传版本文件cout << "收到版本管理上传文件包" << endl;UploadFileReq *req = (UploadFileReq*)buffer;cout << req->file_info.file_name << " md5:" << req->file_info.md5 << " size:" << req->file_info.file_size << endl<< " old:" << req->file_info.old_version << endl;// 服务端的业务：将文件写到指定目录，并且在数据库中记录相应的信息// 保存了之后，回一个响应包给客户端UploadFileManager upload;upload.business(client, req);}// 将收到的数据原封不动的回给客户端// send(client, buffer, len_recv, 0);// 释放内存,防止内存泄露delete[] head_buffer;delete[] buffer;head_buffer = nullptr;buffer = nullptr;}closesocket(client); // 关闭客户端套接字
}

Qt客户端处理如下：

收包槽函数代码：

        这里要注意的是，Qt的网络通信是异步的，不能像纯windows服务端那样，使用recv来阻塞收包，所以采用了一个全局变量来存储数据包，当然也可以考虑使用静态局部变量或者成员变量来处理，本文为了表示得更加直白，选择使用了全局变量 g_allBuffer。

QByteArray g_allBuffer; // 全局缓冲区，用来保存收到的封包内容
void TcpMainWindow::myRead()
{QByteArray buffer =  m_client->readAll();g_allBuffer.append(buffer);int len = g_allBuffer.size();while(len > 0){if(len < sizeof(Head)) break; // 不满足数据头大小，继续收包int len_total = ((Head*)(g_allBuffer.data()))->len;if(len < len_total) break; // 不满足全部大小，继续收包QByteArray datas = g_allBuffer.left(len_total);  // 可能会收到多个，先拿一个出来出来emit unpackSignal(datas);g_allBuffer = g_allBuffer.mid(len_total); // 处理完了，将后面的挪到前面来len = g_allBuffer.size();}
}

 解包业务槽代码如下：

void TcpMainWindow::unpackSlot(QByteArray buffer)
{QString buf = buffer;ui->label->setText(buf);m_heartCheckTimes = HEART_CHECK_TIMES; // 重置阈值int type = ((Head*)buffer.data())->type;if(type == 100){Data *d = (Data*)buffer.data();qDebug()<<"收到:"<<d->data;buf = d->data;ui->label->setText(buf);}else if(type == HEART_CHECK_RES){// 收到心跳响应包qDebug()<<"收到心跳响应包";}
}

最后，以上只提供了核心代码，哪里有不清楚的，可以留言谈论一些细节，也可以关注后私信给回复，可以发完整工程代码。