編集履歴

質問編集履歴

問題文の要約

2019/08/08 19:02

投稿

tosakasimon

スコア8

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -1,35 +1,5 @@
-### 複数クライアント接続対応のチャットサーバープログラム
+### 複数クライアント接続
-linux環境下のｃ言語を用いて複数クライアント接続対応のサーバプログラムを作成しているのですがあまりうまく行きません。他者が作成したクライアントプログラムとも通信をするために以下のようなプロトコル仕様があります。
-クライアントの仕様
-[状態c1](初期状態)ソケットを生成し(socket)，引数で指定されたホストへ接続要求を出す(connect)．[状態c2]へ移る．
-[状態c2](参加)サーバから17文字のメッセージを受信する(read)．もしメッセージが接続受理("REQUEST ACCEPTED\n")ならば状態c3へ，さもなければ(接続拒否または何らかの例外)[状態c6]へ移る．
-[状態c3](ユーザ名登録)引数で指定されたユーザ名(最後に改行)を送信する．(write)続いて20文字の文字列を受信し(read)，受信文字列が登録完了メッセージ("USERNAME REGISTERED\n")であれば，[状態c4]へ，さもなければ，エラーメッセージを表示し，[状態c6]へ移る．
-[状態c4](メッセージ送受信)標準入力とサーバ両方の入力を待ち(select)，標準入力からの文字列はサーバへ送信し(write)，サーバからの受信文字列は標準入力へ出力する(read)．標準入力がEOFなら[状態c5]へ，さもなければ[状態c4]へ移る．
-[状態c5](離脱)ソケットを閉じて(close)，クライアントプログラムを正常終了する(exit(0))．
-[状態c6](例外処理)ソケットを閉じて(close)，クライアントプログラムを異常終了する(exit(1))．
-サーバ側のプロトコル仕様状態
-[s1](初期状態)ソケットを生成(socket)し，接続要求を待つように設定する(bind,listen)．参加クライアント数kを0に初期化する．[状態s2]へ移る．
-[状態s2](入力待ち)接続要求を待つソケットからの入力，および，参加しているすべてのクライアントのソケットからの入力3を一定時間監視する(select)．[状態s3]へ移る．
-[状態s3](入力処理)入力があったすべてのソケットに対して入力処理を行う．接続要求あり:[状態s4]へ移る．クライアントi(i= 1; : : : ; k)から入力あり:[状態s6]へ移る．入力があったソケットすべてに対して処理を終えたら[状態s2]へ移る．
-[状態s4](参加受け付け)接続要求を受理する(accept)．次に，もし現在の参加クライアント数kがMAXCLIENTS未満であれば，接続受理のメッセージ(文字列"REQUEST ACCEPTED\n")を返し(write)，クライアントソケット4をk+ 1番目のクライアントとして登録し，[状態s5]へ移る．さもなければ接続拒否のメッセージ(文字列"REQUEST REJECTED\n")を返し(write)，クライアントソケットを閉じて(close)，[状態s3]へ移る．
-[状態s5](ユーザ名登録)\ユーザ名＋改行"を受信し(read)，1～k番目のユーザのいずれかと同じ名前ならば，登録拒否のメッセージ(文字列"USERNAME REJECTED\n")を返し(write)，登録拒否したユーザ名を分かりやすく標準出力に出力し，クライアントソケットを閉じて(close)，[状態s3]へ移る．未登録のユーザならば，k+1番目のクライアントのユーザ名として登録する．登録完了メッセージ(文字列"USERNAME REGISTERED\n")を送信し(write)，登録したユーザ名を分かりやすく標準出力に出力し，kを1増やす．[状態s3]へ移る．
-[状態s6](メッセージ配信)クライアントiから文字列を入力する(read)．もしEOFならば[状態s7]へ移る．さもなければその入力文字列の先頭にユーザ名を追加して，全クライアントに対して送信し(write)，[状態s3]へ移る．
-[状態s7](離脱処理)クライアントiのソケットを閉じる(close)．離脱したユーザ名を分かりやすく標準出力に出力し，クライアント数kを1減らすなどの離脱処理を行い，[状態s3]へ移る
 ###問題
 ```

文法の大幅修正

2019/08/08 19:01

投稿

tosakasimon

スコア8

title CHANGED Viewed

File without changes

body CHANGED Viewed

@@ -33,7 +33,8 @@
 ###問題
 ```
