Flux avec socket

Version imprimable

1 pièce(s) jointe(s)

Flux avec socket

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:

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

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:

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) {}

1 pièce(s) jointe(s)

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 :cry:
voici le nouveau 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
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

24/02/2011, 14h15
MigouW

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

problème de flux avec socket

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:

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) {}

25/02/2011, 17h00
MigouW

Exactement ce que je disais pour le readline ^^ :ccool:
28/02/2011, 10h18
b_imen

1 pièce(s) jointe(s)

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

enfin, j'ai résolu le problème :ccool:
le out.flush a résolu mon problème
voila le nouveau 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
 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 ;) :D

14/03/2011, 13h31
MigouW

:ccool: