int select(int maxfdp,fd_set *readfds,fd_set *writefds,fd_set *errorfds,struct timeval *timeout);/*参数列表
int maxfdp是一个整数值，是指集合中所有文件描述符的范围，即所有文件描述符的最大值加1，不能错！在Windows中这个参数的值无所谓，可以设置不正确。 fd_set *readfds是指向fd_set结构的指针，这个集合中应该包括文件描述符，我们是要监视这些文件描述符的读变化的，即我们关心是否可以从这些文件中读取数据了，如果这个集合中有一个文件可读，select就会返回一个大于0的值，表示有文件可读，如果没有可读的文件，则根据timeout参数再判断是否超时，若超出timeout的时间，select返回0，若发生错误返回负值。可以传入NULL值，表示不关心任何文件的读变化。 fd_set *writefds是指向fd_set结构的指针，这个集合中应该包括文件描述符，我们是要监视这些文件描述符的写变化的，即我们关心是否可以向这些文件中写入数据了，如果这个集合中有一个文件可写，select就会返回一个大于0的值，表示有文件可写，如果没有可写的文件，则根据timeout参数再判断是否超时，若超出timeout的时间，select返回0，若发生错误返回负值。可以传入NULL值，表示不关心任何文件的写变化。 fd_set *errorfds同上面两个参数的意图，用来监视文件错误异常。 struct timeval* timeout是select的超时时间，这个参数至关重要，它可以使select处于三种状态：
第一，若将NULL以形参传入，即不传入时间结构，就是将select置于阻塞状态，一定等到监视文件描述符集合中某个文件描述符发生变化为止；
第二，若将时间值设为0秒0毫秒，就变成一个纯粹的非阻塞函数，不管文件描述符是否有变化，都立刻返回继续执行，文件无变化返回0，有变化返回一个正值；
第三，timeout的值大于0，这就是等待的超时时间，即 select在timeout时间内阻塞，超时时间之内有事件到来就返回了，否则在超时后不管怎样一定返回，返回值同上述。
*/

/*
返回值： 

负值：select错误正值：某些文件可读写或出错0：等待超时，没有可读写或错误的文件
*/

#include <winsock.h> #include <stdio.h> #define PORT       5150 #define MSGSIZE     1024 #pragma comment(lib, "ws2_32.lib") int     g_iTotalConn = 0; SOCKET g_CliSocketArr[FD_SETSIZE]; DWORD WINAPI WorkerThread(LPVOID lpParameter); int main() {   WSADATA     wsaData;   SOCKET       sListen, sClient;   SOCKADDR_IN local, client;   int         iaddrSize = sizeof(SOCKADDR_IN);   DWORD       dwThreadId;   // Initialize Windows socket library
         WSAStartup(0x0202, &wsaData);   // Create listening socket
         sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);   // Bind
         local.sin_addr.S_un.S_addr = htonl(INADDR_ANY); local.sin_family = AF_INET; local.sin_port = htons(PORT);   bind(sListen, (struct sockaddr *)&local, sizeof(SOCKADDR_IN));   // Listen   listen(sListen, 3);   // Create worker thread
         CreateThread(NULL, 0, WorkerThread, NULL, 0, &dwThreadId);     while (TRUE)   {               // Accept a connection
             sClient = accept(sListen, (struct sockaddr *)&client, &iaddrSize);     printf("Accepted client:%s:%d\n", inet_ntoa(client.sin_addr), ntohs(client.sin_port));     // Add socket to g_CliSocketArr
             g_CliSocketArr[g_iTotalConn++] = sClient;   }     return 0; } DWORD WINAPI WorkerThread(LPVOID lpParam) {   int             i;   fd_set         fdread;   int             ret;   struct timeval tv = {1, 0};   char           szMessage[MSGSIZE];     while (TRUE)   {     FD_ZERO(&fdread);     for (i = 0; i < g_iTotalConn; i++) { FD_SET(g_CliSocketArr, &fdread); }                     // We only care read event
             ret = select(0, &fdread, NULL, NULL, &tv); if (ret == 0) {       // Time expired
                 continue; } for (i = 0; i < g_iTotalConn; i++) { if (FD_ISSET(g_CliSocketArr, &fdread)) {         // A read event happened on g_CliSocketArr
                       ret = recv(g_CliSocketArr, szMessage, MSGSIZE, 0); if (ret == 0 || (ret == SOCKET_ERROR && WSAGetLastError() == WSAECONNRESET)) { // Client socket closed
                             printf("Client socket %d closed.\n", g_CliSocketArr); closesocket(g_CliSocketArr); if (i < g_iTotalConn - 1) { g_CliSocketArr[i--] = g_CliSocketArr[--g_iTotalConn]; } } else { // We received a message from client
                               szMessage[ret] = '\0'; send(g_CliSocketArr, szMessage, strlen(szMessage), 0); } } //if
             }//for
         }//while
         return 0; } 

int CALLBACK ConditionFunc(LPWSABUF lpCallerId,LPWSABUF lpCallerData, LPQOS lpSQOS,LPQOS lpGQOS,LPWSABUF lpCalleeId, LPWSABUF lpCalleeData,GROUP FAR *
g,DWORD dwCallbackData)
{
　　if (当前连接数 < FD_SETSIZE)
　　　　return CF_ACCEPT;
　　else
　　　　return CF_REJECT;
}