0

我有一个 UDP 客户端，它必须从两个不同的套接字接收。
我正在使用select系统调用来多路复用recv调用。

但我看到客户端在第二次recv通话中被阻止。

我该如何解决这个问题？

struct timeval timeout;
timeout.tv_sec = 1;
timeout.tv_usec = 0;
int activity;

FD_ZERO(&socketfds);
FD_SET(usocket,&socketfds);
max_sd = std::max(max_sd, usocket);
FD_SET(msocket,&socketfds);
max_sd = std::max(max_sd, msocket);
rset = socketfds;

do
{
      rset = socketfds;
      activity = select( max_sd + 1 , &rset , NULL , NULL , &timeout);
}
while(activity<0 && errno == EINTR);

if ((activity < 0) && (errno!=EINTR))
{
     printf("select error");
}
if(FD_ISSET(usocket, &socketfds))
{
      int len;
      printf("Receiving from unicast socket..\n");
      if((len = recvfrom(usocket, dataBuffer, dataLength, 0, (struct sockaddr *)  
   &clientAddr, &clen) < 0) )
     {
           printf("Error reading message \n");
           close(msocket);
           exit(-1);
     }
     else
     {
             printf("Size of message: %d\n", strlen(dataBuffer));
             handleMessage(dataBuffer);
     }
}
if(FD_ISSET(msocket, &socketfds))
{
     printf("Receiving from multicast socket..\n");
     if((recvfrom(msocket, dataBuffer, dataLength, 0, (struct sockaddr *)  
   &multicastClientAddr, &mlen) < 0) )
    {
       printf("Error reading message \n");
       close(msocket);
       exit(-1);
    }
    else
    {
      printf("Message from server:%s\n", dataBuffer);
      handleMessage(dataBuffer);
    }
}
4

3 回答 3

3

您需要rset通过 select 检查返回（修改）以查看套接字是否已准备好读取 - 这些位将始终设置，socketfds因为这是您等待的主要套接字集。所以改变

if(FD_ISSET(Xsocket, &socketfds))

线到

if(FD_ISSET(Xsocket, &rset))
于 2013-09-04T20:30:50.627 回答
1

我认为问题在于您没有考虑超时，超时时选择 return 0 。在这种情况下，当返回 0 时，我不知道rset结构将如何，可能是未定义的或未触及的。如果您想无限等待，请使用 NULL 代替超时。

于 2013-09-04T20:58:16.113 回答
1

您应该更改 do-while 循环的条件。仅当存在某些事件时，Select 才会返回非零值（具有事件的 fd 的数量）。在您的情况下，它将返回已读取事件的 fd 数量。因此，如果其中一个 fd 具有读取事件，则 select() 将返回 1，如果两者都有读取事件，则 select 将返回 2。如果 (activity == 0)，则具有读取事件的 fd 数量是零，所以如果你调用 recvfrom()，那自然会阻塞。

while(activity <= 0 && errno == EINTR);
于 2013-09-04T23:46:59.360 回答