C++ socket select() 函数返回 0,连接数较多

发布于 2024-10-16 18:28:40 字数 2676 浏览 1 评论 0原文

我有一个代码,服务器向客户端发送包含 TCP 端口号的 UDP 消息。然后服务器等待与客户端的传入 TCP 连接。但是,select() 函数在连接较多时返回超时。我可以弄清楚可能是什么问题。

非常感谢对下面代码的任何帮助和评论。预先感谢您的帮助。

void initialise( void ) 
{

   m_tcp_listensocket = getlistensocket();
  highsock = m_tcp_listensocket;

  setnonblocking(m_tcp_listensocket);
  struct timeval timeout;
  timeout.tv_sec = m_timeout;
  timeout.tv_usec = 0;


  // Send UDP messages to clients not connected
  for (int i = 0; i < UDP_Connections.size(); i++)
  {  
      // Only to clients not connected
      if ( TCP_Connections[i]->IsConnected() )
      {
        continue;
      }

      // making the message: 'server_address:server_port'.
      char l_str_server_port_number[6];
      sprintf ( l_str_server_port_number, "%d",  TCP_Connections[i]->get_server_port_number ());

      struct hostent  *host;

     if( (host = gethostbyname( m_host_name )) == NULL)
     {

       // gethostbyname() made error
     }    
      struct in_addr  MyAddress;
      memcpy( &MyAddress.s_addr, host->h_addr_list[0], sizeof( MyAddress.s_addr ) );

      std::string l_str_init_message = std::string(l_str_server_port_number) + "\0";

      UDP_Connections[i]->sendUDPMessage(l_str_init_message.c_str());
   }

  for (int i = 0; i < TCP_Connections.size(); i++)
    {
      struct sockaddr_in clientaddr;  
      bzero(&clientaddr, sizeof(clientaddr));
      clientaddr.sin_family = AF_INET;
      clientaddr.sin_addr.s_addr = htonl(INADDR_ANY);

      fd_set readSet;
      FD_ZERO(&readSet);
      FD_SET(m_tcp_listensocket, &readSet);

      int readsocks = select(highsock+1, &readSet, NULL, NULL, &timeout);

      switch (readsocks)
    {
    case 0:
      /* timeout */   
      break;

    case -1:
      /* error */
      break;

    default:
      if (FD_ISSET (m_tcp_listensocket, &readSet))
        {
          socklen_t tempo = (socklen_t)sizeof(clientaddr);

          int l_Socket = accept(m_tcp_listensocket, (struct sockaddr *)&clientaddr, &tempo);
          if ( l_Socket > highsock )
        highsock =  l_Socket;

          if ( l_Socket >= 0 )
        {
          // connection accepted

          char adr[16] ;
          inet_ntop(PF_INET,&clientaddr.sin_addr, adr, sizeof(adr));

          for (int j= 0; j < UDP_Connections.size(); j++)
            {

              if ( UDP_Connections[j]->get_clientIP() == (std::string)adr )
            {     
              TCP_Connections[j]->set_TCPsocket( l_Socket );
              break;
            }
            }

        }
          else 
        {
          // socket error
        }
        }
    }
    }
}

I have a code where the server sends a UDP message which contains a TCP port number to clients. Then the server waits for incoming TCP connections with clients. However, the select() function returns timeout with many connections. I can figure out what might be the problem.

Any help and comments on the code below are very much appreciated. Thanks in advance for help.

void initialise( void ) 
{

   m_tcp_listensocket = getlistensocket();
  highsock = m_tcp_listensocket;

  setnonblocking(m_tcp_listensocket);
  struct timeval timeout;
  timeout.tv_sec = m_timeout;
  timeout.tv_usec = 0;


  // Send UDP messages to clients not connected
  for (int i = 0; i < UDP_Connections.size(); i++)
  {  
      // Only to clients not connected
      if ( TCP_Connections[i]->IsConnected() )
      {
        continue;
      }

      // making the message: 'server_address:server_port'.
      char l_str_server_port_number[6];
      sprintf ( l_str_server_port_number, "%d",  TCP_Connections[i]->get_server_port_number ());

      struct hostent  *host;

     if( (host = gethostbyname( m_host_name )) == NULL)
     {

       // gethostbyname() made error
     }    
      struct in_addr  MyAddress;
      memcpy( &MyAddress.s_addr, host->h_addr_list[0], sizeof( MyAddress.s_addr ) );

      std::string l_str_init_message = std::string(l_str_server_port_number) + "\0";

      UDP_Connections[i]->sendUDPMessage(l_str_init_message.c_str());
   }

  for (int i = 0; i < TCP_Connections.size(); i++)
    {
      struct sockaddr_in clientaddr;  
      bzero(&clientaddr, sizeof(clientaddr));
      clientaddr.sin_family = AF_INET;
      clientaddr.sin_addr.s_addr = htonl(INADDR_ANY);

      fd_set readSet;
      FD_ZERO(&readSet);
      FD_SET(m_tcp_listensocket, &readSet);

      int readsocks = select(highsock+1, &readSet, NULL, NULL, &timeout);

      switch (readsocks)
    {
    case 0:
      /* timeout */   
      break;

    case -1:
      /* error */
      break;

    default:
      if (FD_ISSET (m_tcp_listensocket, &readSet))
        {
          socklen_t tempo = (socklen_t)sizeof(clientaddr);

          int l_Socket = accept(m_tcp_listensocket, (struct sockaddr *)&clientaddr, &tempo);
          if ( l_Socket > highsock )
        highsock =  l_Socket;

          if ( l_Socket >= 0 )
        {
          // connection accepted

          char adr[16] ;
          inet_ntop(PF_INET,&clientaddr.sin_addr, adr, sizeof(adr));

          for (int j= 0; j < UDP_Connections.size(); j++)
            {

              if ( UDP_Connections[j]->get_clientIP() == (std::string)adr )
            {     
              TCP_Connections[j]->set_TCPsocket( l_Socket );
              break;
            }
            }

        }
          else 
        {
          // socket error
        }
        }
    }
    }
}

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

似狗非友 2024-10-23 18:28:40

select() 的某些实现会更新其超时参数,您可能需要在每次调用之前重置它。

Some implementations of select() update their timeout argument, you may need to reset this before each call.

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文