Discussion :

[wassim_boy]

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 ), 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 .

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 je me retourne vers vous. si quelqu'un peut m'éclairer sur ce sujet svp

Merci et à bientôt.

[dinobogan]

Donne le code qui reproduit le problème.

[wassim_boy]

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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

[dinobogan]

Ta méthode "Stoper" doit être synchronized.

[wassim_boy]

merci dinobogan pour ta réponse.

j'ai mis le synchronized mais sans effet.

[wassim_boy]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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