0

ソケットを作成し、接続にバインドし、それをリッスンして結果を受信することはできますが、このすべてで1つの接続しかありません.cで複数の着信接続を処理するにはどうすればよいですか？それを機能させる。

助けてください。

4

3 に答える 3

3

fork//threadsまたはsome pollフレームワーク関数を使用できます。

グーグルからの簡単なフォークの例：

#include <stdio.h>
#include <strings.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#include <stdlib.h>

void doprocessing (int sock)
{
    int n;
    char buffer[256];

    bzero(buffer,256);

    n = read(sock,buffer,255);
    if (n < 0)
    {
        perror("ERROR reading from socket");
        exit(1);
    }
    printf("Here is the message: %s\n",buffer);
    n = write(sock,"I got your message",18);
    if (n < 0)
    {
        perror("ERROR writing to socket");
        exit(1);
    }
}

int main( int argc, char *argv[] )
{
    int sockfd, newsockfd, portno;
    socklen_t clilen;
    struct sockaddr_in serv_addr, cli_addr;

    /* First call to socket() function */
    sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd < 0)
    {
        perror("ERROR opening socket");
        exit(1);
    }
    /* Initialize socket structure */
    bzero((char *) &serv_addr, sizeof(serv_addr));
    portno = 5001;
    serv_addr.sin_family = AF_INET;
    serv_addr.sin_addr.s_addr = INADDR_ANY;
    serv_addr.sin_port = htons(portno);

    /* Now bind the host address using bind() call.*/
    if (bind(sockfd, (struct sockaddr *) &serv_addr,
                          sizeof(serv_addr)) < 0)
    {
         perror("ERROR on binding");
         exit(1);
    }
    /* Now start listening for the clients, here
     * process will go in sleep mode and will wait
     * for the incoming connection
     */
    listen(sockfd,5);
    clilen = sizeof(cli_addr);
    while (1)
    {
        newsockfd = accept(sockfd,
                (struct sockaddr *) &cli_addr, &clilen);
        if (newsockfd < 0)
        {
            perror("ERROR on accept");
            exit(1);
        }
        /* Create child process */
        pid_t pid = fork();
        if (pid < 0)
        {
            perror("ERROR on fork");
            exit(1);
        }
        if (pid == 0)
        {
            /* This is the client process */
            close(sockfd);
            doprocessing(newsockfd);
            exit(0);
        }
        else
        {
            close(newsockfd);
        }
    } /* end of while */
}
于 2012-05-16T20:39:03.373 に答える
2

それがどのように機能するかについて簡単に説明します。

接続をリッスンするシステムをセットアップする必要があり、接続がある場合は、開いている接続のリストにプッシュします。接続をリストに保存した後、別のリスナーを作成します。接続ステータスに基づいて、リストを定期的に整理します。

于 2012-05-16T20:12:07.687 に答える
0

どのOSについては言及していないので、Unix/Linuxを想定します。

複数の接続を処理する最も一般的な方法は、たとえば、スレッドを介してfork()、またはスレッドを使用して、各接続を個別のプロセスで処理するpthreadsことです。サーバーは接続を待機し、接続が受け入れられると、を使用して新しいプロセスが作成されるfork()か、新しい接続を処理するための新しいスレッドが作成されます。これはあなたが見てみたいと思うかもしれないまともなチュートリアルです。

これが便利なpthreadチュートリアルです

于 2012-05-16T22:45:19.020 に答える