Arrêt d'un serveur multithread

Version imprimable

bonjour,
je suis en train de tester un programme qui lance un thread serveur, qui ecoute sur un port et lance des thread de services pour les clients.
j'ai ce code :
Code:

1 2 3 4 5 6 7 while (!fin) { clientSocket = serverSocket.accept(); Thread clientThread = new Thread(new ServiceBiblio( serverAddress, clientSocket, gdd)); clientThread.start(); fin = stopThread; }
basé sur le code trouvé dans la FAQ et j'ai une fonction stop() comme décrit dans la faq :
Code:

1 2 3 public synchronized void stop() { this.stopThread = true; }
mon probleme est si je souhaite arreter le serveur pendant qu'il est en train d'écouter...bah ça marche pas, normal il n'est pas en train de parcourir la boucle...il écoute.. :roll:
je ne vois pas trop comment arreter ce serveur proprement, j'ai essayé un violent serverSocket.close(), mais ça arrete carrement le programme principale...trop violent :P

pouvez vous m'aider s'il vous plait?

11/12/2005, 09h31
FFF

il fait autre chose après l'exécution du serveur ton programme principal ? sinon c'est normal que ton programme s'arrête après un close() ? :roll:
Qu'est ce que tu voudrais faire après l'extinction du serveur ?

Salut,

Pour stopper les connections réseaux il faut utiliser des InterruptibleChannel qui permettent d'intérrompre les méthodes bloquantes comme "accept()"...

Pour les sockets tu dois donc utiliser la classe ServerSocketChannel, par exemple :

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
 
		ServerSocketChannel serverSocketChannel = null;
		ServerSocket serverSocket = null;
		Socket clientSocket = null;
		boolean fin = false;
 
		try {
			SocketAddress address = new InetSocketAddress(9999);
			serverSocketChannel = ServerSocketChannel.open();
			serverSocket = serverSocketChannel.socket();
			serverSocket.bind(address);
 
			while (!fin) {
				try {
					clientSocket = serverSocket.accept();
 
					// Traitement sur le clientSocket
 
				} catch (ClosedByInterruptException lException) {
					fin = true;
				}
			}
		} catch (IOException lException) {
			// TODO Auto-generated catch block
			lException.printStackTrace();
		} finally {
			try {
				if (serverSocket!=null) {
					serverSocket.close();
				} 
			} catch (Exception lException) {}
 
			try {
				if (serverSocketChannel!=null) {
					serverSocketChannel.close();
				} 
			} catch (Exception lException) {}
		}

Ensuite il te suffit d'utiliser la méthode interrupt() sur le thread de ton serveur, cela générera une exception du type ClosedByInterruptException lorsque tu es dans accept()...

a++

11/12/2005, 14h18
bambou

yes c'est nikel merci (encore) adiGuba

et, FFF, aprés l'arret du serveur, le programme principal sauvegarde les données, la configuration...etc, et indépendament de l'arret du serveur, le programme doit permet de faire de l'administration sur certaines données.

encore merci à vous et bonne journée

Citation:

Envoyé par adiGuba

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
        ServerSocketChannel serverSocketChannel = null;
        ServerSocket serverSocket = null;
        SocketChannel clientSocket = null;
        boolean fin = false;

        try {
            SocketAddress address = new InetSocketAddress(9999);
            serverSocketChannel = ServerSocketChannel.open();
            serverSocket = serverSocketChannel.socket();
            serverSocket.bind(address);
            
            while (!fin) {
                try {
                    clientSocket = serverSocketChannel.accept();
                    
                    // Traitement sur le clientSocket
                    
                } catch (ClosedByInterruptException lException) {
                    fin = true;
                }
            }
        } catch ...

Bonjour,
Je remonte un vieux thread mais ce ne serait pas plutôt comme ca ?

19/04/2006, 21h25
Pill_S

Socket ou SocketChannel, même combat, armes différentes...
10/05/2008, 13h51
ServerSocket

Probleme serveur

Bonjour

je remonte ce thread

j'ai utilisé vos implémentations utilisant les channels pour pouvoir stopper mon thread bloqué en accept(), et cela fonctionne parfaitement, ou presque.
En effet, maintenant mon programme se ferme proprement, mais plus aucun client ne peut se connecter au serveur...

depuis que j'utilise les channels mon serveur ne peut plus rien recevoir !

avez vous une idée d'où cela pourrait venir ?

Merci de votre aide

( j'utilise Java 1.5.0 )

J'essaie de faire la même avec DatagramChannel.

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
try {
			datagramChannel = DatagramChannel.open();
			socket = datagramChannel.socket();
			SocketAddress address = new InetSocketAddress(udpPort);
			socket.bind(address);
			DatagramPacket datagramPack = new DatagramPacket(buffer,
					buffer.length);
 
			while (live) {
 
				try {
					socket.receive(datagramPack);
					ACLMessage aclMessage = getACLMessageFromByte(datagramPack
							.getData());
					notifyTCPPMessageListener(aclMessage);
				} catch (ClosedByInterruptException e) {
					live = false;					
				} catch (ClassNotFoundException e) {
					e.printStackTrace();
				}
 
			}
		} catch (SocketException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			try {
				if (socket != null) {					
					socket.close();
				}
			} catch (Exception lException) {
			}
 
			try {
				if (datagramChannel != null) {					
					datagramChannel.close();
				}
			} catch (Exception lException) {
			}
		}
	}

Mais quand j'utilise interrupt() le thread ne s'arrête pas. Si quelqu'un a un exemple de code similaire je suis preneur.