Forum |  HardWare.fr | News | Articles | PC | S'identifier | S'inscrire | Shop Recherche
744 connectés 

  FORUM HardWare.fr
  Programmation
  C

  [C/java] Socket et thread

 
 


 Mot :   Pseudo :  
 
Bas de page
Auteur Sujet :

[C/java] Socket et thread

n°1501301
roms712
Posté le 10-01-2007 à 15:20:17  profilanswer
 

Bonjour,
 
je dois coder un système de ventes aux enchères en C pour le serveur et en java (interface graphique) pour le client
donc en gros, dès qu'il y a un accept() au niveau du serveur, on lance un thread avec en paramètre le socket renvoyé par le accept()
Pour l'instant ça fonctionne.
Dans la méthode associée au thread, on récupère une action (avec un switch) que le client a envoyé(par exemple 1 correspond à une inscription, 2 à une identification, etc)
Donc le serveur récupère bien ces informations avec un recv() quand le client valide son inscription.
Le problème se situe au niveau de la réponse du serveur, lorsque que le client clique par exemple pour valider son inscription, le serveur recoit bien les informations mais ici l'application client freeze et ne semble rien recevoir (readLine() bloquant au niveau du client ou send bloquant au niveau du serveur?)
Par contre l'application ne freeze pas (je reçois quelque chose au niveau du client) lorsque dans la routine du thread j'enleve le commentaire //sortie=TRUE; mais le problème c'est que le thread se termine et qu'on forme le socket client et donc aucun dialogue possible par la suite.
voici le code du serveur

Code :
  1. void* inscription(void *param)
  2. {
  3. char buf [1024];
  4. struct Client monClient;
  5. int action, sd_client;
  6. sd_client=*(int*)param;
  7. bool sortie=FALSE;
  8. while(!sortie)
  9. {
  10.  memset(buf,0,sizeof(buf));
  11.  recv(sd_client,buf,sizeof(buf),0);
  13.  //fprintf(stdout,"buf-> %s",buf);  
  14.  char *Tab = (char *) malloc ((1024+1) * sizeof (char));
  15.  for (z = 0; z < 1024; z++)
  16.   Tab [z] = buf[z];
  17.  Tab [z+1] = '\0';
  19.  //action=atoi(strtok(Tab,"|" ));  
  20.  action=atoi(Tab);
  21.  switch(action)
  22.  {
  23.   case 0: break;
  24.   case 1:
  25.    if(recv(sd_client,buf,sizeof(buf),0) != -1)
  26.    {
  27.     for (z = 0; z < 1024; z++)
  28.      Tab [z] = buf[z];
  29.     Tab [z+1] = '\0';
  30.     //fprintf(stdout,"%s","inscription" );
  31.     monClient.Nom=strtok(Tab,"|" );
  32.     monClient.Prenom=strtok(NULL,"|" );
  33.     monClient.Adresse=strtok(NULL,"|" );
  34.     monClient.Email=strtok(NULL,"|" );
  35.     monClient.Telephone=strtok(NULL,"|" );
  36.     monClient.IP=strtok(NULL,"|" );
  37.     monClient.MP=strtok(NULL,"|" ); 
  38.     fprintf(stdout,"%s\n",monClient.Nom);
  39.     fprintf(stdout,"%s\n",monClient.Prenom);
  40.     fprintf(stdout,"%s\n",monClient.Adresse);
  41.     fprintf(stdout,"%s\n",monClient.Email);
  42.     fprintf(stdout,"%s\n",monClient.Telephone);
  43.     fprintf(stdout,"%s\n",monClient.IP);
  44.     fprintf(stdout,"%s\n",monClient.MP);
  46.     deja_inscrit=0;
  47.     for(i=0;i<nb_clients_inscrits;i++)
  48.     {
  49.      if(strcmp(Clients[i].Email,monClient.Email) == 0)
  50.      {
  51.       deja_inscrit=1;
  52.      }
  53.     }
  55.     if(deja_inscrit == 0)
  56.     {
  57.      nb_clients_inscrits++;
  58.      Clients=realloc(Clients,nb_clients_inscrits*sizeof(monClient));
  59.      Clients[nb_clients_inscrits-1]=monClient;
  60.      fprintf(stdout,"Inscription reussie pour %s\n",Clients[nb_clients_inscrits-1].Nom);
  61.      fprintf(stdout,"%s",msg);
  62.      strcpy(test,"Inscription reussie!" );
  63.      //sortie=TRUE;
  64.     }
  65.     else
  66.     {
  67.      fprintf(stdout,"Inscription KO pour %s\n",monClient. Nom);
  68.      fprintf(stdout,"%s",msg);
  69.      strcpy(test,"Vous etes deja inscrit!" );
  70.     }
  71.  
  72.     fprintf(stdout,"Nombre d'inscrits : %d\n", nb_clients_inscrits);
  73.     for(i=0;i<nb_clients_inscrits;i++)
  74.     {
  75.      fprintf(stdout, "mail  : %s\n", Clients[i].Email);
  76.     }
  79.     //n=write(sd_client,test,strlen(test));
  80.     if(send(sd_client,test, strlen(test),0) == -1)
  81.     {
  82.      perror("erreur send" );
  83.     }
  84.     /*if(n < 0)
  85.     {
  86.      perror("erreur write" );
  87.     }
  88.     else
  89.     {
  90.      fprintf(stdout,"message envoye -> %s",test);
  91.     }*/
  92.    }
  93.     break;
  94.   case 2:
  95.    [...]
  96.    break;
  97.   case 3:
  98.    [...]
  99.    break;
  100.  }
  101. }//fin du while
  102. close(sd_client);
  103. pthread_exit(0);
  104. }


 
