13

複数のクライアントから接続できるサーバーを作ろうとしています。これまでの私のコードは次のとおりです。

クライアント:

int main(int argc, char **argv) {

  struct sockaddr_in servaddr;
  int sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);

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

  bzero((void *) &servaddr, sizeof(servaddr));
  servaddr.sin_family = AF_INET;
  servaddr.sin_port = htons(6782);
  servaddr.sin_addr.s_addr = inet_addr(<server_ip_address>);

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

  while(1) {

    char message[6];
    fgets(message, 6, stdin);

    message[5] = '\0';

    send(sock, message, 6, 0);
  }


  close(sock);
}

サーバ:

int main(int argc, char **argv) {

  fd_set fds, readfds;
  int i, clientaddrlen;
  int clientsock[2], rc, numsocks = 0, maxsocks = 2;

  int serversock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  if (serversock == -1) perror("Socket");

  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(6782);

  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");
            FD_SET(clientsock[numsocks], &fds);
            numsocks++;
          } else {
            printf("Ran out of socket space.\n");

          }
        } else {
          int messageLength = 5;
          char message[messageLength+1];
          int in, index = 0, limit = messageLength+1;

          while ((in = recv(clientsock[i], &message[index], limit, 0)) > 0) {
            index += in;
            limit -= in;
          }

          printf("%d\n", index);
          printf("%s\n", message);

        }
      }
    }
  }

  close(serversock);
  return 0;
}

クライアントが接続して最初のメッセージを送信するとすぐに、サーバーは無限ループで実行され、メッセージ配列からガベージを吐き出します。recvは何も受信していないようです。誰かが私がどこで間違っているのか見ることができますか?

4

5 に答える 5

4

コードの2つの問題:

  • あなたはrecv(i, ...)代わりにすべきですrecv(clientsock[i], ...)

  • recv()その後、失敗したかどうかをチェックしないためprintf()、初期化されていないバッファmessageが出力され、出力にゴミが表示されます

于 2010-11-17T00:30:54.823 に答える
1

readを呼び出すに、readループでlimit<=0をチェックする必要があります。

于 2010-11-17T00:24:11.893 に答える
1

サーバーのwhileループで、コードを.recv(i)の代わりにdoに変更しますrecv(clientsocks[i])。私はこのコードを実装しましたが、この変更で機能します。

于 2012-09-26T09:25:38.640 に答える
0

elseを以下に置き換えて動作します

 } else {
/*                  int messageLength = 5;
                    char message[messageLength+1];
                    int in, index = 0, limit = messageLength+1;

                    memset ( &message[index] , 0, sizeof ( message [index] ) );

                    while ((in = recv(i, &message[index], limit, 0)) > 0) {
                        index += in;
                        limit -= in;
                    }

                    printf("%d\n", index);
                    printf("%s\n", message);
*/
                    bzero(buf, sizeof(buf));
                    if ((rval = read(i, buf, 1024)) < 0)
                        perror("reading stream message");
                    else if (rval == 0)
                        printf("Ending connection\n");
                    else
                        printf("-->%s\n", buf);

                }
于 2013-03-26T17:07:09.230 に答える
0


1)ソケットの作成時には、AF_INET(アドレスファミリ)ではなくPF_INET(プロトコルファミリ)を使用することをお勧めします。

2)while(1)ループ内で、
FD_ZERO(&readfds)を使用してreadfdsを空にすることをお勧めします。recv()呼び出しでは、clientsocks [i]ではなくiを使用する必要があります。その場合、メッセージを出力する必要がない場合は、recvの戻り値が負(読み取りエラーを示す)であることを確認する必要があります。メッセージを出力するときは、stdout / serverがwritefds(selectの3番目の引数)を使用して実行できるものを書き込む準備ができていることを確認してください。

于 2018-02-09T08:27:05.817 に答える