+ ユーザー名の登録などがうまく行かないです。空白文字で区切ったりしてはいるのですが。
- 状態遷移などがうまく行かないです。サーバプログラムを実行し、クライアントから、サーバー側端末名、クライアント側のゲスト名を引数にして実行したら、最初にREQUESTの承認の是非やユーザー名の確認作業にはいるはずが、if(FD_ISSET〜以降のソケットからの入力処理のところに入ってしまいます。
+また、クライアントがEOFを入力したら、そのユーザーのみのソケットを閉じて入力、受付待ちに戻るはずなのですが、ユーザー名を大量に出力して作業が強制的に終了してしまいます。
 ```
 ### schat.c(サーバプログラム)
@@ -61,8 +62,9 @@
     struct sockaddr_in clt;
     struct sockaddr_in svr;
     struct hostent *cp;
-    int clen,nbytes,kmax;
+    int clen,nbytes,fdmax,flag;
+    int Nbyte[5];
-    char  USERNAME[5][32];
+    char  USERNAME[5][32],Nbuf[32];
     fd_set rfds;/* select()で用いるファイル記述子集合*/
     struct timeval tv;
     char rbuf[128],buffer[128],*arg;
@@ -90,93 +92,83 @@
         perror("listen");
         exit(1);
     }
-    while(1){/*入力を監視するファイル記述子の集合を変数rfdsにセットする*/
+    while(1){
         FD_ZERO(&rfds);
-        FD_SET(0,&rfds);
         FD_SET(sock,&rfds);
-        kmax=sock;
+        fdmax=sock;
-        clen=sizeof(clt);
-       fprintf(stderr,"01\n");
-        for(h=0;h<MAXCLIENTS;h++){
+        for(int i=0;i<MAXCLIENTS;i++){
-            if(csock[h]!=-1){
+            if(csock[i]>0){
-        FD_SET(csock[h],&rfds);
-                if(csock[h] > kmax ) {
+                if(csock[i]>fdmax){
-                    kmax = csock[h];
+                    fdmax=csock[i];
-                    write(csock[h],"1connected\n",9);
-                    write(1,"connected\n",9);
-                    printf(" \n");
-                        if(sock==MAXCLIENTS-1){
-                            write(sock,"REQUEST REJECTED\n",17);
-                            close(sock);
-                            continue;
-                        }else if(sock<MAXCLIENTS-1){
-                            write(sock,"REQUEST ACCEPTED\n",17);
-                            read(sock,rbuf,sizeof(rbuf));
-                            for(int i=0;i<5;i++){
-                                if(strcmp(rbuf,USERNAME[i])==0){
-                                    write(sock,"USERNAME REJECTED\n",18);
-                                    close(sock);
-                                    continue;
-                                }else{
-                                    strcpy(USERNAME[i],rbuf);
-                                    write(sock,"USERNAME REGISTERED\n",20);
-                                    sock++;
-                                }
-                            }
-                        }
                 }
+                FD_SET(csock[i],&rfds);
             }
         }
-    /*監視す る待ち時間を1秒に設定*/
         tv.tv_sec = 1;
         tv.tv_usec = 0;/*標準入力とソケットからの受信を同時に監視する*/
+        section3:
-        if(select(kmax+1,&rfds,NULL,NULL,&tv)>0) {
+        if(select(fdmax+1,&rfds,NULL,NULL,&tv)>0){
-            if(FD_ISSET(sock,&rfds)) {
+            if(FD_ISSET(sock,&rfds)){
-                for(int i=0;i<k;i++){
+                for(int i=0;i<MAXCLIENTS;i++){
-                    fprintf(stderr,"02\n");
-                    if(csock[i]<0){
+                    clen=sizeof(clt);
-                        if ( ( csock[i] = accept(sock,(struct sockaddr *)&clt,&clen) ) <0 ) {
+                    if ( ( csock[i] = accept(sock,(struct sockaddr *)&clt,&clen) ) <0 ) {
-                            perror("accept");
+                        perror("accept");
-                            exit(2);
+                        exit(2);
-                        }
+                    }
+                    if(sock<MAXCLIENTS){
-                        fprintf(stderr,"03\n");
+                        write(csock[i],"REQUEST ACCEPTED\n",17);
                         nbytes=read(csock[i],rbuf,sizeof(rbuf));
+                        strncpy(Nbuf,rbuf,nbytes-1);
+                        Nbyte[i]=nbytes;
+                        flag=0;
-                        for(int j=0;j<k;j++){
+                        for(int j=0;j<MAXCLIENTS;j++){
-                            fprintf(stderr,"04\n");
+                            if(strcat(USERNAME[j],Nbuf)==0){
+                                flag=1;
-                            char usr_1[128]="<";
+                                char name[32]="REJECTED";
-                            char usr_2[]="<";
+                                write(csock[i],"USERNAME REJECTED\n",18);
-                            strcat(usr_1,USERNAME[i]);
-                            strcat(usr_1,usr_2);
-                            strcat(usr_1,rbuf);
+                                strcat(name,Nbuf);
+                                for(int k=0;k<MAXCLIENTS;k++)
-                                write(csock[j],usr_1,sizeof(usr_1));
+                                    write(csock[k],name,sizeof(name));
+                                close(csock[i]);
+                                goto section3;
+                            }
                         }
+                        if(flag==0){
+                            write(csock[i],"USERNAME REGISTERED\n",20);
+                            strncpy(USERNAME[i],Nbuf,Nbyte[i]-1);
+                            char nll[]="\0";
+                            strcat(USERNAME[i],nll);
+                            write(1,USERNAME[i],sizeof(USERNAME[i]));
+                            k++;
+                            goto section3;
+                        }
                     }
                 }
             }
-            for(int i=0;i<k;i++){
+            for(int i=0;i<MAXCLIENTS;i++){
                 if(FD_ISSET(csock[i],&rfds)){
-                    if(read(csock[i],rbuf,sizeof(rbuf))!=EOF){
+                    if(read(csock[i],rbuf,sizeof(rbuf))!=0){
+                        char STRING[64]="<";
+                        strcat(STRING,USERNAME[i]);
+                        strcat(STRING,"\0");
+                        strcat(STRING,">");
-                            close(csock[i]);
+                        strcat(STRING,rbuf);
+                        for(int j=0;j<MAXCLIENTS;j++){
+                            write(csock[j],STRING,sizeof(STRING));
+                        }
                     }else{
-                        nbytes=read(csock[i],rbuf,sizeof(rbuf));
-                        if(nbytes<=0)exit(1);
+                        fprintf(stderr,"01\n");
-                        write(0,rbuf,nbytes);
+                        close(csock[i]);
-                        for(int j=0;j<k;j++){
+                        for(int j=0;MAXCLIENTS;j++){
-                            if(j!=i){
-                                write(csock[j],rbuf,nbytes);
+                            write(csock[j],USERNAME[i],sizeof(USERNAME[i]));
-                            }
                         }
+                        USERNAME[i][0]='\0';
+                        k--;
                     }
-                }
+                }
             }
         }
     }