[Thread] (impl. runnable) dans DaemonThread

**rXpCH** · 13/07/2009, 14h42

Bonjour,

Je fais un serveur multithread, je viens de lui apporter de grosse modification.
Il y a un DaemonThread et des Thread (implements runnable) pour chaque clients. Mon problème c'est que depuis que j'ai fais les grosses modifications, je n'arrive plus à lancer les Threads pour chaque clients. A chaque fois que je le fait il relance le DaemonThread.
Quand je fais :

Code :

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

1
2
3
4
5
6
// create the thread
                Thread t = new Thread(new ServerData(skt));
                // give it a name
                t.setName(skt.getInetAddress().getHostAddress());
                // start the thread
                t.start();

Il ne va pas dans ServerData mais il recommence dans DaemonThread.

Voici mon 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
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
public class Server {
 
// list of the Players connected
protected final List <Player> connections = new ArrayList<Player>();
 
// list of the IP connected and waiting for logins
protected final List <Socket> ipWaiting = new ArrayList<Socket>();
 
// port of the application
protected int port = 1991;
 
// objects connections
protected final Connections con = new Connections();
 
    public Server() throws IOException{
 
        Thread t = new DaemonThread();
 
  }
 
    class DaemonThread extends Thread{
        public DaemonThread(){
            //start the main thread
        start();
        }
 
        @Override
        public void run(){
 
        Socket skt = null;
        ServerSocket srvr = null;
            try {
                //open the port
                srvr = new ServerSocket(port);
            } catch (IOException ex) {
                Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
            }
 
        while(true){
            int result = 0;
             try{
                 //accept the connections
                 skt = srvr.accept();
                 System.out.print("New connection ! \n");
                 //check in address if the client is already connected
                 result = ipWaitingChanges(skt, "check");
                 //error
            }catch(IOException ioe){
                 System.out.print("It didn't work! - "+ioe.getMessage()+"\n");
                 ioe.printStackTrace();
                 ipWaitingChanges(skt, "kill");
            }
             if(result == 1){
             //if no error :
                 ipWaitingChanges(skt, "add");
             }
        }
 
        }
    }
 
 
  class ServerData implements Runnable{
      private Socket skt;
      protected Player player = null;
      private Network network;
      private cmdToServer cts;
      public ServerData(Socket skt) throws IOException{
          //init
          this.skt = skt;
          network = new Network(this.skt);
          cts = new cmdToServer();
          // number of thread
          System.out.println("Number of thread : "+Thread.activeCount());
      }
 
      public void run(){
      try{
                try {
                    try {
                        //analyse the packet juste receive
                        cts.analyse((Object) network.readObject(), network);
                    } catch (SQLException ex) {
                        Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
                    } catch (NoSuchAlgorithmException ex) {
                        Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
                    }
                } catch (ClassNotFoundException ex) {
                    Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
                }
         }catch(IOException ioe){
             //if error :
             //close the connection
            System.out.print("It didn't work! - "+ioe.getMessage()+"\n");
            ioe.printStackTrace();
            if(getPlayerFromSocket(skt) != null){
                //if he is already login in
                removePlayer(getPlayerFromSocket(skt), network);
            }else{
                //if not
            }
         }
      }
  }

Avez-vous une idée ?

Cordialement,
Dafflon Emmanuel

**tchize_** · 13/07/2009, 15h13

Je ne vois pas ton bout de code du haut dans ton code global, donc difficile de savoir ce que tu fait pour lancer tes threads.

**rXpCH** · 13/07/2009, 15h20

J'ai mis à jour le poste du dessus, et voici le code de la méthode ou j'appelle le thread :

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
  public synchronized int ipWaitingChanges(Socket skt, String type){
      //-1 = error
      int result = -1;
    // create connection
    if(type.equals("add")){
            try {
                synchronized (ipWaiting) {
                    // add the inetaddress to address
                    ipWaiting.add(skt);
                }
                // create the thread
                Thread t = new Thread(new ServerData(skt));
                // give it a name
                t.setName(skt.getInetAddress().getHostAddress());
                // start the thread
                t.start();
            } catch (IOException ex) {
                Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
            }
    }
 
    //check connection
    else if(type.equals("check")){
        //create an iterator
        Iterator it;
        result = 1;
        synchronized(ipWaiting){
        //init an iterator of address
        it = ipWaiting.iterator();
        }
        while(it.hasNext()){
            InetAddress add = null;
                     add = (InetAddress) it.next();
                     if(skt.getInetAddress().equals(add)){
                         System.out.print("Server has refused connection : "+add.getHostAddress()+" - Already connect \n");
                         //2 = already connected
                         result = 2;
                         break;
                     }else{
                         //1 = not connected
                         result = 1;
                     }
         }
    }
 
    return result;
  }

**tchize_** · 17/07/2009, 09h53

on, pourrait voir du code un peux plus global, parce que là tes petit bout de code à gauche a droite j'ai du mal a suivre. Par exemple tu te plaint que ton DaemonThread est lancé à la place de l'autre Thread, masu je ne vois nulle par de référence à cette classe, donc je dirais dans un premier temps vire là puisque tu ne l'utilise pas. Si ton problème est que cette classe est démarrée, la premier chose qu'il faut analyser c'est comment tu la démarre. Comme je ne vois pas de messages de logs lors de l"'utilisation de ServerData, il n'y a aucune moyen de savir si c'est pas une erreur de logique de ton code qui fait que tu ne passe pas là ou tu pense passer. FAit du pas à pas dans ton ide et regéarde par ou tu passe.

**rXpCH** · 17/07/2009, 10h28

Bon,
Voici mon Main :

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
public class Main {
 
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        try {
            // TODO code application logic here
            Server server = new Server();
            } catch (IOException ex) {
            Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
            }
    }
 
}

