Arrêt d'un serveur (connexion socket)

Version imprimable

24/02/2007, 16h54
Goduak

Arrêt d'un serveur (connexion socket)

Salut,

Je me pose une question...
Comment arrêter proprement un serveur multithread ?
Mon client envoie un message pour que le serveur s'arrête et mon serveur envoie à tous les clients l'ordre de couper leur connexion.
Mais mon serveur conserve en mémoire toutes les sockets des différents clients connectés...du coup depuis le serveur je coupe chaque connexion des clients en parcourant mon conteneur. Est-ce la bonne façon de faire ?

J'ai vu que sur : http://defaut.developpez.com/tutorie...r/multithread/

le serveur se coupait en faisant un System.exit(0) uniquement ce qui me parait pas propre...qu'en pensez-vous?

Merci d'avance!

Go
24/02/2007, 22h03
Janitrix

Fait voir le code qui "coupe" les connexions s'il te plait...

Hello!
merci de ta réponse!
Mon code est le suivant :
Lors de l'arrêt du serveur j'appelle la méthode deleteAllStreams() qui appelle les autres...
La variable clients est une Hashtable qui contient la socket et les input/output de chaque client référencés en clé de la dite Hashtable.

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
54
55
56
57
58
59
60
61
62
63
public synchronized void deleteAllStreams()
{
	Set keys = clients.keySet();
	Iterator it = keys.iterator();
	while(it.hasNext())
	{
		String key = (String)it.next();
		deleteStreams(key);
		removeClient(key);
	}
}
 
private synchronized void deleteStreams(String key)
{
	Hashtable streams;
 
	streams = (Hashtable) clients.get(key);
 
	if (streams != null)
	{
		ObjectOutputStream output = (ObjectOutputStream) streams.get("output");
		try
		{
			output.flush();
		}
		catch (IOException e)
		{
			System.out.println("Flush sortie client : " + e.getMessage());
		}
		try
		{
			output.close();
		}
		catch (IOException e)
		{
			System.out.println("Fermeture sortie client : " + e.getMessage());
		}
		ObjectInputStream input = (ObjectInputStream) streams.get("input");
		try
		{
			input.close();
		}
		catch (IOException e)
		{
			System.out.println("Fermeture entrée client : " + e.getMessage() );
		}
		Socket socket = (Socket) streams.get("socket");
		try
		{
			socket.close();
		}
		catch (IOException e)
		{
			System.out.println("Fermeture socket client : " + e.getMessage() );
		}
	}
}
 
private synchronized void removeClient(String key)
{
	//Suppression du client de la liste
	clients.remove(key);
}

25/02/2007, 01h51
Goduak

D'ailleurs à ce propos j'ai une erreur :

java.util.ConcurrentModificationException Hashtable$Enumerator.next
à la ligne du deleteStreams(key) dans la méthode deleteAllStreams()...

Une erreur de chez Sun apparemment...http://forum.java.sun.com/thread.jsp...rt=15&tstart=0
25/02/2007, 13h32
adiGuba

Salut,

Citation:

Envoyé par Goduak

D'ailleurs à ce propos j'ai une erreur :

java.util.ConcurrentModificationException Hashtable$Enumerator.next
à la ligne du deleteStreams(key) dans la méthode deleteAllStreams()...

Une erreur de chez Sun apparemment...http://forum.java.sun.com/thread.jsp...rt=15&tstart=0

Non ce n'est pas une erreur de chez Sun !

Lorsqu'on utilise un Iterator, on ne doit pas modifier la collection source sous peine de provoquer une ConcurrentModificationException.

Or dans ton cas dans la méthode deleteAllStreams() tu utilises un Iterator sur les clef de ta Map clients. Or tu modifies cette dernier dans la méthode removeClient()...

:arrow: Il faudrait plutôt utiliser la méthode remove() de l'Iterator...

a++