简介
本文向大家介绍一个C++实战项目：手把手教你了解并解决TCP粘包问题。通过该实战项目可以了解TCP粘包问题产生的原因及解决方式，具有一定的C++实战价值，感兴趣的朋友可以参考一下。
什么时候需要考虑粘包问题
1).如果利用tcp每次发送数据，就与对方建立连接，然后双方发送完一段数据后，就关闭连接，这样就不会出现粘包问题（因为只有一种包结构,类似于http协议）。关闭连接主要要双方都发送close连接（参考tcp关闭协议）。如：A需要发送一段字符串给B，那么A与B建立连接，然后发送双方都默认好的协议字符如"hello give me sth abour yourself"，然后B收到报文后，就将缓冲区数据接收,然后关闭连接，这样粘包问题不用考虑到，因为大家都知道是发送一段字符；
2).如果发送数据无结构，如文件传输，这样发送方只管发送，接收方只管接收存储就ok，也不用考虑粘包；
3).如果双方建立连接，需要在连接后一段时间内发送不同结构数据，如连接后，有好几种结构：
1) "hello give me sth abour yourself"
2) "Don't give me sth abour yourself"
那这样的话，如果发送方连续发送这个两个包出去，接收方一次接收可能会是
hello give me sth abour yourselfDon't give me sth abour yourself
这样接收方就傻了，到底是要干嘛？不知道，因为协议没有规定这么诡异的字符串，所以要处理把它分包，怎么分也需要双方组织一个比较好的包结构，所以一般可能会在头加一个数据长度之类的包，以确保接收。
粘包问题出现原因
在流传输中出现，UDP不会出现粘包，因为它有消息保护边界。
DWORD WINAPI ThreadFun(LPVOID lpThreadParameter)
SOCKET sock = (SOCKET)lpThreadParameter;
cout << "客户端 " << sock << " 连接成功！" << endl;
::Sleep(1000);
char buf[] = "服务器：C++实战网(www.cppszw.com)\n";
// 这里多次发送以便实现产生TCP粘包问题
for (int i = 1; i < 11; ++i)
if (SendMsg(sock, buf))
printf("%d：发送数据成功......\n", i);
printf("%d：发送数据失败......\n", i);
while (1)
char recvBuf[100];
memset(recvBuf, 0, sizeof(recvBuf));
// 接收数据
int ret = recv(sock, recvBuf, sizeof(recvBuf), 0);
if (ret == SOCKET_ERROR || ret == 0)
cout << sock << "断开了连接！" << endl;
break;
cout << sock << " 收到数据: " << recvBuf << endl;
return 0;
// 发送数据
bool SendMsg(SOCKET sock, char* pMsg)
if (INVALID_SOCKET == sock)
return false;
if (pMsg[0] == '\0')
return false;
bool bRet = true;
if (SOCKET_ERROR == send(sock, pMsg, strlen(pMsg) + 1, 0))
bRet = false;
return bRet;
运行后截图如下：
memset(recv_buf, 0, MSG_BUF_SIZE);
if (m_tcpClientHelper.RecvData(recv_buf, MSG_BUF_SIZE))
WriteLog("TCP消息 接收：%s", recv_buf);
WriteLog("系统检测到TCP异常断开...");
DisConnect();
运行后截图如下：
memset(sendMsgLen, 0, 4);
sendMsgLen[0] = (BYTE)(iMsgLen);
sendMsgLen[1] = (BYTE)(iMsgLen >> 8);
sendMsgLen[2] = (BYTE)(iMsgLen >> 16);
sendMsgLen[3] = (BYTE)(iMsgLen >> 24);
int iBytesLen = MSG_HEAD_SIZE + iMsgLen;
// 字节拼接
BYTE* pBData = new BYTE[iBytesLen];
for (int i = 0; i < 6; ++i)
pBData[i] = m_sendHead[i];
for (int i = 0; i < 4; ++i)
pBData[6 + i] = sendMsgLen[i];
for (int i = 0; i < iMsgLen; ++i)
pBData[MSG_HEAD_SIZE + i] = pMsg[i];
bool bRet = true;
if (SOCKET_ERROR == send(sock, (char*)pBData, iBytesLen, 0))
bRet = false;
delete[] pBData;
return bRet;
客户端接收部分代码如下：
if (recv_buf[0] == 'c'&&recv_buf[1] == 'p'&&recv_buf[2] == 'p'&&recv_buf[3] == 's'&&recv_buf[4] == 'z'&&recv_buf[5] == 'w')
int iPos = 0;
while (iPos <= MSG_BUF_SIZE)
// 获取当前消息长度
int iMsgLen = 0;
memcpy(&iMsgLen, &recv_buf[iPos + 6], 4);
int iPacketSize = iMsgLen + MSG_HEAD_SIZE;
if (iPacketSize < MSG_BUF_SIZE - iPos)
ParseTCPMsg(recv_buf, iPos, iMsgLen);
// 数据完整
if (recv_buf[iPos + iPacketSize] == '\0')
break;
// 粘包 作拆包处理
iPos += iPacketSize;
// 拷贝到不完整包
memcpy(&packet[iLen], &recv_buf[iPos], MSG_BUF_SIZE - iPos);
iLen += (MSG_BUF_SIZE - iPos);
break;
运行结果如下：
站点声明：
1、欢迎大家访问本站，如需转载文章请注明出处，尊重他人劳动成果及原作者版权，未经许可不得用于任何商业目的。
2、本站提供的内容部分收集整理于互联网，如有侵权，请联系站长进行删除处理。举报邮箱：cppszw@163.com。
3、由于运营成本高昂，本站接入广告联盟，若广告给您带来困扰，敬请谅解。
Rights Reserved. 备案号：粤ICP备2022073185号