Ensuite dans le main() j'ai ça (je déclare un socket + bind + listen juste avant)

Code :
  1. while(1) /* Si demande de connexion ouvre une socket pour celle-ci */
  2. {
  3.     msgsock = accept(sock, (struct sockaddr *)&emis,&lemis);
  4.     if (msgsock < 0) perror("accept" );
  5.  else
  6.  {
  7.   if (getsockname (msgsock,(struct sockaddr *)&emis, &lemis) < 0)
  8.   {
  9.        perror ("getsockname" ); close (sock); return 1;
  10.   }
  11.   /* ntohs conversion entiers format réseau to hote */
  12.   printf ("Socket TCP emetteur %s port #%d\n", inet_ntoa(emis.sin_addr.s_addr), ntohs (emis.sin_port));
  13.   if (pthread_create(&thread_inscription, NULL,inscription, &msgsock) == -1)
  14.   {
  15.      perror("Unable to create the thread" );
  16.   }
  19.  }
  21. }
  22. close(sock);


 
au niveau du client :  

Code :
  1. private void bt_valider_inscriptionActionPerformed(java.awt.event.ActionEvent evt) {
  2.         String retour="";
  4.         if(TestVariable(tf_nom.getText()) && TestVariable(tf_prenom.getText()) && TestVariable(tf_adresse.getText()) && TestVariable(tf_email.getText()) && TestVariable(tf_tel.getText()) && TestVariable(new String(tf_mdp.getPassword())))
  5.         {
  6.            
  7.             try
  8.             {
  9.                 String ip="";
  10.                 ip = InetAddress.getLocalHost().getHostAddress();
  11.                 leClient=new structClient();
  12.                 leClient.setAdresse(tf_adresse.getText());
  13.                 leClient.setEmail(tf_email.getText());
  14.                 leClient.setIP(ip);
  15.                 leClient.setNom(tf_nom.getText());
  16.                 leClient.setPrenom(tf_prenom.getText());
  17.                 leClient.setTel(tf_tel.getText());
  18.                 leClient.setMP(new String(tf_mdp.getPassword()));
  19.                 pred.println(INSCRIPTION);
  20.                 pred.println(leClient.getNom()+"|"+leClient.getPrenom()+"|"+leClient.getAdresse()+"|"+leClient.getEmail()+"|"+leClient.getTel()+"|"+leClient.getIP()+"|"+leClient.getMP());          // envoi d'un message   */
  21.                 System.out.println(leClient.getNom()+"|"+leClient.getPrenom()+"|"+leClient.getAdresse()+"|"+leClient.getEmail()+"|"+leClient.getTel()+"|"+leClient.getIP()+"|"+leClient.getMP());
  23.                     retour=plec.readLine();
  24.                     System.out.println("retour: "+retour+"\n" );
  25.                
  26.                 if(retour.equals("Vous etes deja inscrit!" ))
  27.                 {
  28.                     bt_valider_inscription.setEnabled(true);
  29.                     //Deconnexion();
  30.                     //if(!Connexion())
  31.                     //{
  32.                         JOptionPane.showMessageDialog(null,"Serveur pas en ligne" );
  33.                     //}
  34.                 }
  35.                 if(retour.equals("Inscription reussie!" ))
  36.                 {
  37.                     //bt_valider_inscription.setEnabled(false);
  38.                    // ActionsInscription.setEnabled(false);
  39.                    // ActionDesinscription.setEnabled(true);
  40.                 }
  41.                 JOptionPane.showMessageDialog(null,retour);
  42.             }
  43.            
  44.             catch(UnknownHostException e) { System.err.println(e); }
  45.             catch(IOException e) { }
  47.            
  48.         }
  49.         else
  50.         {
  51.             JOptionPane.showMessageDialog(null,"Un des champs n'est pas rempli" );
  52.         }
  54.     }


Message édité par roms712 le 10-01-2007 à 15:28:01
mood
Publicité
Posté le 10-01-2007 à 15:20:17  profilanswer
 


Aller à :
Ajouter une réponse
  FORUM HardWare.fr
  Programmation
  C

  [C/java] Socket et thread

 

Sujets relatifs
[JAVA] WebSphere configuration[Java] Serveur JAVA Web
API Sound java[Java] Problème TableModel sous Linux uniquement
java ServletDessiner un arbre en java?^^
Problème de réveil de ThreadJava threads : wait() & notify()
Probleme envoie de mails Java : courrier indésirable[C] Des accolades "just pour le fun" ?
Plus de sujets relatifs à : [C/java] Socket et thread

Forum MesDiscussions.Net, Version 2010.2
(c) 2000-2011 Doctissimo
Page générée en 0.085 secondes

Copyright © 1997-2022 Hardware.fr SARL (Signaler un contenu illicite / Données personnelles) / Groupe LDLC / Shop HFR