1

マルチクライアント チャット サーバーを使用していますが、何らかの理由で最初のクライアントのみが追加されています。チュートリアルを使用して、作業を開始しました。以下に私のコードを含めました。別のクライアントを追加しようとしても、追加されていないようです。クライアントを1つ追加すると、サーバーから希望どおりの応答が返されますが、最初に入力したメッセージのみが送信され、その後は正しく送信されなくなります。

サーバーコード: 

 int main(void)  
 {  
 struct sockaddr_in my_addr, cli_addr[10],cli_temp;  
 int sockfd;  
 socklen_t slen[10],slen_temp;

 slen_temp = sizeof(cli_temp);
 char buf[BUFLEN];  
 int clients = 0;
 int client_port[10];

 if ((sockfd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP))==-1)
 {
     printf("test\n");
     err("socket");  
 }else{  
     printf("Server : Socket() successful\n");  
 }   
 bzero(&my_addr, sizeof(my_addr));  
 my_addr.sin_family = AF_INET;  
 my_addr.sin_port = htons(PORT);  
 my_addr.sin_addr.s_addr = htonl(INADDR_ANY);  

 if (bind(sockfd, (struct sockaddr* ) &my_addr, sizeof(my_addr))==-1)
 {
     err("bind");  
 }else{
     printf("Server : bind() successful\n");  
 }

 int num_clients = 0;
 while(1)  
 {
     //receive
     printf("Receiving...\n");
     if (recvfrom(sockfd, buf, BUFLEN, 0, (struct sockaddr*)&cli_temp, &slen_temp)==-1)  
         err("recvfrom()");

     if (clients <= 10) {
        cli_addr[clients] = cli_temp;
        client_port[clients] = ntohs(cli_addr[clients].sin_port);
        clients++;
        printf("Client added\n");
        //printf("%d",clients);
        int i;
        for(i=0;sizeof(clients);i++) {
            sendto(sockfd, buf, BUFLEN, 0, (struct sockaddr*)&cli_addr[i], sizeof(cli_addr[i]));

        }
     }
 }  

 close(sockfd);  
 return 0;

}

役立つ場合に備えて、クライアントコードも含めました。

void err(char *s)  
{  
perror(s);  
exit(1);  
}  
sig_atomic_t child_exit_status;

void clean_up_child_process (int signal_number) 
{
/* Clean up the child process. */ 
int status; 
wait (&status); 
/* Store its exit status in a global variable. */ 
child_exit_status = status;
}

 int main(int argc, char** argv)  
 {  
 struct sockaddr_in serv_addr;  
 int sockfd, slen=sizeof(serv_addr);  
 char buf[BUFLEN];  
 struct sigaction sigchld_action; 
 memset (&sigchld_action, 0, sizeof (sigchld_action)); 
 sigchld_action.sa_handler = &clean_up_child_process; 
 sigaction (SIGCHLD, &sigchld_action, NULL);
 int pid,ppid;

 if(argc != 2)  
 {  
   printf("Usage : %s <Server-IP>\n",argv[0]);  
   exit(0);  
 }  

 if ((sockfd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP))==-1)  
     err("socket");  

 bzero(&serv_addr, sizeof(serv_addr));  
 serv_addr.sin_family = AF_INET;  
 serv_addr.sin_port = htons(PORT);  
 if (inet_aton(argv[1], &serv_addr.sin_addr)==0)  
 {  
     fprintf(stderr, "inet_aton() failed\n");  
     exit(1);  
 }
 pid = fork();
 if (pid<0) {
     err("Fork Error");
 }else if (pid==0) {
     //child process will receive from server
     while (1) {
         bzero(buf,BUFLEN);
         //printf("Attempting to READ to socket %d: ",sockfd);
         fflush(stdout);
         //recvfrom here
         if (recvfrom(sockfd, buf, BUFLEN, 0, (struct sockaddr*)&serv_addr, &slen)==-1)  
             err("recvfrom()");

         printf("The message from the server is: %s \n",buf);
         if (strcmp(buf,"bye\n") == 0) {
             ppid = getppid();
             kill(ppid, SIGUSR2);

             break;
         }
     }
 }else {
     //parent will send to server
     while(1){
         printf("Please enter the message to send: ");
         bzero(buf,BUFLEN);
         fgets(buf,BUFLEN,stdin);
         printf("Attempting to write to socket %d: ",sockfd);
         fflush(stdout);
         //send to here
         if (sendto(sockfd, buf, BUFLEN, 0, (struct sockaddr*)&serv_addr, slen)==-1)
         {
             err("sendto()");
         }
     }
 }
 close(sockfd);  
 return 0;

}

4

1 に答える 1

3

いくつかの問題が私に飛び出します。まず、メッセージを受信するたびに、それが新しいクライアントであると見なされます。メッセージのクライアント変数をインクリメントするだけでなく、配列をスキャンして送信元アドレスが既に存在するかどうかを確認する必要があります。次に、sizeof(clients)マシンで int が占めるバイト数に応じて、静的な値 (おそらく 4) を返します。そのループはfor( int i = 0; i < clients; i++ ).

使用されていないという名前の変数もありますnum_clients。それは何かのためにそこにあるはずで、混乱を引き起こしているのでしょうか?

最後に、あらゆる場所で魔法の値 10 を使用する代わりに、#define MAX_CONNECTIONS 10これらすべての数値を使用して MAX_CONNECTIONS に置き換えます。読みやすく、後で変更するのがはるかに簡単です。

于 2013-05-09T23:24:49.780 に答える