Problème server - server socket

Version imprimable

1 pièce(s) jointe(s)

Bonjour,

je dois développer une application genre msn qui permettra de communiquer entre deux ordinateurs.
J'ai codé une partie socket (client) et une partie serverSocket (serveur).

Mon problème avec mon code, c'est que j'attends l'envoi d'un msg du 2ème PC, je le reçois ca c'est bon. J'arrive à envoyer un msg moi aussi, mais lorsque j'envoi ce message je n'arrive pas a relancer ma fonction d'attente reception.

Voici mon code :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
 
private void Ecoute()
     {
      try {       
      oreille=new ServerSocket (1234);
      System.out.println("creation");
 
      while (connection=true)
       {
        Socket client=oreille.accept();
        // mise en attente d'une connexion
        InputStream entrée=client.getInputStream();
        OutputStream sortie=client.getOutputStream();
        //lecture d'un entier
        //int iClient=entrée.read();
        //envoie d'un octet
        //sortie.write(13);
        //lecture d'une chaine
        DataInputStream dataentrée=new DataInputStream(entrée);
        String chaineClient=dataentrée.readLine();
        //Scanner sc = new Scanner(System.in);
        System.out.print(chaineClient);
        //écriture d'une chaine
        //PrintStream printsortie=new PrintStream (sortie);
        //printsortie.write("la chaine que j'envoie au client");
        client.close();
        connection = false;
       }
      oreille.close();
      } 
     catch (IOException e) {
     // TODO Auto-generated catch block
      System.out.println("pas de connexion");}
     }
 
     //-------------------------------------------------------------
  //   GESTION DES INTERACTIONS
  //------------------------------------------------------------- 
     class boutonEnvoyerListener implements ActionListener
     {
     private String AdresseIP;
     private Socket s;
     private OutputStream sortie;
  public void actionPerformed(ActionEvent arg0)
      {
 
 
       TextBuffer += AdresseIp + " dit : " + TextIn.getText() + " \n";
 
       //TextBuffer = <html><body>Ligne 1<br />Ligne 2</body></html>;
       TextOut.setText(TextBuffer);
 
 
       TextIn.setText("");      
 
          try {
    oreille.close();
   } catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   this.AdresseIP = "192.168.0.2";       
 
   try
   {
    this.s=new Socket(AdresseIP,PortCom); 
    InputStream entree= s.getInputStream();
    this.sortie= s.getOutputStream();
    //this.EnvoyerMessage();
    PrintStream PrintSortie=new PrintStream(sortie);
    PrintSortie.println("coucou");
    s.close();
   }
   catch(UnknownHostException e)
   {
    System.out.println("serveur introuvable");
   }
   catch(IOException e)
   {
    System.out.println("impossible de se connecter");
   }
   connection = true;
      //Ecoute();    
      }
     }

Voila mes fonctions. La fonction Ecoute() attend un message. La fonction d'envoi ce fait lors d'un appui sur le bouton envoyer.
Pourriez vous me dire comment une fois que mon message est envoyé comment je peux repasser sur ma fonction Ecoute automatiquement.

Je vous joins mon projet complet en meme temps.

19/06/2009, 17h45
dinobogan

Tu fois faire de l'asynchrone entre l'envoi et la réception. Lorsque le ServerSocket accepte une connexion, tu dois démarrer un nouveau Thread pour gérer les envoi/réception de chaque client. La boucle "while" sera à placer dans le Thread client.
19/06/2009, 18h24
orj30754

Merci pour ta réponse, mais pour être sincère je débute en java et j'ai du mal à mettre en oeuvre ta réponse.

J'ai vu des exemples de code avec des threads pr les fonctions serverSocket mais je ne suis pas arrivé à la mettre en oeuvre.

Pourrais tu me faire une esquisse de code avec tes explications

salut

Vous avez deux fonctions qui vont remplir votre client

reception et envoi

pour l'envoi il n'y a pas de probleme parce que c'est ce qui va faire l'envoi
exemple

Code:

1
2
3
4
 
//le prosedure de envoyer ta chaine(se tu veu envoye) 
 
sortie.println(str);

et pour ta fonction qui fait la reception, elle doit etre lancee lorsque la connexion est acceptee avec un thread

Code:

1
2
3
4
 
   String chaineClient=dataentrée.readLine();
        //Scanner sc = new Scanner(System.in);
        System.out.print(chaineClient);

la solution c'est de cree une class qui fait la reception et une class qui fait l'envoi
class de reception

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 
public class ThreadReception extends Thread {
  Private InputStream entrée;
DataInputStream dataentrée;
public ThreadReception(InputStream IN)//constructeur de la class
{
entrée=IN;
dataentrée==new DataInputStream(entrée);
 
}
 
public void run()//la fct  qui s'excute lors appel le thead 
 {
    // faire la reception 
   try 
   {
        String chaineClient=dataentrée.readLine();
        System.out.print("Client :" + chaineClient);
   }
     catch(Exception f)
   {
      System.out.println("probleme de connexion :" + f.getMessage());
    }
  }
 
}

et la class d'envoi qui est votre class avec une petite modification

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
 
private void Ecoute()
     {
      try {       
      oreille=new ServerSocket (1234);
      System.out.println("creation");
 
 
        Socket client=oreille.accept();
        // mise en attente d'une connexion
        InputStream entrée=client.getInputStream();
        OutputStream sortie=client.getOutputStream();
//Lancement de reception       
ThreadReception reception=new ThreadReception(entrée);
reception.start();//l'excution de la thread (la fct run )
 
       }
      oreille.close();
      } 
     catch (IOException e) {
     // TODO Auto-generated catch block
      System.out.println("pas de connexion");}
     }
 
     //-------------------------------------------------------------
  //   GESTION DES INTERACTIONS
  //------------------------------------------------------------- 
     class boutonEnvoyerListener implements ActionListener
     {
     private String AdresseIP;
     private Socket s;
     private OutputStream sortie;
  public void actionPerformed(ActionEvent arg0)
      {
 
 
       TextBuffer += AdresseIp + " dit : " + TextIn.getText() + " \n";
 
       //TextBuffer = <html><body>Ligne 1<br />Ligne 2</body></html>;
       TextOut.setText(TextBuffer);
 
 
       TextIn.setText("");      
 
          try {
    oreille.close();
   } catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
   this.AdresseIP = "192.168.0.2";       
 
   try
   {
    this.s=new Socket(AdresseIP,PortCom); 
    InputStream entree= s.getInputStream();
    this.sortie= s.getOutputStream();
    //this.EnvoyerMessage();
    PrintStream PrintSortie=new PrintStream(sortie);
    PrintSortie.println("coucou");
    s.close();
   }
   catch(UnknownHostException e)
   {
    System.out.println("serveur introuvable");
   }
   catch(IOException e)
   {
    System.out.println("impossible de se connecter");
   }
   connection = true;
      //Ecoute();    
      }
     }