VS2017实现Tcp socket多线程通信（C++）

#include <stdio.h> #include <Winsock2.h> #include <stdlib.h> #include <process.h> #include <Ws2tcpip.h> #include "stdafx.h" void WorkThread(LPVOID ipParam) { SOCKET sClient = (SOCKET)ipParam; int ret; fd_set readSet; timeval tv; memset(&tv, 0, sizeof(tv)); tv.tv_sec = 8; char revData[1200]; while (true) { FD_ZERO(&readSet); FD_SET(sClient, &readSet); ret = select(0, &readSet, NULL, NULL, &tv); if (ret == SOCKET_ERROR) { printf("select:%d\n", WSAGetLastError()); closesocket(sClient); break; } if (ret == 0) { closesocket(sClient); continue; } if (FD_ISSET(sClient, &readSet)) { memset(revData, 0, 1200); ret = recv(sClient, revData, 1200, 0); if (ret == SOCKET_ERROR) { printf("recv:%d\n", WSAGetLastError()); closesocket(sClient); continue; } if (ret > 0) { revData[ret] = 0x00; printf(revData); } char sendData[] = "Hello,Client!\n"; send(sClient, sendData, strlen(sendData), 0); closesocket(sClient); } } closesocket(sClient); } int main(int argc, char*argv[]) { WSADATA wsaData; if (WSAStartup(MAKEWORD(2, 2), &wsaData) == SOCKET_ERROR) { printf("Failed to load Winsock.\n"); return -1; } SOCKET sListen = socket(AF_INET, SOCK_STREAM, 0); if (sListen == INVALID_SOCKET) { printf("socket( ) Failed: %d\n", WSAGetLastError()); WSACleanup(); closesocket(sListen); } struct sockaddr_in sin; sin.sin_family = AF_INET; sin.sin_port = htons(5060); sin.sin_addr.S_un.S_addr = htonl(INADDR_ANY); if ((bind(sListen, (struct sockaddr *)&sin, sizeof(sin))) == SOCKET_ERROR) { printf("bind( ) Failed: %d\n", WSAGetLastError()); closesocket(sListen); WSACleanup(); closesocket(sListen); } if ((listen(sListen, 5)) == SOCKET_ERROR) { printf("listen( ) Failed: %d\n", WSAGetLastError()); closesocket(sListen); WSACleanup(); } SOCKET sClient; while (true) { printf("Waiting for connection��\n"); sClient = accept(sListen, NULL, NULL); if (sClient == INVALID_SOCKET) { printf("accept() Failed: %d\n", WSAGetLastError()); continue; } else { HANDLE hThread = (HANDLE)_beginthread(WorkThread, 0, (LPVOID)sClient); if (!hThread) { continue; } } } closesocket(sListen); WSACleanup(); return 0; }