如何在linux下使用udp中的select api

Question

 int CreateSocket()
 {
     socklen_t len;

   // Socket creation for UDP

   acceptSocket=socket(AF_INET,SOCK_DGRAM,0);

   if(acceptSocket==-1)

   {

     printf("Failure: socket creation is failed, failure code\n");

     return 1;

   }

   else

   {

     printf("Socket started!\n");

   }

 memset(&addr, 0, sizeof(addr));

 addr.sin_family=AF_INET;

 addr.sin_port=htons(port);

 addr.sin_addr.s_addr=htonl(INADDR_ANY);

 rc=bind(acceptSocket,(struct sockaddr*)&addr,sizeof(addr));

 if(rc== -1)

 {

     printf("Oh dear, something went wrong with bind()! %s\n", strerror(errno));

   return 1;

 }

 else

 {

   printf("Socket an port %d \n",port);
 }

   while(rc!=-1)
   {
       fd_set master;
       fd_set read_fds;
       int retval;
       FD_ZERO(&master);
       FD_ZERO(&read_fds);
       FD_SET(acceptSocket, &master);
       FD_SET(acceptSocket, &read_fds);
       retval =select(2, &master, NULL, NULL, NULL);
       len = sizeof(client);
       if(retval == -1)
       {
           printf("error\n");
       }
       else if(FD_ISSET (acceptSocket, &master))
       {
     rc=recvfrom(acceptSocket,buf, 256, 0, (struct sockaddr*) &client, &len);
     if(rc==0)
     {
       printf("Server has no connection..\n");
       break;
     }
     if(rc==-1)
     {
         printf("Oh dear, something went wrong with read()! %s\n", strerror(errno));
       break;
     }
     XcpIp_RxCallback( (uint16) rc, (uint8*) buf, (uint16) port );

       }

       else
       {
           makeTimer("First Timer", &firstTimerID, 2, 2);   //2ms
                             makeTimer("Second Timer", &secondTimerID, 10, 10);    //10ms
                             makeTimer("Third Timer", &thirdTimerID, 100, 100);  //100ms

       }


   }


   close(acceptSocket);



   return 0;
   }

上面是udp层通过ip地址和端口号接收客户端数据的服务器代码。我使用 select api 检查端口是否有数据，然后接收数据，否则调用计时器函数。我想实现从客户端接收数据，接收后我必须调用计时器。但上面的代码并没有调用定时器任务。上面的代码有什么错误？？使用 select api 效率高吗？

Answer 1

select()的第一个参数是1+三组中最高编号的FD，所以应该是acceptSocket+1。

（我假设你真正的问题比上面的代码更复杂，因为你可以只进行阻塞的recvfrom（）调用而不用担心select（）。如果你想处理多个套接字，你需要select（）单个线程，和/或在超时后唤醒阻塞调用 - 尽管还有其他方法可以实现后者。）

Answer 2

您使用

select()

== NULL 调用

timeout

的方式将会阻塞，直到有需要读取

master

中文件描述符之一的数据为止。在您的情况下，由于

master

仅包含

acceptSocket

，因此您调用

else

的

makeTimer()

将永远不会到达。

做

struct timeval timeout;

timeout.tv_sec = 0l;
timeout.tv_usec = 0l; 
retval = select( acceptSocket+1, master, NULL, NULL, &timeout );

只检查而不阻塞

请注意，如果由于超时而返回，则

select()

返回0，否则返回的描述符集中包含文件描述符的数量。所以你也必须改变你的状况：

else if(FD_ISSET (acceptSocket, &master))

到

else if(retval > 0 && FD_ISSET (acceptSocket, &master))

因为否则你也会在超时后调用

recvfrom()

，在这种情况下它会阻塞