TCP粘包是指發送方發送的若干包數據到接收方接收時粘成一包,從接收緩沖區看,后一包數據的頭緊接著前一包數據的尾。
出現粘包現象的原因既可能由發送方造成,也可能由接收方造成。
發送方引起的粘包是由TCP協議本身造成的,TCP為提高傳輸效率,發送方往往要收集到足夠多的數據后才發送一包數據。若連續幾次發送的數據都很少,通常TCP會根據優化算法把這些數據合成一包后一次發送出去,這樣接收方就收到了粘包數據。
接收方引起的粘包是由于接收方用戶進程不及時接收數據,從而導致粘包現象。這是因為接收方先把收到的數據放在系統接收緩沖區,用戶進程從該緩沖區取數據,若下一包數據到達時前一包數據尚未被用戶進程取走,則下一包數據放到系統接收緩沖區時就接到前一包數據之后,而用戶進程根據預先設定的緩沖區大小從系統接收緩沖區取數據,這樣就一次取到了多包數據。
c++的解決方法如下:接收端
int iRecvSize = PackteSize + 10;
int iRet;
int idx = 0;
while (iRecvSize > 0)
{
iRet = recv(AcceptSocket, recvbuf+idx, iRecvSize, 0);
if (iRet > 0)
{
idx += iRet;
iRecvSize -= iRet;
}
else if (iRet == 0)
{
break;
}
else if ( iRet == SOCKET_ERROR)
{
break;
}
}
發送端:
int iSendSize = PacketSize + 10;
int iSent;
int idx = 0;
while (iSendSize > 0)
{
iSent = send(m_socket,sendbuffer+idx,iSendSize,0);
if (iSent > 0)
{
idx += iSent;
iSendSize -= iSent;
}
else if (iSent == 0)
{
break;
}
else if (iSent == SOCKET_ERROR)
{
wprintf(L"send failed with error: %d\n", WSAGetLastError());
//closesocket(m_socket);
//WSACleanup();
break;
}
}
若傳輸的數據為不帶結構的連續流數據(如文件傳輸),則不必把粘連的包分開(簡稱分包),反之則必須分包。
c#中用socket的Available成員來表示是否還有數據需要讀取,如果Available>0,表示還有數據需有讀取,反之讀取完成。
public class ConnectInfo
{
public ArrayList tmpList { get; set; }
public SocketAsyncEventArgs SendArg { get; set; }
public SocketAsyncEventArgs ReceiveArg { get; set; }
public Socket ServerSocket { get; set; }
public User user = new User();
}
if (client.Available > 0)
{
Console.WriteLine("粘包處理");
for (int i = 0; i < rec; i++)
info.tmpList.Add(datas[i]);
Array.Clear(datas, 0, datas.Length);
datas = new byte[client.Available];
e.SetBuffer(datas, 0, datas.Length);
client.ReceiveAsync(e);
}
else
{
//檢查暫存數據的ArrayList中有沒有數據,有就和本次的數據合并
if (info.tmpList.Count > 0)
{
for (int i = 0; i < rec; i++)
info.tmpList.Add(datas[i]);
datas = info.tmpList.ToArray(typeof(byte)) as byte[];
rec = datas.Length;
}
//對接收的完整數據進行處理
}
半包顧名思義,就不是一個完整的包,tcp發出一個段后,它啟動一個定時器,等待目的端確認收到這個報文段。如果不能及時收到一個確認,將重發這個報文段。
常見的解決方法就是制定規范的數據傳輸格式。