connexion à une application web + processus parallèle sur le serveur

Version imprimable

13/06/2007, 08h38
AnneB

connexion à une application web + processus parallèle sur le serveur

Bonjour à tous!

:D

Je viens de me poser une question, si ca se trouve c'est débile mais c'est une question de fonctionnement basique des appli web. Ca fait quelque temps que je développe des appli web, mais j'avoue que je ne métais jamais posé la question :

Une fois l'appli déployée sur le serveur d'appli, les client peuvent y accéder. Ca c'est ok (;) tout de même lol)
Mettons qu'un premier client lance l'appli. vu que personne est connecté, c'est lui qui fait que tout est initialisé, en particulier les objets java. Si un deuxième client se connecte, alors est ce que les objets java de l'appli sont de nouveau créé? Je veux dire est ce que du coup c'est comme si sur le pc serveur on avait deux fois la même appli qui tourne? ou alors est -ce que c'est plus comme si on avait une seule appli qui tourne mais que on la voit sur 2 écrans différents?

En fait cette question je me la pose pour des questions de performances de mon appli :P ... En effet il faut que j'ai un thread qui aille toutes les X secondes checker la BDD, pour voir si il n'y aurait pas de nouvelles données.
Mon souci c'est que si a chaque nouvelle connexion a mon appli ca redémarre le thread je vais avoir trop de requête en Base de données et du coup ca va trop ramer et mon appli sera pas performante...

Voilà, si quelqu'un pouvait éclairer mes lanternes svp...8-)

Anne
13/06/2007, 10h37
AnneB

on m'a conseillé de regarder du côté des démons....
Mais si je fais ca le truc va tourner sur mon serveur en permanance....

Vous en pensez quoi?

Finalement j'ai fait un singleton dans mon pgm :

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 class MySingleton {
    private static  MySingleton _instance;
    private MyThread myThread;
    private MySingleton() {
        // construct object . . .
    	MyThread p = new MyThread();
    	myThread=p;
        p.start();
    }
    // For lazy initialization
    public static synchronized MySingleton getInstance() {
        if (_instance==null) {
            _instance = new MySingleton();
        }
        return _instance;
    }
        // Remainder of  class definition . . .
	/**
         * @return the myThread
         */
	public MyThread getMyThread() {
		return myThread;
	}
}

sachant que MyTread c'est ca :

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 class MyThread extends Thread {
        private boolean running;
        private int i;
 
        MyThread() {
        	running=true;
        	i=0;
        }
 
        public void run() {
        	System.out.println("démarrage du thread");
        	long millis = (long) (60*1000);
        	while(running){
        		System.out.println("run number = "+i);
        		try{
            		sleep(millis);
            		i++;
            	}
            	catch (InterruptedException e){
            		System.out.println("exception sleep");
            	}
        	}
        }
}

et dans la classe action ou j'ai besoin de récupérer les valeurs que le thread va consulter :

Code:

MySingleton.getInstance();

maintenant quant à savoir si c'est dub code propre....et surtout si c'est génant parce que pas top pour un azppli web.... j'en sais rien vu que j'avais encore jamais été amenée à utiliser les thread comme ca en j2ee :roll:

voilà!!!

14/06/2007, 13h28
grishka

Citation:

Envoyé par AnneB

maintenant quant à savoir si c'est dub code propre....et surtout si c'est génant parce que pas top pour un azppli web....

Si ce thread est initialisé par l'appli web, à chaque redéploiement un nouveau thread sera recréé (le classloader est déréférencé, donc ton singleton aussi). Pour être averti du redéploiement et arrêter le thread (en mettant running=false), utilise un ServletContextListener.

De plus ton serveur ne s'arrêtera pas car le thread n'est pas démon (utilise la méthode setDaemon(true) du thread)
14/06/2007, 15h16
AnneB

Citation:

Envoyé par Grégory Picavet

De plus ton serveur ne s'arrêtera pas car le thread n'est pas démon (utilise la méthode setDaemon(true) du thread)

Je ne comprend pas.... si jamais j'arrête le serveur alors forcément tous les processus en cours seront tués non?
14/06/2007, 16h13
grishka

si tu stoppe le serveur sauvagement (kill -9 ou ctrl-c), tous les threads (on ne parle pas de processus ici) seront tués, mais tu risques de laisser des lock sur tes ressources ouvertes, ce qui est mal.
mais si tu essayes d'arrêter le serveur par script, le serveur ne pourra pas stoppé les threads créés par l'application, uniquement ceux managés par son pool de threads. cf. http://tomcat.apache.org/faq/misc.html#stop

c'est valable pour toutes les applications java. Par exemple dans une application Swing, tu est obligé de faire System.exit(-1) lors de la fermeture de la fenêtre sinon le programme tourne toujours...

ok :)
J'ai fait ca :)

Donc c'est cool :) ca marche :

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
public class MyThread extends Thread implements ServletContextListener{
        private boolean running;
        private int i;
 
        private ArrayList alarms;
 
        MyThread() {
        	// wait to run server
        	running=false;
        	// thread daemon in order to enable server to shut down properly
        	setDaemon(true);
        	// init var for suystem.out.println
        	i=0;
        }
 
        public void run() {
        	System.out.println("démarrage du thread");
        	// sleep time for the thread = 3 seconds
        	long millis = (long) (3*1000);
        	running = true;
        	while(running){
        		System.out.println("run number = "+i);
        		try{
        			// sleep
            		sleep(millis);
            		i=i+3;
            		//then access to the database
            		// get all the alarms
            		ApiIdexAnne apiIdex = ApiIdexAnne.getInstance();
            		apiIdex.updateAlarms(i);
            	}
            	catch (InterruptedException e){
            		System.out.println("exception sleep");
            	}
        	}
        }
 
		/**
                 * @return the running
                 */
		public boolean isRunning() {
			return running;
		}
 
		/**
                 * @param running the running to set
                 */
		public void setRunning(boolean running) {
			this.running = running;
		}
 
		public void contextDestroyed(ServletContextEvent arg0) {
			running=false;
			System.out.println("halt thread");
		}
 
		public void contextInitialized(ServletContextEvent arg0) {
		}
}

enfin maintenant je suoppose que ca marche parce que de tte facon je ne vois pas si c'est tout ok :)

Merci bcp pour tes conseils Grégory Picavet :)