0

私は Unix/Linux ネットワーキング プログラミングが初めてなので、以下にサーバー クライアント プログラムを書きました。このコードでは、クライアントとサーバーの間に 1 つのソケットがあり、クライアントからサーバーへの要求があり、次にクライアントへの 1 から 100 の数字のサーバー応答があります。私の質問は、スレッドを使用せずに 3 つのソケット (tcp 接続) でこのプロセスを実行するにはどうすればよいですか? (例: 最初のソケットが実行され、次に 2 番目が実行され、次に 3 番目が実行され、さらに最初に実行されます。) 何か提案はありますか?

Client.c

int main()
{

int sock;
struct sockaddr_in sa;
int ret;
char buf[1024];
int x;

sock = socket (AF_INET, SOCK_STREAM, 0);

bzero (&sa, sizeof(sa));
sa.sin_family = AF_INET;
sa.sin_port = htons(SERVER_PORT);
inet_pton (AF_INET, SERVER_IP, &sa.sin_addr);

ret = connect (sock,
(const struct sockaddr *) &sa,sizeof (sa));

if (ret != 0) {
    printf ("connect failed\n");
    exit (0);
}

x = 0;
while (x != -1) {
    read (sock, buf , sizeof(int));
    x = ntohl(*((int *)buf));
    if (x != -1)
    printf ("int rcvd = %d\n", x);
}

close (sock);

exit (0);

}

サーバー.c

int main()
{

int list_sock;
int conn_sock;
struct sockaddr_in sa, ca;
socklen_t ca_len;
char buf[1024];
int i;
char ipaddrstr[IPSTRLEN];

list_sock = socket (AF_INET, SOCK_STREAM, 0);

bzero (&sa, sizeof(sa));
sa.sin_family = AF_INET;
sa.sin_addr.s_addr = htonl(INADDR_ANY);
sa.sin_port = htons(SERVER_PORT);
bind (list_sock,(struct sockaddr *) &sa,sizeof(sa));

listen (list_sock, 5);

while (1){

    bzero (&ca, sizeof(ca));
    ca_len = sizeof(ca); // important to initialize
    conn_sock = accept (list_sock,(struct sockaddr *) &ca,&ca_len);

    printf ("connection from: ip=%s port=%d \n",inet_ntop(AF_INET, &(ca.sin_addr),
        ipaddrstr, IPSTRLEN),ntohs(ca.sin_port));

    for (i=0; i<100; ++i){

        *((int *)buf) = htonl(i+20);
        // we using converting to network byte order

        write (conn_sock, buf, sizeof(int));

    }

    * ((int *)buf) = htonl(-1);
    write (conn_sock, buf, sizeof(int));

    close (conn_sock);

    printf ("server closed connection to client\n");

}
}
4

2 に答える 2

0

たぶんそれはあなたが望むものではないかもしれませんが、私はあなたがepollを試すことができると思います、簡単な例があります

typedef struct event_loop
{
    int max_event;
    int epfd;
}event_loop;

event_loop* create_event_loop()
{
    event_loop *ep = malloc(sizeof(event_loop));
    ep->max_event = 512;
    ep->epfd = epoll_create(512);
    return ep; 
}
int add_event(event_loop *ep, int fd) 
{
    epoll_event ee; 
    ee.data.fd = fd; 
    ee.event = EPOLLIN | EPOLLPRI;
    epoll_ctl(ep->epfd, EPOLL_CTL_ADD, fd, &ee);
}
void event_main(event_loop *ep, int listenfd)
{
    epoll_event events[512];
    int nfds, i, newfd;
    while(1)
    {   
        if(nfds = epoll_wait(ep->epfd, events, 512, -1) == -1) 
            exit(1);
        for(i = 0; i < nfds; i++)
        {   
            if(events[nfds].data.fd == listenfd)
            {   
                newfd = accept(listenfd, NULL, NULL);
                add_event(ep, newfd);
            }
            else
            {
                //do what you want
            }
        }
    }
}

epollは高効率のソリューションであり、man epollより多くの情報を入手するだけです

于 2012-10-17T05:28:06.990 に答える
0

これについて詳しく説明している優れたリソースであるBeej's Guide to Netwokr Programmingを参照するのが最善だと思います。彼はまた、出発点として使用できるいくつかの良い例を持っており、Windows を含むすべての主要なプラットフォームをカバーしています。

基本的にあなたは：

socket()
bind()
listen()
accept()

accept() は、一意のクライアントに接続されたソケットを返します。次に、select、poll、または epoll を使用して、それらのソケットでデータが利用可能になる時期を判断します。これらの API と Beej のガイドのマニュアル ページを参照することをお勧めします。ここで初めてネットワーク プログラミングを学びました。

コードを見ると、内側のループが間違っています。接続を受け入れるときは、それをリストなどに追加する必要があります。現在、あなたはそれを上書きして失います。(e)poll または select を使用して、どちらにデータがあるかを確認する必要があります。いつでもそれらのいずれかに書き込むことができます。繰り返しますが、Beej のガイドの例を見てください。それらは最も役に立ちます。

于 2012-10-16T22:39:56.267 に答える