Ici je démarre le daemonThread.

Code :

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

1
2
3
4
5
public Server() throws IOException{
 
        Thread t = new DaemonThread();
 
  }

Ensuite, le daemonThread attend une connexion.

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
class DaemonThread extends Thread{
        public DaemonThread(){
            //start the main thread
        start();
        }
 
        @Override
        public void run(){
 
        Socket skt = null;
        ServerSocket srvr = null;
            try {
                //open the port
                srvr = new ServerSocket(port);
            } catch (IOException ex) {
                Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
            }
 
        while(true){
            int result = 0;
             try{
                 //accept the connections
                 skt = srvr.accept();
                 System.out.print("New connection ! \n");
                 //check in address if the client is already connected
                 result = ipWaitingChanges(skt, "check");
                 //error
            }catch(IOException ioe){
                 System.out.print("It didn't work! - "+ioe.getMessage()+"\n");
                 ioe.printStackTrace();
                 ipWaitingChanges(skt, "kill");
            }
             if(result == 1){
             //if no error :
                 ipWaitingChanges(skt, "add");
             }
        }
 
        }
    }

Après une fois qu'il la reçu il va dans la méthode "ipWaitingChanges" pour checker si la personne est déjà connecté. Si oui alors on ferme le socket, sinon alors on l'ajoute à la liste des socket connectés et on démarre le thread (serverData) pour ce client.

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
  public synchronized int ipWaitingChanges(Socket skt, String type){
      //-1 = error
      int result = -1;
    // create connection
    if(type.equals("add")){
            try {
                synchronized (ipWaiting) {
                    // add the inetaddress to address
                    ipWaiting.add(skt);
                }
                // create the thread
                Thread t = new Thread(new ServerData(skt));
                // give it a name
                t.setName(skt.getInetAddress().getHostAddress());
                // start the thread
                t.start();
            } catch (IOException ex) {
                Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
            }
    }
 
    //check connection
    else if(type.equals("check")){
        //create an iterator
        Iterator it;
        result = 1;
        synchronized(ipWaiting){
        //init an iterator of address
        it = ipWaiting.iterator();
        }
        while(it.hasNext()){
            InetAddress add = null;
                     add = (InetAddress) it.next();
                     if(skt.getInetAddress().equals(add)){
                         System.out.print("Server has refused connection : "+add.getHostAddress()+" - Already connect \n");
                         //2 = already connected
                         result = 2;
                         break;
                     }else{
                         //1 = not connected
                         result = 1;
                     }
         }
    }
 
    return result;
  }

Avant le code était semblable mais ne prenait pas en compte quelque choses... Quand je lance le Thread :

Code :

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

Thread t = new Thread(new ServerData(skt));

Au lieu d'aller la dedans, il va tenter de créer un nouvelle instance du daemonThread, ce qui n'est pas normal. J'ai débug mon code une bonne vingtaine de fois et j'arrive toujours au même problème : Il relance le daemonThread, donc il crée un nouveau serverSocket sur le même port et tout plante.

**tchize_** · 17/07/2009, 10h39

pour identifier facilement l'origine du problème, change ton constructeur comme ceci:

Code :

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

1
2
3
4
5
6
class DaemonThread extends Thread{
        public DaemonThread(){
            new Exception("Deamon Thread en démarrage").printStackTrace();
            //start the main thread
            start();
        }

mais a vue de pifometre, je dirais que quelque part tu crée un new Server()

**rXpCH** · 17/07/2009, 11h02

Merci pour cette info, je ne connaissais pas.
Alors apparemment il passe par le serverData (j'ai eu tord) mais ensuite, il va dans la class "cmdToServer" quand je crée l'objet (ce qui est correct) et dans le constructeur de "cmdToServer" (constructeur vide) il va tout à coup sur le constructeur de la class server où le daemonThread se crée.
Et oui c'est normal car comme un con j'ai oublie que ma classe "cmdToServer" est hérité de server, donc elle va appeler le constructeur de server et tout faire bugger.
J'ai honte de cela...
Merci de ton aide !

[Thread] (impl. runnable) dans DaemonThread

Concurrence et multi-thread Java

Discussions similaires

Partager

Partager