1. <wbr id="m8vu6"></wbr>

      <del id="m8vu6"><center id="m8vu6"><source id="m8vu6"></source></center></del>
        <p id="m8vu6"><sub id="m8vu6"></sub></p>

        VB.net 2010 視頻教程 VB.net 2010 視頻教程 VB.net 2010 視頻教程
        SQL Server 2008 視頻教程 c#入門經典教程 Visual Basic從門到精通視頻教程
        當前位置:
        首頁 > 硬件網絡 > 網絡工程師 >
        • TCP協議的粘包問題(數據的無邊界性)

        • 2019-11-13 20:51 來源:未知
        上節我們講到了socket緩沖區和數據的傳遞過程,可以看到數據的接收和發送是無關的,read()/recv() 函數不管數據發送了多少次,都會盡可能多的接收數據。也就是說,read()/recv() 和 write()/send() 的執行次數可能不同。

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

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

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

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

        服務器端代碼 server.cpp:
        
        		
        1. #include <stdio.h>
        2. #include <windows.h>
        3. #pragma comment (lib, "ws2_32.lib") //加載 ws2_32.dll
        4.  
        5. #define BUF_SIZE 100
        6.  
        7. int main(){
        8. WSADATA wsaData;
        9. WSAStartup( MAKEWORD(2, 2), &wsaData);
        10.  
        11. //創建套接字
        12. SOCKET servSock = socket(AF_INET, SOCK_STREAM, 0);
        13.  
        14. //綁定套接字
        15. sockaddr_in sockAddr;
        16. memset(&sockAddr, 0, sizeof(sockAddr)); //每個字節都用0填充
        17. sockAddr.sin_family = PF_INET; //使用IPv4地址
        18. sockAddr.sin_addr.s_addr = inet_addr("127.0.0.1"); //具體的IP地址
        19. sockAddr.sin_port = htons(1234); //端口
        20. bind(servSock, (SOCKADDR*)&sockAddr, sizeof(SOCKADDR));
        21.  
        22. //進入監聽狀態
        23. listen(servSock, 20);
        24.  
        25. //接收客戶端請求
        26. SOCKADDR clntAddr;
        27. int nSize = sizeof(SOCKADDR);
        28. char buffer[BUF_SIZE] = {0}; //緩沖區
        29. SOCKET clntSock = accept(servSock, (SOCKADDR*)&clntAddr, &nSize);
        30.  
        31. Sleep(10000); //注意這里,讓程序暫停10秒
        32.  
        33. //接收客戶端發來的數據,并原樣返回
        34. int recvLen = recv(clntSock, buffer, BUF_SIZE, 0);
        35. send(clntSock, buffer, recvLen, 0);
        36.  
        37. //關閉套接字并終止DLL的使用
        38. closesocket(clntSock);
        39. closesocket(servSock);
        40. WSACleanup();
        41.  
        42. return 0;
        43. }
        客戶端代碼 client.cpp:
        
        		
        1. #include <stdio.h>
        2. #include <stdlib.h>
        3. #include <WinSock2.h>
        4. #include <windows.h>
        5. #pragma comment(lib, "ws2_32.lib") //加載 ws2_32.dll
        6.  
        7. #define BUF_SIZE 100
        8.  
        9. int main(){
        10. //初始化DLL
        11. WSADATA wsaData;
        12. WSAStartup(MAKEWORD(2, 2), &wsaData);
        13.  
        14. //向服務器發起請求
        15. sockaddr_in sockAddr;
        16. memset(&sockAddr, 0, sizeof(sockAddr)); //每個字節都用0填充
        17. sockAddr.sin_family = PF_INET;
        18. sockAddr.sin_addr.s_addr = inet_addr("127.0.0.1");
        19. sockAddr.sin_port = htons(1234);
        20.  
        21. //創建套接字
        22. SOCKET sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
        23. connect(sock, (SOCKADDR*)&sockAddr, sizeof(SOCKADDR));
        24.  
        25. //獲取用戶輸入的字符串并發送給服務器
        26. char bufSend[BUF_SIZE] = {0};
        27. printf("Input a string: ");
        28. gets(bufSend);
        29. for(int i=0; i<3; i++){
        30. send(sock, bufSend, strlen(bufSend), 0);
        31. }
        32. //接收服務器傳回的數據
        33. char bufRecv[BUF_SIZE] = {0};
        34. recv(sock, bufRecv, BUF_SIZE, 0);
        35. //輸出接收到的數據
        36. printf("Message form server: %s\n", bufRecv);
        37.  
        38. closesocket(sock); //關閉套接字
        39. WSACleanup(); //終止使用 DLL
        40.  
        41. system("pause");
        42. return 0;
        43. }
        先運行 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() 卻只接收到一個數據包,這很好的說明了數據的粘包問題。
        相關教程
        免费看成年人视频大全_免费看成年人视频在线观看