Arrêter un serveur et le relancer

Version imprimable

28/03/2012, 04h31
wassim_boy

Arrêter un serveur et le relancer

Bonjour,

J'ai un thread qui représente mon serveur et qui se met en attente des clients.

J'aimerai pouvoir lancer mon serveur via un bouton (ça c'est fait :ccool:), l'arrêter (via un autre bouton), le relancer, l'arrêter après ... etc

Lorsque je lance mon serveur une première fois tout se passe bien :D.

Le premier problème c'était que l'arrêt se passe bien (enfin je pense) en utilisant un interrupt mais quand je le relance l'appli se bloque.

Le deuxième problème j'ai utilisé la solution proposé dans ce sujet par adiGuba, mais lorsque je l'arrête je me retrouve avec cette erreur : java.nio.channels.AsynchronousCloseException

Après plusieurs tests et recherche sur google sans résultat :cry: je me retourne vers vous. si quelqu'un peut m'éclairer sur ce sujet svp

Merci et à bientôt.
28/03/2012, 11h05
dinobogan

Donne le code qui reproduit le problème.

voila j'ai une classe serveur, voici le code :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
//....
public Serveur(){
        this.monServeur = new ServiceServeur(Serveur.port); //un thread
    }
    //je lance le thread pour que le serveur se met en écoute
    public void lancer() {
        System.out.println("serveur ok");
        this.monServeur.start();
    }
    //ici pour le stoper
    public void Stoper() {
        try {
            this.monServeur.serverSocket.close();
        } catch (IOException ex) {
            ex.printStackTrace();
        }
        this.monServeur.interrupt();
    }

la classe serviceserveur qui est un thread avec la méthod run qui permet d'effectuer l'écoute :

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
 
//....
public class ServiceServeur extends Thread{
    private ServerSocketChannel serverSocketChannel;
    public ServerSocket serverSocket;
    private Socket clientServiceSocket;
    boolean arret = false;
//....
public ServiceServeur(int port) {
//...
try {
            this.serverSocket = new ServerSocket(port);
        } catch (IOException ex) {
            System.out.println("Impossible de démarrer l'écoute du serveur, port " + port + " occupé.");
        }
}
//....
    /**
     * Démarre l'écoute du serveur
     * (cette solution je l'ai trouvé dans le poste que j'ai cité)
     */
    public synchronized void run() {
 
        try {
            SocketAddress address = new InetSocketAddress(9999);
            serverSocketChannel = ServerSocketChannel.open();
            serverSocket = serverSocketChannel.socket();
            serverSocket.bind(address);
            while(!arret) {
                try {
 
                    this.clientServiceSocket = this.serverSocket.accept();
                    ServiceClient monService = new ServiceClient(this.clientServiceSocket, this); //je crée un client
                    monService.start(); //et je le démarre
                    System.out.println("monService.start");
                    this.listThread.add(monService);
 
                } catch (ClosedByInterruptException lException) {
                    arret = true;
                    System.out.println("Connection au serveur impossible."); 
//quand j'arrete le serveur j'avais ce message qui s'affiche en boucle à l'infini 
//puis (j'ai rien modifié) maintenant j'ai l'erreur : java.nio.channels.AsynchronousCloseException
                }
            }
        } catch (IOException lException) {
            lException.printStackTrace();
        } finally {
            try {
                    if (serverSocket!=null) {
                            serverSocket.close();
                    } 
            } catch (Exception lException) {}
 
            try {
                    if (serverSocketChannel!=null) {
                            serverSocketChannel.close();
                    } 
            } catch (Exception lException) {}
        }
    }
//...

dans l'interface j'ai cela :

Code:

1
2
3
4
5
6
7
8
9
10
11
 
//...
private void BoutonDemarrerActionPerformed(java.awt.event.ActionEvent evt) {                                               
        //lancement du serveur
        this.serveur.lancer();
}
private void BoutonArreterActionPerformed(java.awt.event.ActionEvent evt) {                                              
        //arrêt du serveur
        this.serveur.Stoper();
}
//....

voila pour d'autre questions je suis à votre disposition. merci

à bientôt

28/03/2012, 17h46
dinobogan

Ta méthode "Stoper" doit être synchronized.
28/03/2012, 18h15
wassim_boy

merci dinobogan pour ta réponse.

j'ai mis le synchronized mais sans effet. :(

en lisant des trucs sur le net et en bidouillant j'ai plus l'erreur java.nio.channels.AsynchronousCloseException. :)

mais maintenant quand je relance mon serveur (avec la methode lancer) il me dit que le port est occupé alors que j'ai fermé le socket.

des idées?

voici le code modifié (tout le reste est le même) :

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
 
//....
public Serveur(){
 
    }
public void lancer() {
        this.monServeur = new ServiceServeur(Serveur.port);//<-- je l'ai enlevé du constructeur
        this.monServeur.start();
        System.out.println("serveur ok!");
    }
 
    public synchronized void Stoper() {//<--- j'ai rajouté le synchronized
        this.monServeur.interrupt(); // <--- je l'ai mis en premier
        System.out.println("interrupt ok -> " + this.monServeur.isInterrupted()); //elle affiche true
        try {
            this.monServeur.serverSocket.close();
            System.out.println("serverSocket ok -> " + this.monServeur.serverSocket.isClosed());//elle affiche true
            this.monServeur.serverSocketChannel.close();// <--- j'ai rajouté ça mais sans effet 
            System.out.println("serverSocketChannel ok -> " + this.monServeur.serverSocketChannel.isOpen()); //elle affiche false
        } catch (IOException ex) {
            System.out.println("serverSocket not ok!!");
        }
    }
//.....

merci et à bientôt

apparemment le problème viens d'ici (classe serviceserveur -> méthode run)
Code:

1 2 3 4 5 SocketAddress address = new InetSocketAddress(9999); serverSocketChannel = ServerSocketChannel.open(); serverSocket = serverSocketChannel.socket(); serverSocket.bind(address); //ici
car j'ai ce message d'erreur : Address already in use: JVM_Bind quand je fais :
Code:

1 2 this.serverSocket = new ServerSocket(port);
personne n'a une idée? SVP

merci