上節我們講到了socket緩沖區和數據的傳遞過程，可以看到數據的接收和發送是無關的，read()/recv() 函數不管數據發送了多少次，都會盡可能多的接收數據。也就是說，read()/recv() 和 write()/send() 的執行次數可能不同。

例如，write()/send() 重復執行三次，每次都發送字符串"abc"，那么目標機器上的 read()/recv() 可能分三次接收，每次都接收"abc"；也可能分兩次接收，第一次接收"abcab"，第二次接收"cabc"；也可能一次就接收到字符串"abcabcabc"。

假設我們希望客戶端每次發送一位學生的學號，讓服務器端返回該學生的姓名、住址、成績等信息，這時候可能就會出現問題，服務器端不能區分學生的學號。例如第一次發送 1，第二次發送 3，服務器可能當成 13 來處理，返回的信息顯然是錯誤的。

這就是數據的“粘包”問題，客戶端發送的多個數據包被當做一個數據包接收。也稱數據的無邊界性，read()/recv() 函數不知道數據包的開始或結束標志（實際上也沒有任何開始或結束標志），只把它們當做連續的數據流來處理。

下面的代碼演示了粘包問題，客戶端連續三次向服務器端發送數據，服務器端卻一次性接收到所有數據。

服務器端代碼 server.cpp：

#include <stdio.h>

#include <windows.h>

#pragma comment (lib, "ws2_32.lib") //加載 ws2_32.dll

?

#define BUF_SIZE 100

?

int main(){

WSADATA wsaData;

WSAStartup( MAKEWORD(2, 2), &wsaData);

?

//創建套接字

SOCKET servSock = socket(AF_INET, SOCK_STREAM, 0);

?

//綁定套接字

sockaddr_in sockAddr;

memset(&sockAddr, 0, sizeof(sockAddr)); //每個字節都用0填充

sockAddr.sin_family = PF_INET; //使用IPv4地址

sockAddr.sin_addr.s_addr = inet_addr("127.0.0.1"); //具體的IP地址

sockAddr.sin_port = htons(1234); //端口

bind(servSock, (SOCKADDR*)&sockAddr, sizeof(SOCKADDR));

?

//進入監聽狀態

listen(servSock, 20);

?

//接收客戶端請求

SOCKADDR clntAddr;

int nSize = sizeof(SOCKADDR);

char buffer[BUF_SIZE] = {0}; //緩沖區

SOCKET clntSock = accept(servSock, (SOCKADDR*)&clntAddr, &nSize);

?

Sleep(10000); //注意這里，讓程序暫停10秒

?

//接收客戶端發來的數據，并原樣返回

int recvLen = recv(clntSock, buffer, BUF_SIZE, 0);

send(clntSock, buffer, recvLen, 0);

?

//關閉套接字并終止DLL的使用

closesocket(clntSock);

closesocket(servSock);

WSACleanup();

?

return 0;

}

客戶端代碼 client.cpp：

#include <stdio.h>

#include <stdlib.h>

#include <WinSock2.h>

#include <windows.h>

#pragma comment(lib, "ws2_32.lib") //加載 ws2_32.dll

?

#define BUF_SIZE 100

?

int main(){

//初始化DLL

WSADATA wsaData;

WSAStartup(MAKEWORD(2, 2), &wsaData);

?

//向服務器發起請求

sockaddr_in sockAddr;

memset(&sockAddr, 0, sizeof(sockAddr)); //每個字節都用0填充

sockAddr.sin_family = PF_INET;

sockAddr.sin_addr.s_addr = inet_addr("127.0.0.1");

sockAddr.sin_port = htons(1234);

?

//創建套接字

SOCKET sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);

connect(sock, (SOCKADDR*)&sockAddr, sizeof(SOCKADDR));

?

//獲取用戶輸入的字符串并發送給服務器

char bufSend[BUF_SIZE] = {0};

printf("Input a string: ");

gets(bufSend);

for(int i=0; i<3; i++){

send(sock, bufSend, strlen(bufSend), 0);

}

//接收服務器傳回的數據

char bufRecv[BUF_SIZE] = {0};

recv(sock, bufRecv, BUF_SIZE, 0);

//輸出接收到的數據

printf("Message form server: %s\n", bufRecv);

?

closesocket(sock); //關閉套接字

WSACleanup(); //終止使用 DLL

?

system("pause");

return 0;

}

先運行 server，再運行 client，并在10秒內輸入字符串"abc"，再等數秒，服務器就會返回數據。運行結果如下：
Input a string: abc
Message form server: abcabcabc

本程序的關鍵是 server.cpp 第31行的代碼Sleep(10000);，它讓程序暫停執行10秒。在這段時間內，client 連續三次發送字符串"abc"，由于 server 被阻塞，數據只能堆積在緩沖區中，10秒后，server 開始運行，從緩沖區中一次性讀出所有積壓的數據，并返回給客戶端。

另外還需要說明的是 client.cpp 第34行代碼。client 執行到 recv() 函數，由于輸入緩沖區中沒有數據，所以會被阻塞，直到10秒后 server 傳回數據才開始執行。用戶看到的直觀效果就是，client 暫停一段時間才輸出 server 返回的結果。

client 的 send() 發送了三個數據包，而 server 的 recv() 卻只接收到一個數據包，這很好的說明了數據的粘包問題。

總結

以上是生活随笔為你收集整理的TCP协议的粘包问题（数据的无边界性）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。