bloquage d'un client de chat (socket et thread)

Version imprimable

salut, je develope un petit chat client serveur en java, dans ce chat le client dés qu'il se connecte il récupere la liste des utilisateurs connectés de puis le serveur et remplie une jlist avec la liste, le probleme c'est que le client se bloque apres qu'il consulte le serveur, voila le code client et serveur, et merci pour l'aide.

si vous avez des idées pour faire cela autrement, elles sont lesbienvenue.

code serveur:

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
 
Thread threadlistpseudo=new Thread()
                    {
                        public PrintWriter out=null;
                        public BufferedReader in=null;
                        public ServerSocket sEcoute=null;
                        public Socket sService=null;
 
                        public void run()
                        {
                            ////////repondre a la requete du client pour lui communiquer la liste des pseudo
                            try{
                                    Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
                                    con = DriverManager.getConnection(url);
                                    stm = con.createStatement();
                                    sEcoute =new ServerSocket(3500);
                                    sService=sEcoute.accept();
                                    out=new PrintWriter(sService.getOutputStream(),true);
                                    in=new BufferedReader(new InputStreamReader(sService.getInputStream()));
 
                                    String query=in.readLine();
                                    rst=stm.executeQuery(query);
 
                                    while(rst.next())
                                    {
                                        out.write(rst.getString(1)+ "\r\n");
                                        out.flush();
                                    }
                                    out.flush();
                                    sEcoute.close();
 
                            }catch(Exception ex){System.out.println(ex.getMessage());}
                        }
                    };
                    threadlistpseudo.start();

code client:

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
 
public void windowOpened(java.awt.event.WindowEvent e) {
            ///////requete pour demander la liste des connectés depuis le serveur
                try {
                    ///state='c' =>connecté
                    String req1="select login from authentification where state='c'";
                    sClient =new Socket("localhost",3500);
                    out=new PrintWriter(sClient.getOutputStream(),true); 
                    out.write(req1+ "\r\n"); 
                    out.flush();
 
                    in=new BufferedReader(new InputStreamReader(sClient.getInputStream()));
                    String req=in.readLine();
                    DefaultListModel dlm=new DefaultListModel();
                    lpseudo.setModel(dlm);
                    while(req!=null)
                    { 
                        req=in.readLine();  
                        lpseudo.setModel(dlm);
                        dlm.addElement(req);    
                        lpseudo=new JList(dlm);        
                    }
                    sClient.close();
                } catch (Exception ex) {System.out.println(ex.getMessage());
}

22/01/2009, 16h04
dinobogan

Il ne fait rien d'autre ton client ?
Car dans ton code, tu te contentes de récupérer des infos du serveur puis tu coupes la connexion. Donc c'est normal que le client ne fasse rien d'autre.
De plus il ne faut pas placer ton code dans l'EDT (le Thread qui gère entre autre l'interface graphique). La méthode "windowOpened" est appelée dans l'EDT.
Pour plus d'infos sur l'EDT, regarde la FAQ et les tutoriels du site.
22/01/2009, 17h22
Taoufik109

mon client a pour rôle de charger la liste des utilisateurs connectés depuis la bd sur le serveur, ensuite je vais utiliser cette liste pour récupérer l'adresse ip des utilisateurs pour chater directement avec eux sans passer par le serveur,
mais le probleme ici, c'est que lorsque le client se connecte il recupere cette liste des gens connecté depuis le serveur mais il reste en attente de quelquechose du serveur avant d'afficher la liste, si je tape quelquechose dans le serveur, le client se libere et affiche la liste

Bonjour,

Ton client attend la fin de la communication (readLine). Ton serveur ne lui envoie aucun message. On pourrait indiquer la fin de la liste par l'envoi d'une ligne vide.

Serveur:

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
 
Thread threadlistpseudo = new Thread() {
   public PrintWriter out=null;
   public BufferedReader in=null;
   public ServerSocket sEcoute=null;
   public Socket sService=null;
 
   public void run() {
     ////////repondre a la requete du client pour lui communiquer la liste des pseudo
     try {
       Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
       con = DriverManager.getConnection(url);
       stm = con.createStatement();
       sEcoute =new ServerSocket(3500);
       sService=sEcoute.accept();
 
       out=new PrintWriter(sService.getOutputStream(),true);
       in=new BufferedReader(new InputStreamReader(sService.getInputStream()));
 
 
       String query = in.readLine();
       rst = stm.executeQuery(query);
 
       while (rst.next()) {
         out.write(rst.getString(1)+ "\r\n");
         // -FMa- Il ne serait à rien de flusher à chaque rien et peut ralentir l'exécution
         //out.flush();
       }
       // -FMa- On indique la fin de la liste
       out.write("\r\n"); 
       out.flush();
       // -FMa- On libère toute les ressources dans finally 
       //sEcoute.close();
     }
     catch (Exception ex){
       // _-FMa- Il serait préférable d'envoyer les messages sur la sortie erreur
       System.out.println(ex.getMessage());}
     }
     finally {
       // _-FMa- On libère les ressources
       /* A faire pour in, out, rst, stm et con */
     }
   };
   threadlistpseudo.start();

Client:

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
 
// -FMA- Même remarque que pour le programme serveur, on libère les ressources après les avoir utilisées.
public void windowOpened(java.awt.event.WindowEvent e) {
  ///////requete pour demander la liste des connectés depuis le serveur
  try {
    ///state='c' =>connecté
    String req1="select login from authentification where state='c'";
    sClient =new Socket("localhost",3500);
    out=new PrintWriter(sClient.getOutputStream(),true);
    out.write(req1+ "\r\n");
    out.flush();
 
    in=new BufferedReader(new InputStreamReader(sClient.getInputStream()));
    DefaultListModel dlm = new DefaultListModel();
    lpseudo.setModel(dlm);
    // -FMa- On lit une ligne et on la traite. Dans le programme original,
    // la première ligne n'était pas traitée.
    String req = in.readLine();
    while(req!=null && !"".equals(req)) {
      lpseudo.setModel(dlm);
      dlm.addElement(req);
      lpseudo=new JList(dlm);
      req=in.readLine();
    }
    sClient.close();
  }
  catch(Exception ex) {
    System.out.println(ex.getMessage());
  }
}