[C/java] Socket et thread

Marsh Posté le 10-01-2007 à 15:20:17

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 :

void* inscription(void *param)
{
char buf [1024];
struct Client monClient;
int action, sd_client;
sd_client=*(int*)param;
bool sortie=FALSE;
while(!sortie)
{
memset(buf,0,sizeof(buf));
recv(sd_client,buf,sizeof(buf),0);
//fprintf(stdout,"buf-> %s",buf);
char *Tab = (char *) malloc ((1024+1) * sizeof (char));
for (z = 0; z < 1024; z++)
Tab [z] = buf[z];
Tab [z+1] = '\0';
//action=atoi(strtok(Tab,"|" ));
action=atoi(Tab);
switch(action)
{
case 0: break;
case 1:
if(recv(sd_client,buf,sizeof(buf),0) != -1)
{
for (z = 0; z < 1024; z++)
Tab [z] = buf[z];
Tab [z+1] = '\0';
//fprintf(stdout,"%s","inscription" );
monClient.Nom=strtok(Tab,"|" );
monClient.Prenom=strtok(NULL,"|" );
monClient.Adresse=strtok(NULL,"|" );
monClient.Email=strtok(NULL,"|" );
monClient.Telephone=strtok(NULL,"|" );
monClient.IP=strtok(NULL,"|" );
monClient.MP=strtok(NULL,"|" );
fprintf(stdout,"%s\n",monClient.Nom);
fprintf(stdout,"%s\n",monClient.Prenom);
fprintf(stdout,"%s\n",monClient.Adresse);
fprintf(stdout,"%s\n",monClient.Email);
fprintf(stdout,"%s\n",monClient.Telephone);
fprintf(stdout,"%s\n",monClient.IP);
fprintf(stdout,"%s\n",monClient.MP);
deja_inscrit=0;
for(i=0;i<nb_clients_inscrits;i++)
{
if(strcmp(Clients[i].Email,monClient.Email) == 0)
{
deja_inscrit=1;
}
}
if(deja_inscrit == 0)
{
nb_clients_inscrits++;
Clients=realloc(Clients,nb_clients_inscrits*sizeof(monClient));
Clients[nb_clients_inscrits-1]=monClient;
fprintf(stdout,"Inscription reussie pour %s\n",Clients[nb_clients_inscrits-1].Nom);
fprintf(stdout,"%s",msg);
strcpy(test,"Inscription reussie!" );
//sortie=TRUE;
}
else
{
fprintf(stdout,"Inscription KO pour %s\n",monClient. Nom);
fprintf(stdout,"%s",msg);
strcpy(test,"Vous etes deja inscrit!" );
}
fprintf(stdout,"Nombre d'inscrits : %d\n", nb_clients_inscrits);
for(i=0;i<nb_clients_inscrits;i++)
{
fprintf(stdout, "mail : %s\n", Clients[i].Email);
}
//n=write(sd_client,test,strlen(test));
if(send(sd_client,test, strlen(test),0) == -1)
{
perror("erreur send" );
}
/*if(n < 0)
{
perror("erreur write" );
}
else
{
fprintf(stdout,"message envoye -> %s",test);
}*/
}
break;
case 2:
[...]
break;
case 3:
[...]
break;
}
}//fin du while
close(sd_client);
pthread_exit(0);
}

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

Code :

while(1) /* Si demande de connexion ouvre une socket pour celle-ci */
{
msgsock = accept(sock, (struct sockaddr *)&emis,&lemis);
if (msgsock < 0) perror("accept" );
else
{
if (getsockname (msgsock,(struct sockaddr *)&emis, &lemis) < 0)
{
perror ("getsockname" ); close (sock); return 1;
}
/* ntohs conversion entiers format rÃ©seau to hote */
printf ("Socket TCP emetteur %s port #%d\n", inet_ntoa(emis.sin_addr.s_addr), ntohs (emis.sin_port));
if (pthread_create(&thread_inscription, NULL,inscription, &msgsock) == -1)
{
perror("Unable to create the thread" );
}
}
}
close(sock);

au niveau du client :

Code :

private void bt_valider_inscriptionActionPerformed(java.awt.event.ActionEvent evt) {
String retour="";
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())))
{
try
{
String ip="";
ip = InetAddress.getLocalHost().getHostAddress();
leClient=new structClient();
leClient.setAdresse(tf_adresse.getText());
leClient.setEmail(tf_email.getText());
leClient.setIP(ip);
leClient.setNom(tf_nom.getText());
leClient.setPrenom(tf_prenom.getText());
leClient.setTel(tf_tel.getText());
leClient.setMP(new String(tf_mdp.getPassword()));
pred.println(INSCRIPTION);
pred.println(leClient.getNom()+"|"+leClient.getPrenom()+"|"+leClient.getAdresse()+"|"+leClient.getEmail()+"|"+leClient.getTel()+"|"+leClient.getIP()+"|"+leClient.getMP()); // envoi d'un message */
System.out.println(leClient.getNom()+"|"+leClient.getPrenom()+"|"+leClient.getAdresse()+"|"+leClient.getEmail()+"|"+leClient.getTel()+"|"+leClient.getIP()+"|"+leClient.getMP());
retour=plec.readLine();
System.out.println("retour: "+retour+"\n" );
if(retour.equals("Vous etes deja inscrit!" ))
{
bt_valider_inscription.setEnabled(true);
//Deconnexion();
//if(!Connexion())
//{
JOptionPane.showMessageDialog(null,"Serveur pas en ligne" );
//}
}
if(retour.equals("Inscription reussie!" ))
{
//bt_valider_inscription.setEnabled(false);
// ActionsInscription.setEnabled(false);
// ActionDesinscription.setEnabled(true);
}
JOptionPane.showMessageDialog(null,retour);
}
catch(UnknownHostException e) { System.err.println(e); }
catch(IOException e) { }
}
else
{
JOptionPane.showMessageDialog(null,"Un des champs n'est pas rempli" );
}
}

Message édité par roms712 le 10-01-2007 à 15:28:01

Marsh Posté le 10-01-2007 à 15:20:17

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed

Name *

Email *

URL

Message *