读书人

关于I/O复用 select的函数的疑义

发布时间: 2012-11-08 08:48:12 作者: rapoo

关于I/O复用 select的函数的疑问
这个是我在UNIX网络编程中对于IO复用select函数作为TCP服务器的一段代码,有点懵了。。。

C/C++ code
int main(int argc, char *argv){    int                   i, maxi, maxfd, listenfd, connfd, sockfd;    int                   nready, client[FD_SETSIZE];        ssize_t               n;    fd_set                rest, allrest;    char                  buf[512];    socklen_t             clilen;    struct sockaddr_in    cliaddr, servaddr;        listenfd = socket(AF_INET, SOCK_STREAM, 0);        bzero(&servaddr, sizeof(servaddr));     servaddr.sin_family = AF_INET;    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);    servaddr.sin_port = htons(SERV_PORT);          bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr));    listen(listenfd, 5);      maxfd = listenfd; /* 初始化 */    maxi = -1;            for (i = 0; i < FD_SETSIZE; i++)    {        client[i] = -1;        }      FD_ZERO(&allrest);    FD_SET(listenfd, &allrest); /* 告诉内核,我们需要对哪些描述字进行测试 */      for (; ;)    {         rest = allrest;              nready = select(maxfd+1, &rest, NULL, NULL, NULL);               if (FD_ISSET(listenfd, &rest)) /* 返回后, rest结构中的内容被重写,任何未就绪的描述字被置为0 */        {            clilen = sizeof(cliaddr);         connfd = accept(listenfd, (struct sockaddr *)&cliaddr, &clilen);                          for (i=0; i < FD_SETSIZE; i++)         {             if (client[i] < 0)             {            client[i] = connfd;            break;                  }              }                      if (i == FD_SETSIZE)        return -1;                      FD_SET(connfd, &allrest);         if (connfd > maxfd)        maxfd = connfd;                            if (i > maxi)        maxi = i;                            if (--nready <= 0)        {        continue;        }                          }            for (i = 0; i < maxi; i++)      {          printf("44444444\n");          if ((sockfd = client[i]) < 0)          continue;                        if (FD_ISSET(sockfd, &rest))           {          printf("55555555555\n");          if ((n = read(sockfd, buf, 512)) == 0)          {              close(sockfd);              FD_CLR(sockfd, &allrest);                  client[i] = -1;                }           else           {                write(sockfd, buf, n);               }                         if (--nready <= 0)               break;           }            }    }}


按我的理解应该是这样的:
TCP服务器开启后,首先allrest里面只有listenfd, 故select()阻塞,等待listenfd就绪。
TCP客户开启,listenfd就绪,故select()返回,此时,nready应该为1,而rest里面对应的listenfd比特位为1。
故执行if (FD_ISSET(listenfd, &rest))里面的语句,接着accept()创建一个connfd,并将此加入到client[]里面,且执行FD_SET(connfd, &allrest)将allrest字符集的connfd比特位打开。接着记录最大maxfd值为下次的select()最准备,将client[]里面的记录数的最大下标值赋给maxi。此时,--nready = 0,故跳出本次循环,接着下次的循环。于是返回最上面执行 rest = allrest,而此时的allrest里面有先前的listenfd,还有后面的connfd,故此时的rest打开了listenfd和connf位的比特位,意味着接下来调用的select()函数将阻塞于监听描述字和已建立好的客户套接口描述字上,于是在等待两者任何一个就绪。
不知道这么理解对不对?

可是问题来了,当上述条件都完成之后,我就在客户端输入并返给服务器端时,并没有反应啊,也就是说没有执行for (i = 0; i < maxi; i++)里面的语句,按道理应该是:
我客户端有了输入并发送给了服务器,那么再服务器的select()将要返回吧,并且if (FD_ISSET(sockfd, &rest)) 也成立啊?
很奇怪诶?!

[解决办法]
nready = select(maxfd+1, &rest, NULL, NULL, NULL);

这句话在for(;;)中,maxfd会被select悄悄的改变。所以,每次select的时候maxfd不一定是你原来的

读书人网 >UNIXLINUX

热点推荐