Flux avec socket

**b_imen** · 24/02/2011, 10h24

Bonjour,
mon problème tourne autour l'envoi de messages depuis et vers la socket..
ce que je veux obtenir est qu'à chaque envoi de message depuis une console dos vers mon serveur, ce dernier me renvoie "message reçu"..
mais, je n'obtient cette résultat que seulement pour le premier message..
voici le code:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 public void run() {
 
            try{
                soc = ser.accept();
                jta.append("["+new Date(DateFormat.LONG)+"]>Connection acceptée via le port--> "+soc.getPort()+"\r\n");
                jta.append("["+new Date(DateFormat.LONG)+"]>Le client: "+InetAddress.getLocalHost().getHostAddress()+"est connecté\n\n");
                jta.setCaretPosition(jta.getText().length());
                jScrollPane1.validate();
                out = new PrintWriter(soc.getOutputStream());
	        out.println("-Bonjour > "+InetAddress.getLocalHost().getHostAddress()+"\nVous êtes connecté\n");
		out.flush();
                in = new BufferedReader(new InputStreamReader(soc.getInputStream()));
                line = in.readLine();
                out.println("-Message reçu\n");
                out.flush();
                jta.append(line);
                while ((line = in.readLine()) != null)
                {
                    jta.append(line+"\n");
                    jta.setCaretPosition(jta.getText().length());
                    jScrollPane1.validate();
 
                    if(line.equals("exit"))
                    {
                        try
                        {
                            out.println("Au revoir "+InetAddress.getLocalHost().getHostAddress()+"\nvous êtes déconnecté");
                            out.flush();
                            soc.close();
                            jta.append("["+new Date(DateFormat.LONG)+"]>"+"SOCKET IS CLOSED >>> CONNECTION IS AVAILABLE\n\n");
                            jta.setCaretPosition(jta.getText().length());
                            jScrollPane1.validate();
                        }
                        catch(IOException e) {}
                    }
                   out.close();
                }
          }catch (Exception e) {}

et voici un imprime écran pour bien voir le problème..
je vous remercie d'avance

**MigouW** · 24/02/2011, 11h50

Le problème vient de la position de "Message Recu", il doit être placé dans la boucle pour etre répété a chaque lecture.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 
 public void run() {
 
            try{
                soc = ser.accept();
                jta.append("["+new Date(DateFormat.LONG)+"]>Connection acceptée via le port--> "+soc.getPort()+"\r\n");
                jta.append("["+new Date(DateFormat.LONG)+"]>Le client: "+InetAddress.getLocalHost().getHostAddress()+"est connecté\n\n");
                jta.setCaretPosition(jta.getText().length());
                jScrollPane1.validate();
                out = new PrintWriter(soc.getOutputStream());
	        out.println("-Bonjour > "+InetAddress.getLocalHost().getHostAddress()+"\nVous êtes connecté\n");
		out.flush();
                in = new BufferedReader(new InputStreamReader(soc.getInputStream()));
                // >>> Ce Code peut/doit etre déplacer dans la boucle
                // line = in.readLine(); Effectueé a chaque passage dans la boucle (dans la condition donc inutile de le faire avant)
                // out.println("-Message reçu\n"); placé dans la boucle
                // out.flush(); placé dans la boucle
                // jta.append(line); Effectué dans la boucle
                // <<< 
                while ((line = in.readLine()) != null)
                {
                    // >>> Code Ajouté
                    out.println("-Message reçu\n");
                    out.flush(); placé dans la boucle
                    // <<< 
                    jta.append(line+"\n");
                    jta.setCaretPosition(jta.getText().length());
                    jScrollPane1.validate();
 
                    if(line.equals("exit"))
                    {
                        try
                        {
                            out.println("Au revoir "+InetAddress.getLocalHost().getHostAddress()+"\nvous êtes déconnecté");
                            out.flush();
                            soc.close();
                            jta.append("["+new Date(DateFormat.LONG)+"]>"+"SOCKET IS CLOSED >>> CONNECTION IS AVAILABLE\n\n");
                            jta.setCaretPosition(jta.getText().length());
                            jScrollPane1.validate();
                        }
                        catch(IOException e) {}
                    }
                   out.close();
                }
          }catch (Exception e) {}

**b_imen** · 24/02/2011, 13h29

je vous remercie pour votre réponse..mais maintenant que je modifie mon code de la façon que vous m'avez proposez..les résultats changent complètement de telle façon que je ne peut qu'envoyer deux messages depuis la console et il y a fermeture automatique de la socket..veuillez m'aider

voici le nouveau code:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
public void run() {
 
            try{
                soc = ser.accept();
                jta.append("["+new Date(DateFormat.LONG)+"]>Connection acceptée via le port--> "+soc.getPort()+"\r\n");
                jta.append("["+new Date(DateFormat.LONG)+"]>Le client "+nbrclient+" : "+InetAddress.getLocalHost().getHostAddress()+" est connecté\n\n");
                jta.setCaretPosition(jta.getText().length());
                jScrollPane1.validate();
                out = new PrintWriter(soc.getOutputStream());
	        out.println("-Bonjour > "+InetAddress.getLocalHost().getHostAddress()+"\nVous êtes connecté\n");
		out.flush();
                in = new BufferedReader(new InputStreamReader(soc.getInputStream()));
 
                while ((line = in.readLine()) != null)
                {
                    line = in.readLine();
                    out.println("-Message reçu\n");
                    out.flush();
                    jta.append(line+"\n");
                    jta.setCaretPosition(jta.getText().length());
                    jScrollPane1.validate();
 
                    if(line.equals("exit"))
                    {
                        try
                        {
                            out.println("Au revoir "+nbrclient+" "+InetAddress.getLocalHost().getHostAddress()+"\nvous êtes déconnecté");
                            out.flush();
                            soc.close();
                            jta.append("["+new Date(DateFormat.LONG)+"]>"+"SOCKET IS CLOSED >>> CONNECTION IS AVAILABLE\n\n");
                            jta.setCaretPosition(jta.getText().length());
                            jScrollPane1.validate();
                        }
                        catch(IOException e) {}
                    }
                   out.close();
                }
          }catch (Exception e) {}

et voici un imprime ecran

**MigouW** · 24/02/2011, 14h15

Je n'ai pas la possibilité de tester mais je pense qu'il faut supprimer "line = in.readLine();" situé dans la boucle.

**sayebni** · 25/02/2011, 15h06

Ca devrait fonctionner comme ca

Fais attention à où tu ouvre un writer et où tu le ferme et je te conseille de lire la doc pour comprendre les méthodes comme readLine.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
public void run() {
 
        try{
            soc = ser.accept();
            jta.append("["+new Date(DateFormat.LONG)+"]>Connection acceptée via le port--> "+soc.getPort()+"\r\n");
            jta.append("["+new Date(DateFormat.LONG)+"]>Le client "+nbrclient+" : "+InetAddress.getLocalHost().getHostAddress()+" est connecté\n\n");
            jta.setCaretPosition(jta.getText().length());
            jScrollPane1.validate();
            out = new PrintWriter(soc.getOutputStream());
	        out.println("-Bonjour > "+InetAddress.getLocalHost().getHostAddress()+"\nVous êtes connecté\n");
	        out.flush();
            in = new BufferedReader(new InputStreamReader(soc.getInputStream()));
 
            while ((line = in.readLine()) != null) //readLine() lit une ligne et se déplace sur la suivante!!
            {
                //line = in.readLine();//donc jusque ici t'a deux lignes lues du coup
            	//c'est pour ca que tu a dit que tu ne peux envoyer que 2 messages
                out.println("-Message reçu\n");
                out.flush();
                jta.append(line+"\n");
                jta.setCaretPosition(jta.getText().length());
                jScrollPane1.validate();
 
                if(line.equals("exit"))
                {//debut if
                    try
                    {
                        out.println("Au revoir "+nbrclient+" "+InetAddress.getLocalHost().getHostAddress()+"\nvous êtes déconnecté");
                        out.flush();
                        soc.close();
                        jta.append("["+new Date(DateFormat.LONG)+"]>"+"SOCKET IS CLOSED >>> CONNECTION IS AVAILABLE\n\n");
                        jta.setCaretPosition(jta.getText().length());
                        jScrollPane1.validate();
                        out.close(); // tu dois fermer ici ton PrintWriter en recevant "exit", car tu dois etre dans le bloc du if!!
                    }
                    catch(IOException e) {}
                }//fin if !!
 
                // out.close(); 
                //si tu ferme  le PrintWriter ici dans la boucle while c'est normal tu ne peux
                //plus rien écrire après car ligne sera null et tu sors de la while
 
            }
            //la while fini ici sa boucle car quand la ligne est null à la fin du stream on passe ici
            // donc la boucle sera fini quand  le PrintWriter est clos ok
      }catch (Exception e) {}

**MigouW** · 25/02/2011, 17h00

Exactement ce que je disais pour le readline ^^

**b_imen** · 28/02/2011, 10h18

je vous remercie pour vos réponse..elles m'ont éclairci tant de chose surtout pour le readline..merci MigouW et sayebni..mais, quant à votre proposition sayebni, elle n'a pas résolu le problème..en fait, d'autres apparaissent:
le serveur ne reçoit pas le premier message depuis la console
il y a une sortie automatique après le deuxième message
et "message reçu n'apparait que pour le deuxième message
je m'excuse si je vous casse la tête mais j'ai vraiment besoin de votre aide
Merci
pj: un imprime ecran qui visualise le probleme

**b_imen** · 14/03/2011, 13h28

enfin, j'ai résolu le problème

le out.flush a résolu mon problème
voila le nouveau code:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 public void run() {
 
            try{
                soc = ser.accept();
                jta.append("["+new Date(DateFormat.LONG)+"]>Connection acceptée via le port--> "+soc.getPort()+"\r\n");
                jta.append("["+new Date(DateFormat.LONG)+"]>Le client "+nbrclient+" : "+InetAddress.getLocalHost().getHostAddress()+" est connecté\n\n");
                jta.setCaretPosition(jta.getText().length());
                jScrollPane1.validate();
                out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(soc.getOutputStream())),true);
                out.flush();
	        out.println("-Bonjour > "+InetAddress.getLocalHost().getHostAddress()+"\nVous êtes connecté\n");
		out.flush();
                //in = new BufferedReader(new InputStreamReader(soc.getInputStream()));
                //line = in.readLine();
                jta.append(line+"\n");
                while ((line = in.readLine()) != null)
                {
                    //line = in.readLine();
                    in = new BufferedReader(new InputStreamReader(soc.getInputStream()));
                    out.println("-Message reçu\n");
                    out.flush();
                    jta.append(line+"\n");
                    jta.setCaretPosition(jta.getText().length());
                    jScrollPane1.validate();
 
                    if(line.equals("exit"))
                    {
                        try
                        {
                            out.println("Au revoir "+nbrclient+" "+InetAddress.getLocalHost().getHostAddress()+"\nvous êtes déconnecté");
                            out.flush();
                            jta.append("["+new Date(DateFormat.LONG)+"]>"+"SOCKET IS CLOSED >>> CONNECTION IS AVAILABLE\n\n");
                            jta.setCaretPosition(jta.getText().length());
                            jScrollPane1.validate();
                            in.close();
                            out.close();
                            soc.close();
 
                        }
                        catch(IOException e) {}
                    }
 
                }
          }catch (Exception e) {}
    }

à un autre problème

**MigouW** · 14/03/2011, 13h31

Flux avec socket

Entrée/Sortie Java

Discussions similaires

Partager

Partager