Gestion des flux avec une Socket

Version imprimable

Bonjour à tous,

Je travaille avec un serveur distant que je peux interroger sur une socket

J'ai les 2 méthodes suivantes (à la fin ) qui fonctionnent ....

Mais ... lorsque je ferme le flux de lecture (les 3 lignes dans la dernière méthode), il semble que le serveur ne reçoit pas le message de fin (MESSAGE_FIN) d'utilisation (ce qui fait que le nombre de thread augmente avec le tps :( ).

Si je commentes les lignes tous fonctionne bien, mais ça me dérange de ne pas fermer ces flux.

Je pensais que la lecture et l'écriture étaient relativement indépendantes.
ça ne semble pas être le cas.

Questions :
Est ce que j'ai fait quelque chose de mal ? :aie:
Quel est la bonne pratique sur ce point ?

Merci

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 List send(IRequete requete) {
		List liste = new ArrayList();
		OutputStream outputStream = null;
		PrintStream fluxSortieSocket = null;
		try {
			outputStream = socket.getOutputStream();
			fluxSortieSocket = new PrintStream(outputStream);
			String message = requete.toMessage();
			fluxSortieSocket.println(message);
			liste = readResponse();
			fluxSortieSocket.println(MESSAGE_FIN);
			socket.close();
		} catch (Exception e) {
			log(...)
		} finally {
			fluxSortieSocket.close();
			try {
				outputStream.close();
			} catch (IOException e) {
				logger.warn("...", e);
			}
		}
		return liste;
	}

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
	private List readResponse() {
		InputStream inputStream = null;
		InputStreamReader inputStreamReader = null;
		BufferedReader fluxEntreeSocket = null;
		List liste = new ArrayList();
		try {
			inputStream = socket.getInputStream();
			inputStreamReader = new InputStreamReader(inputStream);
			fluxEntreeSocket = new BufferedReader(inputStreamReader);
			String line = fluxEntreeSocket.readLine();
			logger.debug("Ligne réponse :"+line);
			Reponse creationReponse = Factory.creationReponse(line);
 
			while (creationReponse != null) {
				liste.add(creationReponse);
				line = fluxEntreeSocket.readLine();
 
				creationReponse = Factory.creationReponse(line);
			}
		} catch (IOException e) {
			logger.error("...", e);
		} finally {
			try {
 
// ICI ces 3 lignes posent problème 
				fluxEntreeSocket.close();
				inputStreamReader.close();
				inputStream.close();
			} catch (IOException e) {
			}
		}
		return liste;
	}

18/05/2011, 12h18
tchize_

vous devez fermer le flux de sortie avant la socket, et pas l'inverse.

effectivement :oops:

mais le problème persiste avec cette méthode

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
 
	public List send(IRequete requete) {
		List liste = new ArrayList();
		OutputStream outputStream = null;
		PrintStream fluxSortieSocket = null;
		try {
			outputStream = socket.getOutputStream();
			fluxSortieSocket = new PrintStream(outputStream);
			String message = requete.toMessage();
			fluxSortieSocket.println(message);
			liste = readResponse();
			fluxSortieSocket.println(MESSAGE_FIN);
 
		} catch (Exception e) {
			log(...)
		} finally {
			try {
				fluxSortieSocket.close();
				outputStream.close();
				socket.close();
			} catch (IOException e) {
				logger.warn("...", e);
			}
		}
		return liste;
	}

18/05/2011, 12h52
tchize_

on peux voir le coté serveur qui recois le message?
18/05/2011, 16h41
LittleBean

si seulement .... ou même avoir des logs dessus serait bien ... :cry:

Mais je suis en développement super moderne ... avec une méthode dite de la black box serveur ....

Le service marche "super trop bien ... il est super performant (c'est du c :mrgreen:).... par contre tu as pas accès au code et y a pas trop de doc"

Donc j'en suis réduit à de l'expérimentation ....
18/05/2011, 16h44
tchize_

sniffez la connexion pour voir si le message est parti.
Sinon si le serveur blackbox il marche trop bien, vous cassez pas la nenette. Fermez proprement vos connexions et laissez le se vautrer lamentablement :)

Bon j'ai enfin eu un peu de temps pour avancer sur ce point :)

Alors j'ai essayé de sniffer les trames qui passaient et il en manque bien lorsque je ferme les flux de lecture avant d'envoyer le message de fin.
(Ma connaissance des protocoles réseaux et des formats trames est assez faible .... mais il me semble bien que le message de fin n'est pas envoyé)

J'ai déplacé les variables pour en faire des attributs et je ferme les flux de lecture après l'envoi du dernier message .... et ça marche nickel :ccool:

Par contre je comprends toujours pas ce qui se passe dans la jvm :cry:

Voila le code qui fonctionne pour info :

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
public List send(IRequete requete) {
		List liste = new ArrayList();
		OutputStream outputStream = null;
		PrintStream fluxSortieSocket = null;
		try {
			outputStream = socket.getOutputStream();
			fluxSortieSocket = new PrintStream(outputStream);
			String message = requete.toMessage();
			fluxSortieSocket.println(message);
			liste = readResponse();
			fluxSortieSocket.println(MESSAGE_FIN);
 
		} catch (Exception e) {
			log(...)
		} finally {
			try {
 
// ICI ces 3 lignes ne posent plus de problème :)
				fluxEntreeSocket.close();
				inputStreamReader.close();
				inputStream.close();
			} catch (IOException e) {
logger.warn("...", e);
			}
 
			try {
				fluxSortieSocket.close();
				outputStream.close();
				socket.close();
			} catch (IOException e) {
				logger.warn("...", e);
			}
		}
		return liste;
	}

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
private List readResponse() {
		inputStream = null;
		inputStreamReader = null;
		fluxEntreeSocket = null;
		List liste = new ArrayList();
		try {
			inputStream = socket.getInputStream();
			inputStreamReader = new InputStreamReader(inputStream);
			fluxEntreeSocket = new BufferedReader(inputStreamReader);
			String line = fluxEntreeSocket.readLine();
			logger.debug("Ligne réponse :"+line);
			Reponse creationReponse = Factory.creationReponse(line);
 
			while (creationReponse != null) {
				liste.add(creationReponse);
				line = fluxEntreeSocket.readLine();
 
				creationReponse = Factory.creationReponse(line);
			}
		} catch (IOException e) {
			logger.error("...", e);
		} 
		return liste;
	}