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

【问题标题】：using select() to listen to multiple clients (TCP)使用 select() 监听多个客户端 (TCP)
【发布时间】：2011-04-25 18:05:15
【问题描述】：

我开发了（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)
    {
        <DO SOME FILE READING STUFF>

        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;

        <DO SOME STRING STUFF>

        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;
    }

    <DO STUFF>


    n = write(newsockfd, "DN\n", 2);

    if (n < 0){error("ERROR writing to socket");}

    close(sockfd);
    close(newsockfd);

    return 0;   

}

哪个站点的 select() 示例最适合我正在尝试做的事情（更改服务器代码以侦听多个客户端）？有人可以用更简单的术语为我解释 select() 吗？（因为我对这一切都很陌生......）

谢谢！

【问题讨论】：

标签： c tcp

【解决方案1】：

您需要围绕accept() 和以下代码进行循环，这样您就可以在程序的整个生命周期内接受多个连接。然后，您需要决定您的服务器将如何处理多个连接。您有几个选择：

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

前两种情况，子线程或进程一心一意地与一个客户端打交道；当客户端正在研究如何响应它发送的内容时，它将等待，这意味着其他线程或进程将在 CPU 上轮到。主题有一些变体，可以预先启动一些工作线程或进程并安排它们来承担工作负载，但这更复杂。

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

【讨论】：