服务器端代码 server.cpp:
- #include <stdio.h>
- #include <windows.h>
- #pragma comment (lib, "ws2_32.lib")
-
- #define BUF_SIZE 100
-
- int main(){
- WSADATA wsaData;
- WSAStartup( MAKEWORD(2, 2), &wsaData);
-
- SOCKET servSock = socket(AF_INET, SOCK_STREAM, 0);
-
- struct sockaddr_in sockAddr;
- memset(&sockAddr, 0, sizeof(sockAddr));
- sockAddr.sin_family = PF_INET;
- sockAddr.sin_addr.s_addr = inet_addr("127.0.0.1");
- 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);
-
- int recvLen = recv(clntSock, buffer, BUF_SIZE, 0);
- send(clntSock, buffer, recvLen, 0);
-
- 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")
-
- #define BUF_SIZE 100
-
- int main(){
- WSADATA wsaData;
- WSAStartup(MAKEWORD(2, 2), &wsaData);
-
- struct sockaddr_in sockAddr;
- memset(&sockAddr, 0, sizeof(sockAddr));
- 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();
-
- 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() 却只接收到一个数据包,这很好的说明了数据的粘包问题。