Problème suppression Sockets d'une collection

Version imprimable

02/03/2012, 20h03
Francky44003

Problème suppression Sockets d'une collection

Bonjour a tous, j'aimerai vous faire part d'un probleme qui me perturbe.
Je suis actuellement en train de développer un tchat en java et je rencontre un probleme que j'arrive plus ou moins à le résoudre, il s'agit de la suppression d'une socket d'un client coté serveur lorsque le client se déconnecte.

Lorsque je connecte 1 seul client au serveur tout marche nickel, mais la chose se complique lorsque je connecte 2 clients sur le serveur, voici le probleme :

- lorsque je connecte le client A puis le client B, le serveur m'affiche 2 clients (ce qui est normal). Ensuite lorsque je deconnecte le client B, le serveur m'affiche 1 client (le client A donc)

Par contre

- lorsque je connecte le client A puis le client B, le serveur m'affiche 2 clients (ce qui est normal). Ensuite lorsque je deconnecte le client A, le serveur m'affiche 0 client, ce qui signifie que le serveur me supprime les 2 clients connectés hors il aurait du m'en supprimer qu'un seul car je ne deconnecte qu'un seul client qui est le client A.

J'aimerai comprendre pourquoi lorsque dans un ordre donné le serveur me supprime 1 client mais que dans un ordre inverse, celui ci me supprime tout les clients contenu dans une collection coté serveur ?

Est ce que c'est parce qu'il on la meme socket ?
Est ce que c'est du au fait que je lance les 2 clients sur la meme machine ?

Voila j'aimerai avoir des éclaircissements la dessus si c'est possible.

Dans l'attente d'une réponse de votre part, je vous remercie d'avance
02/03/2012, 21h25
thelvin

... Tu pensais qu'on allait deviner comment tu crées et supprimes tes Sockets ?

Eh bien non...

Désolé. Voici donc le code source.

Coté serveur :

J'ai implémenté un thread qui permet au serveur d'ecouter sur un port sur lequel les clients se connectent, une fois que le serveur a intercepté une connexion de la part d'un client, le serveur stock le socket de ce client dans un List<Socket> socketClients :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
socketClient = socketServer.accept(); // permet de prendre la socket du client qui va se connecter
 
				InputStream fluxEntree = socketClient.getInputStream(); // lit les flux entrant de la part du client	
				OutputStream fluxSortie = socketClient.getOutputStream();
 
				clientsInputStream.put(socketClient,  fluxEntree);
				clientsOutputStream.put(socketClient,  fluxSortie);
				socketClients.add(socketClient);
 
				RunnableEcouteMessageDesClients ecouteMessagesClient = new RunnableEcouteMessageDesClients(clientsOutputStream, socketClients, clientsInputStream, socketClient);
				Thread threadEcouteMessageClients = new Thread(ecouteMessagesClient);
				lesThreadEcouteursDeMessages.add(threadEcouteMessageClients);
				threadEcouteMessageClients.start();

Je lance ensuite pour le socketClient un Thread afin d'ecouter les messages du client.

Coté client :

Lorsque un client souhaite se deconnecter, le client clique sur un bouton bDeconnexion afin d'avertir le serveur (en lui envoyant un message)

Voici le code permettant la deconexion du client :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
PrintWriter envoyer_server = new PrintWriter(new BufferedWriter(new OutputStreamWriter(fluxSortant)), true);
			envoyer_server.write("deconnexion client\n");
			envoyer_server.flush();	
 
				/*fluxEntrant.close();
				fluxSortant.close(); */
			try {
 
 
			    clientSocket.close();
				client.setArret(true);
				this.connected = false;
 
 
				textBoxMessages.append("Vous etes déconnecté\n");
 
			} catch (IOException | NullPointerException e2) {
				// TODO Auto-generated catch block
				JOptionPane.showMessageDialog(this, "Un problème est survenue lors de la déconnexion","Avertissement", JOptionPane.WARNING_MESSAGE);
			}

Coté serveur :

Une fois que le serveur reçois le message de la part du client en ce qui concerne la deconnexion, le serveur ferme la socket et le supprime de la collection :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
message = buffer.readLine(); // renvoi null si un probleme est apparue
				if(message.isEmpty() || message.compareTo("deconnexion client") == 0 )
				{
 
					this.buffer.close();
					this.lesClientsInputStream.get(laSocketClient).close();
					this.lesClientsOutputStream.get(laSocketClient).close();
 
					this.laSocketClient.close(); 
					this.lesSocketClients.remove(laSocketClient);
 
					arret = true;
					System.out.println("on ferme ! ");
				};

Voila. Si vous avez besoin de plus de code n'hésitez pas a demander.