使用select()监听多个客户端(TCP)

我开发了(TCP)服务器来监听客户端并与之交互。 现在我正在尝试调整该服务器代码以收听多个客户端。 我想使用select,但我对我发现的一些例子和解释感到困惑。

我一直在阅读: http : //support.sas.com/documentation/onlinedoc/sasc/doc750/html/lr2/select.htm和http://support.sas.com/documentation/onlinedoc/sasc/doc750/html /lr2/select.htm这两个都被推荐给我..:S

第一个网站的例子似乎不太复杂..(虽然仍然不知道如何使其适应我的代码,因为我非常非常非常新的网络等)但我担心我错过了关键方面,因为第二个网站的例子的复杂性。

下面是我的服务器代码的快照,当只监听一个客户端时(包括一些伪代码以最小化不那么重要的东西):

int main(int argc, char *argv[]) { int sockfd, newsockfd, portno, clilen; char buffer[3]; struct sockaddr_in serv_addr, cli_addr; int n; if (argc < 2) { fprintf(stderr,"ERROR, no port provided\n"); exit(1); } sockfd = socket(AF_INET, SOCK_STREAM, 0); if (sockfd < 0){error("ERROR opening socket");} bzero((char *) &serv_addr, sizeof(serv_addr)); portno = atoi(argv[1]); serv_addr.sin_family = AF_INET; serv_addr.sin_addr.s_addr = INADDR_ANY; serv_addr.sin_port = htons(portno); if (bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0) {error("ERROR on binding");} listen(sockfd,5); clilen = sizeof(cli_addr); newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen); if (newsockfd < 0){error("ERROR on accept");} while (UNTIL END OF FILE) {  n = write(newsockfd, "test/n", 5); if (n < 0){error("ERROR writing to socket");} bzero(buffer,3); n = read(newsockfd,buffer,3); if (n < 0){error("ERROR reading from socket");} buffer[n] = 0;  while(done != 1) { bzero(buffer,3); n = read(newsockfd,buffer,3); if (n < 0){error("ERROR reading from socket");} buffer[n] = 0; if(strcmp(buffer, "CO")) { done = 1; } } done = 0; }  n = write(newsockfd, "DN\n", 2); if (n < 0){error("ERROR writing to socket");} close(sockfd); close(newsockfd); return 0; } 

哪个网站的select()示例最适合我正在尝试做的事情(更改服务器代码以收听多个客户端)? 有人可以用一些更简单的术语来解释select()吗? (因为我对这个和所有人都很新……)

谢谢!

您需要围绕accept()和以下代码包装一个循环,以便您可以在程序的整个生命周期中接受多个连接。 然后,您需要确定服务器将如何处理多个连接。 你有几个选择:

  • 使用多个线程,每个客户端一个线程。
  • 使用分叉服务器,每个客户端一个进程。
  • 使用单个服务器,它将使用select()来决定哪些文件描述符已准备就绪。

在前两种情况下,子线程或进程是一心一意处理一个客户端; 它将在客户端正在研究如何响应它发送的内容时等待,这意味着其他线程或进程在CPU处转向。 主题上有一些变体可以预先发布一些工作线程或进程并安排那些工作负载,但这更复杂。

在最后一种情况下,您将设置一个您希望select()处理的文件描述符数组,然后将该列表的副本传递给select() (因为它会遍历它)。 当你有工作要做(因为select()返回)时,如果已经准备就在你正在监听的文件描述符上执行accept() ,或者如果它们已经准备好你从已经打开的套接字描述符中读取。