3

そのため、ポートとクライアント/サーバー通信のアイデアをいじっています。

ポートを開き、リッスン記述子を開き、接続を受信すると、子を分岐して接続クライアントとの通信を処理できる server.c プログラムがあります。5 つのコマンドライン引数を受け取る client.c プログラムがあります。基本的に、最初の 3 つの引数はサーバーに送信する練習用の文字列で、4 番目はホスト名、5 番目はポート番号です。

これまでのところ、これら 2 つの接続は正常に機能していますが、クライアントが 3 つの異なる文字列 (argv[1]、argv[2]、および argv[3]) を server.c に書き込もうとすると、server.c は最初のものを読み取ることができた場合、クライアントがすべての文字列を通信ファイル記述子に書き終えても、スタックして追加の読み取りを続行できないようです。サーバーとクライアントをよりよく学習するための簡単な練習プログラムを見つけようとして、4 時間以上立ち往生しました。私はもう迷子になりたくないので、誰かがこの問題の処理方法や私が間違っていることについてアドバイスをくれることを願っています.

Client.c

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include "uici.h"
#include "func.h"


int main(int argc, char *argv[]){
  int fd;
  u_port_t portnum;

  if(argc != 6){
    fprintf(stderr, "Usage: %s string1 string2 string3 host port\n",argv[0]);
    return -1;
  }
  portnum = (u_port_t)atoi(argv[5]);
  if((fd = u_connect(portnum, argv[4])) == -1){
    perror("Failled to establish connection");
    return 1;
  }
  fprintf(stderr, "[%ld]:connection made to %s\n", (long)getpid(), argv[4]);
  if((write(fd, argv[3], strlen(argv[3])+1)) == -1){
    fprintf(stderr, "Failed to write %s to fd", argv[3]);
    r_close(fd);
    return 0;
  }
  if((write(fd, argv[1], strlen(argv[1])+1)) == -1){
    fprintf(stderr, "Failed to write %s to fd", argv[1]);
    r_close(fd);
    return 0;
  }
  if((write(fd, argv[2], strlen(argv[2])+1)) == -1){
    fprintf(stderr, "Failed to write %s to fd", argv[2]);
    close(fd);
    return 0;
  }
  fprintf(stderr, "Everything has been written\n");
  return 0;
}

サーバー.c

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <limits.h>
#include <sys/types.h>
#include <sys/wait.h>
#include "func.h"
#include "uici.h"

int main(int argc, char *argv[])
{
   u_port_t portnumber;
   int listenfd;
   int fd;
   char client[MAX_CANON];
   int bytes_copied;
   pid_t child;

   if (argc != 2) {
      fprintf(stderr, "Usage: %s port\n", argv[0]);
      return 1;
   }

   portnumber = (u_port_t) atoi(argv[1]);
   if ((listenfd = u_open(portnumber)) < 0) {
      perror("Listen endpoint creation failed");
      return 1;
   }

   fprintf(stderr, "[%ld]: Waiting for the first connection on port %d\n",
                    (long)getpid(), (int)portnumber);
   for ( ; ; ) {
      if ((fd = u_accept(listenfd, client, MAX_CANON)) != -1) {
         fprintf(stderr, "[%ld]: A connection has been received from %s\n",
                 (long) getpid(), client);
         if ((child = fork()) == -1)
            perror("Could not fork a child");

         if (child == 0) {                            /* child code */
            r_close(listenfd);
            int MAXSZ = 1024;
            char str3[MAXSZ];
            char str1[MAXSZ];
            char str2[MAXSZ];
            int bytesread = 0;
            fprintf(stderr, "Beginning the reads\n");
            read(fd,str3, MAXSZ);
            fprintf(stderr, "Finished 1st read\n");
            read(fd,str1, MAXSZ);
            fprintf(stderr, "Finished 2nd read\n");
            read(fd,str2, MAXSZ);
            fprintf(stderr, "str3: %s\n",str3);
            fprintf(stderr, "str1 = %s\n",str1);
            fprintf(stderr, "str2 = %s\n",str2);
            close(fd);
            return 0;
         } else {                                    /* parent code */
            close(fd);
            while (waitpid(-1, NULL, WNOHANG) > 0) ;  /* clean up zombies */
         }
      }
      else
         perror("Accept failed");
   }
}
4

2 に答える 2

0

注:またはがファイル記述子との間ですべてのデータを読み書きするという保証はなく、クライアントが書き込んでいるデータ ブロックがサーバー上で同じ方法で読み取られるという保証もありませんread。write

書き込まれたバイトを確認し、すべてを書き込むまで fd にデータを書き続ける必要があります。読み取るときは、予想されるデータ量を説明する何らかの種類のヘッダー データをクライアントに送信させる必要があります。または、あなたの場合、一度に 1 バイトを読み取って、'\0'文字の終わりを示す文字を探すことができます。ストリング。

送信している文字列よりも大きい可能性があるためMAXSZ、サーバーはすべての文字列を一度に最初のバッファーに読み取り、その後の読み取りをブロックする可能性があります。

于 2016-04-22T15:29:00.757 に答える