[Java] Problème échanges client-serveur (Résolu)

Problème échanges client-serveur (Résolu) [Java] - Java - Programmation

Marsh Posté le 25-05-2006 à 12:24:51    

Salut,
Dans le cadre d'un projet pour mon école, je dois programmer un petit jeu réseau.
Le problème est que l'échange de données entre le client et le serveur se fait bien au début, mais dès que le serveur lance le thread s'occupant du client, la réception plante  :??:  
 
voilà le code concerné :

Code :
  1. import java.net.*;
  2. import java.io.*;
  4. class ServerListen implements Runnable
  5. {
  6. private Socket socket = null;
  7. private Donnees baseDonnee = new Donnees();
  8. private DataPlayer joueur=null;
  9. private ObjectInputStream ois = null;
  10. private ServerStream serveur=null;
  11. private ObjectOutputStream oos = null;
  12. private OutputStream os=null;
  13. private int _numClient=0;
  15. public ServerListen(Socket socket, Donnees baseDonnee, ServerStream serveur)
  16.  {
  17.   this.socket=socket;
  18.   this.baseDonnee=baseDonnee;
  19.   this.serveur=serveur;
  20.   try {       
  21.                 InputStream is = socket.getInputStream();
  22.                 ObjectInputStream ois = new ObjectInputStream(is);
  23.                 OutputStream os = socket.getOutputStream();
  24.                 ObjectOutputStream oos = new ObjectOutputStream(os);
  25.                 _numClient = serveur.addClient(oos);
  26.                
  27.                 joueur = (DataPlayer)ois.readObject();
  28.                 } catch(Exception e) {System.err.println(e);}
  29.                System.out.println("<<ok reception data joueur" );
  30.              
  31.                 serveur.sendAll(baseDonnee);
  32.                 System.err.println(">>Ok envoi database" );
  33.                
  34.                 Thread t = new Thread(this);
  35.                 t.start();
  36.  }
  38. public void run()
  39.  {
  40.   System.out.println("Connection de "+joueur.getPseudo()+" ["+_numClient+"]" );
  41.    try {
  42.     while(true)
  43.    {
  44.    joueur = (DataPlayer)ois.readObject();
  45. //##############################################################
  46.    System.out.println("<<<ok reception data joueur "+_numClient);
  47.    baseDonnee.updateClient(joueur);
  48.    serveur.sendAll(baseDonnee);
  49.    }
  50.    } catch (Exception e) {System.err.println(e);}
  51.   finally
  52.        {
  53.         try
  54.           {
  55.                 System.out.println("deconnection de ["+_numClient+"]" );
  56.           serveur.delClient(_numClient);
  57.           socket.close();
  58.           }
  59.          catch (IOException e){ }
  60.        }
  61.  }}


Voici la partie du code du serveur, il plante à l'endroit avec les '###" et envoie comme erreur  
java.lang.NullPointerException
 

Code :
  1. mport java.io.*;
  2. import java.net.*;
  3. import java.awt.*;
  4. import javax.swing.*;
  5. import java.awt.event.*;
  7. class ClientListen extends Thread
  8. {
  9. DataPlayer joueur = new DataPlayer();
  10. Donnees baseDonnees=new Donnees();
  11. InputStream is = null;
  12. ObjectInputStream ois = null;
  13. OutputStream os = null;
  14. ObjectOutputStream oos = null;
  15. private Socket socket = null;
  17. public ClientListen(Socket socket, DataPlayer joueur)
  18.  {
  19.   this.socket=socket;
  20.   this.joueur=joueur;
  21.   joueur.setPseudo("prout" );
  22.  try
  23.  {
  24. os = socket.getOutputStream();
  25.         oos = new ObjectOutputStream(os);
  26. is = socket.getInputStream();
  27.         ois = new ObjectInputStream(is);
  28.        
  29.  }
  30.  catch (Exception e) {System.err.println(e);}
  31.  this.start();
  32.  }
  34. public synchronized Donnees getDonnees()
  35.  {
  36.   return baseDonnees;
  37.  }
  39. public void run()
  40.  {
  41.   System.out.println("##Ok connexion" );
  42.  try
  43.   {
  44.   while (true)
  45.    {
  46.    oos.writeObject(joueur);
  47.                          System.out.println(">>Ok envoi data joueur" );
  48. //############################################################
  49.    baseDonnees = (Donnees)ois.readObject();
  50.                                 System.out.println("<<Ok reception database" );
  51.    }
  52.   }
  53.  catch (Exception e) {System.err.println(e);}
  54.  finally
  55.   {
  56.   System.out.println("Connexion interrompue\n" );
  57.   }}}


