Microsoft Visual C++:
| Код |
DWORD WINAPI ClientThread(LPVOID lpParam)
{
SOCKET sock=(SOCKET)lpParam;
char szRecvBuff[1024],
szSendBuff[1024];
int ret;
while(1)
{
ret = recv(sock, szRecvBuff, 1024, 0);
if (ret == 0)
break;
else if (ret == SOCKET_ERROR)
{
MessageBox(0, "Recive data filed", "Error", 0);
break;
}
szRecvBuff[ret] = '\0';
strcpy(szSendBuff, "Command get OK");
ret = send(sock, szSendBuff, sizeof(szSendBuff), 0);
if (ret == SOCKET_ERROR)
{
break;
}
}
return 0;
}
DWORD WINAPI NetThread(LPVOID lpParam)
{
SOCKET sServerListen;
SOCKET sClient;
struct sockaddr_in localaddr;
struct sockaddr_in clientaddr;
HANDLE hThread;
DWORD dwThreadId;
int iSize;
sServerListen = socket(AF_INET, SOCK_STREAM, IPPROTO_IP);
if (sServerListen == SOCKET_ERROR)
{
MessageBox(0, "Can't load WinSock", "Error", 0);
return 0;
}
localaddr.sin_addr.s_addr = htonl(INADDR_ANY);
localaddr.sin_family = AF_INET;
localaddr.sin_port = htons(5050);
if (bind(sServerListen, (struct sockaddr *)&localaddr,
sizeof(localaddr)) == SOCKET_ERROR)
{
MessageBox(0, "Can't bind", "Error", 0);
return 1;
}
MessageBox(0, "Bind OK", "Error", 0);
listen(sServerListen, 4);
MessageBox(0, "Listen OK", "Error", 0);
while (1)
{
iSize = sizeof(clientaddr);
sClient = accept(sServerListen, (struct sockaddr *)&clientaddr,
&iSize);
if (sClient == INVALID_SOCKET)
{
MessageBox(0, "Accept filed", "Error", 0);
break;
}
hThread = CreateThread(NULL, 0, ClientThread,
(LPVOID)sClient, 0, &dwThreadId);
if (hThread == NULL)
{
MessageBox(0, "Create thread filed", "Error", 0);
break;
}
CloseHandle(hThread);
}
closesocket(sServerListen);
return 0;
}
|
|
