我有以下代码,我不确定为什么它不能正常工作。
它是一个多线程 TCP 服务器,循环 accept() 调用并触发指定的
每次线程。
问题是接受有时不会阻塞,从而导致
当理论上没有连接时打开一个新线程的程序。
这就是循环 -
for (dwI = 0;; dwI++) //Accept MAX_CLIENTS connections
{
if(MAX_CLIENTS == dwI)
{
dwI=0;
continue;
}//if
if(clients[dwI].bIsInUse)
{
continue;
}//if
ZeroMemory(&from,sizeof(from));
if(!AcceptConnection(&ServerSock,&from,&ClientSock))
{
PRINT_LE("AcceptConnection",ERROR_ACCEPT_SERVER_CONNECTION);
closesocket(ServerSock);
WSACleanup();
return EXIT_FAILURE;
}//if
clients[dwI].ClientSock = ClientSock;
if(! (clients[dwI].hThread = CreateThread(
NULL, //Not inheritable
0, //Default stack size
ThreadedAcceptTCP, //ThreadedAccept - function
&clients[dwI],//Pass pointer to the socket
0, //Start immidiately
&clients[dwI].dwThreadId //Save thread id
)))
{
PRINT_GLE("CreateThread");
closesocket(ServerSock);
WSACleanup();
return EXIT_FAILURE;
}//if
#ifdef PRINT_STATUS //Print status if macro is defined
printf("Server responce message has been sent.\n");
#endif
}//for
每个函数都有我自己的包装器。
AcceptConnection 具有以下代码 -
SOCKET ClientSocket = INVALID_SOCKET; //Client socket
INT sockaddrSize = sizeof(*pSockAddr);
ClientSocket = accept( //Create client accepting socket
*pSock, //Listen-ed socket
pSockAddr,
&sockaddrSize
);
if (INVALID_SOCKET == ClientSocket) //Check for errors - if any - cleanup and return failure
{
PRINT_WSAGLE("socket");
return FAILURE;
}//if
*pClientSock = ClientSocket; //Pass socket
return SUCCESS;
当我通过浏览器连接到服务器时出现问题,
例如 ,
在第一个线程完成后(我已经通过暂时休眠主线程 5 秒来确保这一点)
它清理一切并关闭客户端套接字,
虽然在第二次接受呼叫 - 它会以相同的方式返回
SOCKADDR 信息并导致一个额外的线程上去,
接收完全相同的数据,发送完全相同的数据。
并打印 2 次(有时甚至更多)次:
“服务器响应消息已发送。”
我无法弄清楚为什么会发生这种情况,希望你们能帮助我。
谢谢 !