Voilà le code du client, qui plante à l'endroit avec les '###" avec le message suivant :
java.net.SocketException: Software caused connection abort: recv failed
 
Désolé pour la longueur, et merci d'avance si vous voyez d'où peut venir mon problème  :jap:


Message édité par Atropos le 26-05-2006 à 18:14:08
Reply

Marsh Posté le 25-05-2006 à 12:24:51   

Reply

Marsh Posté le 25-05-2006 à 12:31:30    

tu es sûr de ce que tu fais avec les Object Input/Output stream là? :o

Reply

Marsh Posté le 25-05-2006 à 12:36:15    

le client envoie les données "joueur" : oos.writeObject(joueur); et reçoit les données du serveur ("baseDonnees" ) : baseDonnees = (Donnees)ois.readObject();
 
Le serveur lui fait l'inverse : il reçoit les données "joueur" et envoie aux clients les données "baseDonnees" :

joueur = (DataPlayer)ois.readObject();
serveur.sendAll(baseDonnee);

 
J'avoue que j'ai un peu de mal à saisir comment envoyer des objets, mais ça fonctionne bien une première fois, donc je ne vois pas où est mon erreur :??:

Reply

Marsh Posté le 26-05-2006 à 14:53:36    

Bon j'ai tout repris à plat et maintenant je n'ai plus de plantages :)
Par contre le premier echange se passe bien, mais dès le second le serveur ne semble pas recevoir les infos mises à jour.
En effet lorsque je tape une phrase à envoyer au serveur, si c'est la premiere il la reçoit bien mais dès la deuxieme il ré-affiche la première :/  
Voilà le nouveau code :  
 
Coté serveur :

Code :
  1. import java.net.*;
  2. import java.io.*;
  4. class ServerListen implements Runnable
  5. {
  6. private Socket socket = null;
  7. private Donnees baseDonnee = new Donnees();
  8. private DataPlayer joueur=null;
  9. private ObjectInputStream ois = null;
  10. private ServerStream serveur=null;
  11. private ObjectOutputStream oos = null;
  12. private OutputStream os=null;
  13. private int _numClient=0;
  15. public ServerListen(Socket socket, Donnees baseDonnee, ServerStream serveur)
  16.  {
  17.   this.socket=socket;
  18.   this.baseDonnee=baseDonnee;
  19.   this.serveur=serveur;
  20.            
  21.                 Thread t = new Thread(this);
  22.                 t.start();
  23.  }
  25. public void run()
  26.  {
  27.     int test=0;
  28.    try {
  30.    InputStream is = socket.getInputStream();
  31.                 ObjectInputStream ois = new ObjectInputStream(is);
  32.                 OutputStream os = socket.getOutputStream();
  33.                 ObjectOutputStream oos = new ObjectOutputStream(os);
  34.                 _numClient = serveur.addClient(oos);
  35.                 System.out.println("Connection de ["+_numClient+"]" );
  36.                                
  37.     while(true)
  38.    {
  40.    joueur = (DataPlayer)ois.readObject();
  41.    if (test==0) baseDonnee.addClient(joueur);
  42.    test=1;
  43.    baseDonnee.updateClient(joueur);
  44.    serveur.sendAll(baseDonnee);
  45.    System.out.println("["+_numClient+"] "+joueur.getPseudo()+" : "+joueur.getMessage());
  46.    System.out.println(joueur.getCoordx());
  47.    }
  48.    } catch (Exception e) {System.err.println(e);}
  50.    finally
  51.        {
  52.         try
  53.           {
  54.      
  55.           System.out.println("deconnection de ["+_numClient+"]" );
  56.           serveur.delClient(_numClient);
  57.           baseDonnee.removeClient(joueur);
  58.           socket.close();
  59.           }
  60.          catch (IOException e){System.err.println(e); }
  61.        }
  62.  }
  65. }


 
Et coté client :

