Discussion :

[agent24]

Bonjour tt le monde !
Voilà j'ai un problème pour mettre en place une communication client/serveur qui interagissent entre eux. J'ai essayé donc avec des threads pour la saisie (avec un scanner) et la récupération du msg.
En gros, le problème c'est que un client envoie son msg, et puis il rentre dans une phase "bloquante", il faut que le serveur lui répond une fois pour pouvoir "débloquer" le client.

Voici mes classes

ClientEcho.java

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
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
 
import java.io.*;
import java.net.*;
import java.util.Scanner;
public class ClientEcho {
 
  public static void main(String[] args) throws IOException {
    if (args.length != 1) {
      System.out.println("Usage : java ClientEcho hostName" );
      System.exit(1);
    }
    String hostName = args[0]; 
    Socket sock = null;
    PrintWriter sockOut = null;
    BufferedReader sockIn = null;
 
    try {
      sock = new Socket(hostName, 7777);
      sockOut = new PrintWriter(sock.getOutputStream(), true);
      sockIn = new BufferedReader(new InputStreamReader(
                                      sock.getInputStream()));
    } catch (UnknownHostException e) {
      System.err.println("host non atteignable : "+hostName);
      System.exit(1);
    } catch (IOException e) {
      System.err.println("connection impossible avec : "+hostName);
      System.exit(1);
    }
    System.out.println("tapez q pour terminer"); 
    String recu = "";
	Scanner scan = new Scanner(System.in);
	new Thread(new Runnable(){
        public void run(){
            try {
            	if(scan.next() != null){
    				message = scan.next();
    				sockOut.println(message);
    			}
            }catch(Exception e){
 
            }
        }
	}).start();
 
	new Thread(new Runnable(){
        public void run(){
            try {
 
            	while (! message.equals("q")) {
            	      sockOut.println(message);
            		  try{
            			recu = sockIn.readLine();
            	      }catch( java.net.SocketException se){
            		  }
            	      System.out.println("echo serveur: " + recu.trim());
 
            			if (recu == null) {
            	        System.out.println("erreur de connection");
            	        break;
            	      }
            	    }
            }catch(Exception e){
 
            }
        }
	}).start();
 
 
    sockOut.close();
    sockIn.close();
    sock.close();
  }
}

Voici la classe ServerEcho.java

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
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
 
import java.net.*;
import java.io.*;
import java.util.Scanner;
class ServerEcho {
 
 
 
  public static void main(String args[]) {
    ServerSocket server = null;
	BufferedReader console = null;
    try {
      server = new ServerSocket(7777);
      while (true) {
        Socket sock = server.accept();
        System.out.println("accept");
        PrintWriter sockOut = new PrintWriter(sock.getOutputStream(), true);
        BufferedReader sockIn = new BufferedReader(new InputStreamReader(sock.getInputStream()));
        String recu;
		String message="";
		Scanner scan = new Scanner(System.in);
        new Thread(new Runnable(){
            public void run(){
                try {
                	if(scan.next() != null){
        				try{
        					scan.notify();
        				}catch(java.lang.IllegalMonitorStateException i){
        				}
        				message = scan.next().toLowerCase();
        				sockOut.println(message);
        			}
                }
                catch(Exception e){
 
                }
            }
        }).start();
 
        new Thread(new Runnable(){
            public void run(){
                try {
 
			        while ((recu = sockIn.readLine()) != null) {
 
						System.out.println("recu client:"+recu);
						if (recu == null) {
							System.out.println("erreur de connection");
							break;
						}
 
			        }
                }
            }
        }).start();
 
        sockOut.close();
        sock.close();
      }
    } catch (IOException e) {
      System.out.println(e.getMessage());
    } finally {
      try {
        server.close();
      } catch (IOException e2) {     
        System.out.println(e2.getMessage());
      }
    }
  }
 
}

Merci de votre aide

[tchize_]

Premièrement, tu devrais éviter les catch vides. si un problème survient, tu ne le saura jamais.

Ensuite, ton premier thread n'envoie qu'un message. Ton deuxième envoie en continu le même message et, en alternance, attends un réponse du serveur.

Si tu veux ne pas bloquer en attendant le serveur, tu dois avoir un thread qui scan (comme le premier), mais dans un boucle, et qui envoie les message.

Le secon ne se charge que de la réception.

Bref, éviter d'alterner réception et émission dans le même thread.