1

2010 年，我查看了一个由 stackoverflow 成员atanos编写的关于将多个客户端连接到单个服务器的程序，我稍微修改了他的程序以从命令行接受连接详细信息，下面是服务器和 cient 代码。

服务器.c

int main(int argc, char **argv)
{
  fd_set fds, readfds;
  int i, clientaddrlen, portno;
  int clientsock[2], rc, numsocks = 0, maxsocks = 2;

  if (argc < 2){
      fprintf(stderr,"ERROR, no port provided\n");
      exit(1);
  }

  int serversock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);

  if (serversock == -1) perror("Socket");

  portno = atoi(argv[1]);
  struct sockaddr_in serveraddr, clientaddr;
  bzero(&serveraddr, sizeof(struct sockaddr_in));
  serveraddr.sin_family = AF_INET;
  serveraddr.sin_addr.s_addr = htonl(INADDR_ANY);
  serveraddr.sin_port = htons(portno);

  if (-1 == bind(serversock, (struct sockaddr *)&serveraddr,sizeof(struct sockaddr_in))) perror("Bind");

  if (-1 == listen(serversock, SOMAXCONN)) perror("Listen");

  FD_ZERO(&fds);
  FD_SET(serversock, &fds);

  while(1) {
    readfds = fds;
    rc = select(FD_SETSIZE, &readfds, NULL, NULL, NULL);

    if (rc == -1){
      perror("Select");
      break;
   }

    for (i = 0; i < FD_SETSIZE; i++)
    {
      if (FD_ISSET(i, &readfds)){
        if (i == serversock){
          if (numsocks < maxsocks){
            clientsock[numsocks] = accept(serversock,(struct sockaddr *) &clientaddr,
                (socklen_t *)&clientaddrlen);

            if (clientsock[numsocks] == -1) perror("Accept");
            else printf("Connection accepted\n");

            FD_SET(clientsock[numsocks], &fds);
             numsocks++;
          }
          else
            printf("Ran out of socket space.\n");
        }
        else
        {
          int messageLength = 10;
          char message[messageLength+1];
          int numOfChRead, index = 0, limit = messageLength+1;

          numOfChRead = recv(clientsock[i], message, messageLength,0);

          if(numOfChRead > 0)
              printf("Data Received !!! length: %d Message: %s", numOfChRead, message);
          else
              printf("Nothing read\n");
        }
      }
    }
  }
  close(serversock);
  return 0;
}

客户端.c

int main(int argc, char **argv)
{
  struct sockaddr_in servaddr;
  struct hostent *server;
  int portno, bytesSent = 0;

  if (argc < 3){
      fprintf(stderr,"Usage %s hostname port\n", argv[0]);
      exit(0);
  }

  portno = atoi(argv[2]);
  int sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  if (sock == -1) perror("Socket");

  server = gethostbyname(argv[1]);

  if (server == NULL){
      fprintf(stderr,"ERROR, no such host\n");
      exit(0);
  }

  bzero((void *) &servaddr, sizeof(servaddr));
  servaddr.sin_family = AF_INET;

  servaddr.sin_port = htons(portno);
  bcopy((char *)server->h_addr,(char *)&servaddr.sin_addr.s_addr,server->h_length);

  if (-1 == connect(sock, (struct sockaddr *)&servaddr, sizeof(servaddr))) perror("Connect");

  while(1) {
    char message[10];
    fgets(message, 10, stdin);
    message[10] = '\0';

    bytesSent = send(sock, message, strlen(message), 0);

    if(bytesSent == -1) printf("Sending failed with errno %d", errno);
    else printf("Sent %d characters", bytesSent);
  }
  close(sock);
}

我可以看到服务器接受多个连接，但是当我从任何客户端发送消息时，服务器中的 recv API 不会读取任何内容。客户端的发送 API 成功，我可以看到所有字符都已发送。有人可以评论吗？

4

2 回答 2

2

问题是您实际上从未将客户端连接放入 read 中fd_set。

该行：

readfds = fds;

重置readfds为其中只有服务器（侦听）套接字的状态。fd_set您需要在调用之前完全重新设置每个客户端文件描述符select，每次循环。

可能是其他问题（要处理很多代码），但这似乎是最有可能的问题。

（顺便说一句，我不确定分配是否合法。我认为实现对fd_set简单、可复制的结构没有任何要求。）

于 2012-09-02T18:48:38.263 回答
1

您的代码中有多个错误。您没有正确使用 select 调用。select 的第一个参数取您正在收听的 fd 的最大数量加 1。第二个参数包含要观看的 fd 列表。

我用 fdmax 替换了你的 FD_SETSIZE。我更正了您的代码中的问题并粘贴在下面。

  8 int main(int argc, char **argv)
  9 {
 10   fd_set fds, readfds;
 11   int i, clientaddrlen, portno;
 12   int clientsock[2], rc, numsocks = 0, maxsocks = 2;
 13   int fdmax=0;
 14
 15   if (argc < 2){
 16       fprintf(stderr,"ERROR, no port provided\n");
 17       exit(1);
 18   }
 19
 20   int serversock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
 21
 22   if (serversock == -1) perror("Socket");
 23
 24   portno = atoi(argv[1]);
 25   struct sockaddr_in serveraddr, clientaddr;
 26   bzero(&serveraddr, sizeof(struct sockaddr_in));
 27   serveraddr.sin_family = AF_INET;
 28   serveraddr.sin_addr.s_addr = htonl(INADDR_ANY);
 29   serveraddr.sin_port = htons(portno);
 30
 31   if (-1 == bind(serversock, (struct sockaddr *)&serveraddr,sizeof(struct sockaddr_in))) perror("Bind");
 32
 33   if (-1 == listen(serversock, SOMAXCONN)) perror("Listen");
 34
 35   FD_ZERO(&fds);
 36   FD_SET(serversock, &fds);
 37   fdmax = serversock;
 38
 39   clientaddrlen = sizeof(clientaddr);
 40   while(1) {
 41     readfds = fds;
 42     rc = select(fdmax + 1, &readfds, NULL, NULL, NULL);
 43
 44     if (rc == -1){
 45       perror("Select");
 46       break;
 47    }
 48
 49     for (i = serversock; i <= fdmax; i++)
 50     {
 51       if (FD_ISSET(i, &readfds)){
 52         if (i == serversock){
 53           if (numsocks < maxsocks){
 54             clientsock[numsocks] = accept(serversock,(struct sockaddr *) &clientaddr,
 55                 (socklen_t *)&clientaddrlen);
 56
 57             if (clientsock[numsocks] == -1) perror("Accept");
 58             else printf("Connection accepted\n");
 59
 60             FD_SET(clientsock[numsocks], &fds);
 61             fdmax = clientsock[numsocks];
 62              numsocks++;
 63           }
 64           else
 65             printf("Ran out of socket space.\n");
 66         }
 67         else
 68         {
 69           int messageLength = 100;
 70           char message[messageLength+1];
 71           int numOfChRead, index = 0, limit = messageLength+1;
 72
 73           numOfChRead = recv(i, message, messageLength,0);
 74
 75           if(numOfChRead > 0)
 76               printf("Data Received !!! length: %d Message: %s", numOfChRead, message);
 77           else
 78               printf("Nothing read\n");
 79         }
 80       }
 81     }
 82   }
 83   close(serversock);
 84   return 0;
 85 }
于 2012-09-02T20:04:44.417 回答