IO serveur et client ! erreur

Version imprimable

Bonjour voilà j'ai un problème avec la tentative de création d'un client / serveur.

voilà mes deux sources

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
31
32
33
34
35
36
37
38
39
40
41
 
import java.io.*;
import java.net.*;
import java.util.*;
 
public class main {
	public static void main(String args[]) {
		System.out.print("Bienvenue sur le chat client...");
 
		try {
			socket = new Socket("127.0.0.1",8080);
		}
		catch(Exception e) {
			System.out.print("Erreur ouverture du socket");
		}
 
		scanIn = new Scanner(System.in);
 
		try {
			out = new PrintWriter(socket.getOutputStream(),true);
		} catch (Exception e) {
			System.out.print("Erreur création flux sortant");
		}
 
		System.out.print("Variable initialisée : attente de la saisie...");
 
		String str;
		while(true) {
			str = scanIn.nextLine();
			out.println(str);
		}
 
	}
 
	private static Socket socket;
 
	private static Scanner scanIn ;
 
	private static PrintWriter out ;
 
}

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
import java.io.*;
import java.net.*;
import java.util.*;
 
public class main {
	public static void main(String args[]) {
 
		try {
			socket = new ServerSocket(8080);
		} catch (Exception e) {
			System.out.println("Erreur création du ServeurSocket");
		}
 
		try {
			s = socket.accept();
			in = new BufferedReader(new InputStreamReader(s.getInputStream()));
		} catch (Exception e) {
			System.out.println("Erreur : " + e);
		}
 
		String str = "";
		try {
			while ((str = in.readLine()) != null) {
				System.out.println(str);
			}
		} catch (Exception e) {
			System.out.println("Erreur IO " + e);
			System.out.println("str : " + str);
		}
 
	}
 
	private static ServerSocket socket;
 
	private static BufferedReader in;
 
	private static Socket s;
 
}

Voilà si je ferme le server brutalement ( avec la croix du haut par exemple ), le client ne s'en apperçois pas... comment faire donc pour éviter ce genre d'erreur ?
Et si jamais je coupe le client brutalement, alors une exception du type java.net.SocketException: Connection reset se lance...

aidez moi à modifier le code pour ne plus avoir ce genre de problème.

PS: je sais qu'il existe sur le site un tutos qui propose un serveur multi-thread, je l'ai lu mais maintenant j'aimerais essayer d'en faire un moi même.
Je tente déjà de le faire comme ceci et si il marche je passerais en Thread...

24/08/2006, 22h45
spekal

Lorsque tu coupes le client, cela coupe la liaison socket. Le serveur, qui est en écoute de la liaison socket, se rend compte de la coupure de cette liaison, et tu reçois une exception. C'est un mode de fonctionnement pratiquement normal : tu es en attente, et tu detectes par cette attente que la liaison est coupée. Il y a d'autres façons de procéder, mais celui-ci est parfaitement correct.

Lorsque tu coupes le serveur, le client, qui n'est pas en écoute de la liaison socket, (puisqu'il écoute la liaison System.in), ne reçoit bien évidemment aucune exception dûe à la coupure de socket. À lire ton code, cela devrait se produire lorsqu'il tentera d'écrire le contenu reçu de System.in vers le serveur.

Est-ce que tu comprends mieux ?
24/08/2006, 23h37
storm_3000

Donc si je veux voir pour le serveur si il est coupé ou non, je doit ouvrir une entrée ( client ) qui écoute les messages en provenance du serveur.
Si je reçois une exception, alors le serveur est coupé... ?

Si je suis en multi-thread et qu'une exception est levé, est que l'application va s'arrêter ? par ce que pour le moment, dès que je capte une exception, tout est coupé
25/08/2006, 00h04
le y@m's

Tu peux attraper les IOExceptions levées lors de l'écriture par le client (cf ce que t'as dit spekal). Sinon tu peux tester l'état de la connection au serveur avec la méthode isConnected() de la classe Socket.

Une remarque, pense à fermer tes fluxs (dans un bloc finally de préference) ;).

Ce que tu me conseil de faire par fermer les flux c'est :

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
 
import java.io.*;
import java.net.*;
import java.util.*;
 
public class main {
	public static void main(String args[]) {
		System.out.print("Bienvenue sur le chat client...");
 
		try {
			socket = new Socket("127.0.0.1",8080);
			scanIn = new Scanner(System.in);
 
			System.out.println(socket.getInetAddress().toString());
 
			try {
				out = new PrintWriter(socket.getOutputStream(),true);
			} catch (Exception e) {
				System.out.println("Erreur création flux sortant");
			}
 
			System.out.print("Variable initialisée : attente de la saisie...");
 
			String str;
			while(socket.isConnected()) {
				str = scanIn.nextLine();
				out.println(str);
			}
		}
		catch(Exception e) {
			System.out.println("Erreur ouverture du socket");
		}
		finally {
			out.close();
			scanIn.close();
			try {
			socket.close();
			}
			catch(Exception e) {
 
			}
		}
 
 
	}
 
	private static Socket socket;
 
	private static Scanner scanIn ;
 
	private static PrintWriter out ;
 
}

?

faut-il détruire les thread aussi ou est que ceci est automatique N

25/08/2006, 14h44
spekal

Moi je trouve ça bien :D Il y aurait encore plein de choses, mais ce sera pour une autre fois.

Un thread se termine simplement à la fin de la méthode run. (quel thread ? ).

Prochain exercice, pour compliquer : que le serveur soit capable de communiquer avec plusieurs clients. Bon week-end.

Pour fermer les fluxs, il est préférable d'utiliser des blocs try/finally différents .

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
 
public class Main {
    public static void main(String[] args) {
        Socket socket = null;
        Scanner scanIn = null;
        PrintWriter out = null;
        System.out.print("Bienvenue sur le chat client...");
        try {
            socket = new Socket("127.0.0.1", 8080);
            System.out.println(socket.getInetAddress().toString());
            scanIn = new Scanner(System.in);
            out = new PrintWriter(socket.getOutputStream(),true);
 
            System.out.print("Variable initialisée : attente de la saisie...");
            try {
                while(socket.isConnected()) {
                    String str = scanIn.nextLine();
                    out.println(str);
                }
            } finally {
                try {
                    out.close();
                } finally {
                    try {
                        scanIn.close();
                    } finally {
                        if(!socket.isClosed()) {
                            socket.close();
                        }
                    }
                }
            }
        } catch (UnknownHostException ex) {
            System.out.println("Serveur inconnu");
            ex.printStackTrace();
        } catch (IOException ex) {
            System.out.println("Erreur de flux");
            ex.printStackTrace();
        }
    }
}

Attention, car avec le

Code:

while(socket.isConnected())

ton client tournera tant que le serveur ne mets pas fin à la connexion.