Code :
  1. import java.io.*;
  2. import java.net.*;
  3. import java.awt.*;
  4. import javax.swing.*;
  5. import java.awt.event.*;
  7. class ClientListen extends Thread
  8. {
  9. DataPlayer joueur = new DataPlayer();
  10. Donnees baseDonnees=new Donnees();
  11. InputStream is = null;
  12. ObjectInputStream ois = null;
  13. OutputStream os = null;
  14. ObjectOutputStream oos = null;
  15. private Socket socket = null;
  16. BufferedReader IN=null;
  19. public ClientListen(Socket socket)
  20.  {
  21.   this.socket=socket;
  22.   this.start();
  23.  }
  25. public synchronized Donnees getDonnees()
  26.  {
  27.   return baseDonnees;
  28.  }
  30. public void run()
  31.  {
  33.  String demande="";
  35.  try
  36.  {
  37.     os = socket.getOutputStream();
  38.         oos = new ObjectOutputStream(os);
  39.  is = socket.getInputStream();
  40.         ois = new ObjectInputStream(is);
  41.         IN = new BufferedReader(new InputStreamReader(System.in));
  42.        
  43.         System.out.println("Pseudo : \n" );
  44.         demande=IN.readLine();
  45.  joueur.setPseudo(demande);
  46.         demande="";
  47.  }
  48.  catch (Exception e) {System.err.println(e);}
  50.  System.out.println("##Ok connexion" );
  52.  try
  53.   {
  54.   while (true)
  55.    {
  56.     if ((demande=IN.readLine())!=null) joueur.setMessage(demande);
  57.    joueur.setCoordx(joueur.getCoordx()+1);
  58.    oos.writeObject(joueur);
  59.    baseDonnees = (Donnees)ois.readObject();
  60.    }
  61.   }
  63.  catch (Exception e) {System.err.println(e);}
  65.  finally
  66.   {
  67.   System.out.println("Connexion interrompue\n" );
  68.   }
  70.  }
  72. }


 
Voilà à mon avis il y a quelque chose que je n'ai pas compris dans les échanges entre clients et serveur en java mais je n'arrive pas à mettre le doigt dessus :(

Reply

Marsh Posté le 26-05-2006 à 16:05:01    

Tu voudrais pas essayer d'isoler un peu le probleme parce que lire tes pavés avec potentiellement 90% de code qui n'a rien a voir avec le probleme c'est lourd.  
Ca te permettrai aussi de reflechir un peu et de dérouler ton programme dans ta tete (puisque t'as pas l'air d'avoir de debugger sous la main)

Message cité 1 fois

---------------
Posté depuis des chiottes, sales. Me gusta.
Reply

Marsh Posté le 26-05-2006 à 16:48:30    

boulax a écrit :

Tu voudrais pas essayer d'isoler un peu le probleme parce que lire tes pavés avec potentiellement 90% de code qui n'a rien a voir avec le probleme c'est lourd.  
Ca te permettrai aussi de reflechir un peu et de dérouler ton programme dans ta tete (puisque t'as pas l'air d'avoir de debugger sous la main)


 
Voilà prise isolément la partie "serveur" qui s'occupe de récupérer les infos d'un client et d'envoyer à tous les clients ses données :
 

Code :
  1. while(true)
  2.   {
  4.    joueur = (DataPlayer)ois.readObject();
  5.    baseDonnee.updateClient(joueur);
  6.    serveur.sendAll(baseDonnee);
  7.    System.out.println("["+_numClient+"] "+joueur.getPseudo()+" : "+joueur.getMessage());
  8.   }


 
et pour le Client, qui reçoit les données du serveur et envoie ses infos :
 

Code :
  1. while (true)
  2.   {
  3.                                 //Ici les données "joueur" étaient modifiées
  4.    oos.writeObject(joueur);
  5.    baseDonnees = (Donnees)ois.readObject();
  6.   }


 
Voilà et si la première boucle semble se dérouler correctement, dès la deuxième boucle on dirait que le programme envoie toujours les mêmes données  :??:

Reply

Marsh Posté le 26-05-2006 à 18:13:41    

En fait j'ai trouvé, il fallait utiliser writeUnshared au lieu de writeObject :o

Reply

Marsh Posté le 31-05-2006 à 10:59:12    

bonjour  
voila g eu les codes source d'un logiciel que je devai mettre sur pieds pour mon memoire.
mais voila:il se compose de plusieurs fichiers.
mon probleme est de pouvoir extirper l'arboressence pour la compilation
merci pour votre aide

Reply

Marsh Posté le 09-06-2006 à 16:51:04    

:heink:

Reply

Sujets relatifs:

Leave a Replay

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