[Débutant]Utilisation des Threads

Bonjour à tous, voila je suis actuellement en stage dans une boite pour laquelle j'essaye de réaliser une petite appli qui fait des requêtes sur des serveurs.

J'ai fait un fichier xml dans lequel on retourouve pour chaque élément serveur, une liste d'url et les paramètres de connexion à une base de donnée ainsi qu'une requêtes sql.
Lorsque j'exécute mon appli, je teste les urls ( et la base correspondante si une des url renvoit une erreur de type 40x ou 50x)

Mon problème est que j'aimerais pouvoir mettre en pause les requêtes sur un serveur et continuer à tester les autres. J'ai regardé beaucoup de doc sur les Thread, je pense avoir compris le fonctionnement mais je n'arrive pas à les utiliser correctement pour mon appli. Voila cela fait deux semaine que j'essaye sans succès :cry: voici ma classe principale si vous pouvez m'aider...

Citation:

public class Main{

static ServerParameters srvParam = null;
String nomServer = null;
String nomDataBase = null;
String reponseResultUrl = null;
String reponseResultDb = null;
ResultParameters resultUrl = null;
ResultParameters resultDb = null;
ArrayList listUrl = null;
ServerListXml svrXml = new ServerListXml();
Timer t = null;
ArrayList listeSrvParameter = svrXml.getListeServerXml();
Calendar calender = null;
ArrayList reponseKo = null;
ReponseKoParameter reponseKoParam = null;
String repDb = null;

public Main(ServerParameters srvParam) {

Main.srvParam = srvParam;
t=new Timer();
t.schedule(new Repet(), 0, 600);
}

class Repet extends TimerTask {

public void run() {

calender= Calendar.getInstance();
reponseKo = new ArrayList();
for (int i = 0; i < listeSrvParameter.size(); i++)
{
srvParam = (ServerParameters)listeSrvParameter.get(i);
listUrl = srvParam.getListeUrl();

nomServer= srvParam.getServerName();
nomDataBase = srvParam.getDbParameters().getDbType();
System.out.println("Test du serveur " + nomServer);

for (int j = 0; j < listUrl.size(); j++ )
{
resultUrl = CheckUrl.checkUrl((UrlParameters)listUrl.get(j));
reponseResultUrl = resultUrl.getCodeReponse();

String logResultUrl = "Connexion à l'Url " + resultUrl.getNomDuTest();
String logReponseUrl = "resultUrl : " + reponseResultUrl + "\n";
System.out.println(logResultUrl);
System.out.println(logReponseUrl);

if(!(reponseResultUrl.equals("OK")))
{
String repServerName = "\r\n" + "============== " +" alerte "+ ", serveur " + nomServer +" =============="+ "\r\n";
String repUrl = calender.getTime() +"\t"+ logResultUrl +"\t"+ logReponseUrl;
try {
resultDb =
CheckDataBase.checkData(srvParam.getDbParameters());
} catch (SQLException e) {
e.printStackTrace();
}
reponseResultDb = resultDb.getCodeReponse();
String logResultDb = "Test de la Base " +nomDataBase+ " " +
resultDb.getNomDuTest();
String logReponseDb = "resultDB : " + reponseResultDb + "\n";
System.out.println(logResultDb);
System.out.println(logReponseDb);

if(!(reponseResultDb.equals("OK")))
{
repDb = calender.getTime()+"\t"+ logResultDb +"\t"+
logReponseDb;
}
reponseKoParam = new ReponseKoParameter(repServerName,repUrl,repDb);
reponseKo.add(reponseKoParam);
}
}

for(int m = 0; m < reponseKo.size(); m ++)
{
reponseKoParam = (ReponseKoParameter)reponseKo.get(m);
LogSentinelle.ecrire(reponseKoParam.getServerNameKo());
LogSentinelle.ecrire(reponseKoParam.getUrlReponseKo());
LogSentinelle.ecrire(reponseKoParam.getDbReponseKo());
}
}
}
}

public static void main(String[] args)throws Exception{
Main repet = new Main(srvParam);

}
}

Bonjour,
Dans ton code il n'y apparemment que 2 thread.
Le thread principal (main) qui ne fait rien, le thread de l'execution de TimerTask.

La méthode run est exécutée par le thread TimerTask a cadence fixe. Il n'y a pas de parallellisation des traitements.

Qu'est ce que tu veux paralleliser ?

Citation:

Envoyé par maniolo

Bonjour à tous, voila je suis actuellement en stage dans une boite pour laquelle j'essaye de réaliser une petite appli qui fait des requêtes sur des serveurs.

pourquoi ecrire une appli qui fait ca ? il en existe plein.

essaye donc JMeter chez apache

@+

j'aimerais pouvoir faire une sorte de multi-threadring si je ne dis pas de bêtise, par exemple si mes requêtes sur un serveur renvoient la réponse "KO" je fait une pause sur les requêtes de ce serveur pour le prochain passage dans la boucle et je passe aux tests des autres serveurs. il faudrait en fait paralleliser les tests sur chaque élément serveur, le problème est que ma boucle test un serveur après l'autre et si je met un thread dans ma boucle avec la méthode wait() par exemple, la boucle s'arrete un temps donné et ne passe pas au test suivant.

Citation:

Envoyé par yopiyop

pourquoi ecrire une appli qui fait ca ? il en existe plein.

essaye donc JMeter chez apache

@+

C'est pas moi qui ai choisi, c'est la boite dans laquelle je fait le stage qui m'a demandé...

Il faut donc paralleliser les appels à TimerTask

Je suppose qu'en créant autant de timer que de serveur alors ton Repet.run sera traité dans des threads différents
(facilement a tester, tu rajoutes un print de Thread.getCurrentThread().getName() dans la methode Repet.run pour savoir dans quel thread tu te trouves)

Pour démarrer tes timers :

for (int j = 0; j < listUrl.size(); j++ )
{
t=new Timer();
t.schedule(new Repet((UrlParameters)listUrl.get(j)), 0, 600);

}

en passant au constructeur de Repet l'url sur laquelle il travaille

Merci pour tes réponses, je crois comprendre le principe :roll: , cependant j'ai deux questions bêtes...:oops:

Citation:

Envoyé par manitoba

Pour démarrer tes timers :

for (int j = 0; j < listUrl.size(); j++ )
{
t=new Timer();
t.schedule(new Repet((UrlParameters)listUrl.get(j)), 0, 600);

}

dois-je le placer ceci le constructeur de ma classe Main et si oui ne vais-je pas avoir un javanullpointerexception? comme ceci :

Citation:

public MainSentinelle2(ServerParameters srvParam) {
MainSentinelle2.srvParam = srvParam;
for (int j = 0; j < listUrl.size(); j++ )
{
t=new Timer();
t.schedule(new RepetSentinelle((UrlParameters)listUrl.get(j)), 0, 600);
}
}

Citation:

Envoyé par manitoba

en passant au constructeur de Repet l'url sur laquelle il travaille

La je comprend pas trop... Repet est la méthode que j'exécute dans mon Main, je dois lui créé un constructeur :roll: ?

Citation:

Envoyé par maniolo

dois-je le placer ceci le constructeur de ma classe Main et si oui ne vais-je pas avoir un javanullpointerexception?

Non ya pas spécialement de raison
Par contre ton constructeur de MainSentinelle est bizarre.
Pourquoi, MainSentinelle.srvParam = srvParam

Citation:

Envoyé par maniolo

La je comprend pas trop... Repet est la méthode que j'exécute dans mon Main, je dois lui créé un constructeur :roll: ?

Repet est pas une méthode c'est une classe.
voir ton code
Code:

1 2 3 4 5 6 Class Repet implements Runnable { ... public void run() { ....} }
il faut simplement que tu lui ajoutes un membre d'instance (a ne pas déclarer en static)
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 Class Repet implements Runnable { UrlParam _urlServeur; public Repet(UrlParam url) { _urlServeur = url; } ... public void run() { // Je fais mon traitement en utilsant _urlServeur ....} }

en fait j'ai une classe ServerListXml qui récupère le contenu de mon fichier xml
et qui passe en paramètre les valeurs à la classe ServerParameters qui sont ensuite stockées dans une Arraylist comme ceci :

Citation:

serverParameter = new ServerParameters(serverName,dbParameters,listeUrl);
listServer.add(serverParameter);

je passe comme parametre au constructeur de ma classe principale
la classe ServerParameter qui est elle-même un constructeur de cette forme

Citation:

public class ServerParameters {
String serverName;
DbParameters dbParameters;
ArrayList listeUrl;

public ServerParameters(String serverName, DbParameters dbParameters, ArrayList listeUrl) {
this.serverName = serverName;
this.dbParameters = dbParameters;
this.listeUrl = listeUrl;
}
avec des getters et des setters

Dans la classe principale j'appelle une classe CheckUrl (dans laquelle je passe en parametre Urlparameter) qui me sert à effectuer les tests des url et qui retourne un resultat ok ou ko

Citation:

if(ok){
result = new ResultParameters(urlParameters.getUrlName(),"OK"); }
else{
result = new ResultParameters(urlParameters.getUrlName(),"KO"); }
return result;
}

la classe Urlparameter à cette forme

Citation:

public class UrlParameters {
private String url;
private String urlName;

public UrlParameters(String url,String urlName){
this.url = url;
this.urlName = urlName;
}
avec des getters et des setters

Cela fait 4 mois que je travaille dessus, et cela fait également 4 mois que j'apprends java...
J'ai essayé de placer la boucle qui créé les timers dans le constructeur de ma classe main mais j'ai bien un javanullpointerexception...

...

Sur l'exception je peux pas trop d'aider :(

La trace de l'exception doit pouvoir de dire ou ca coince (normalement tu a le numéro de ligne ), ou utilises un debugger.

J'ai donc fait ceci :

Citation:

public Main(ServerParameters srvParam) {
Main.srvParam = srvParam;
for (int i = 0; i < listeSrvParameter.size(); i++)
{
srvParam = (ServerParameters)listeSrvParameter.get(i);
listUrl = srvParam.getListeUrl();

for (int j = 0; j < listUrl.size(); j++ )
{
t=new Timer();
t.schedule(new Repet((UrlParameters)listUrl.get(j)), 0, 600);
}
}
}
class Repet extends TimerTask {

UrlParameters _urlServeur;

public RepetSentinelle(UrlParameters url)
{
_urlServeur = url;
}

Lorsque j'exécute il me créé autant de timer que j'ai d'url mais les requêtes s'exécute de façon aléatoire, sinon je ne vois pas comment dois-je utiliser _urlServeur dans ma méthode run()?

J'aimerais savoir comment puis-je mettre en pause un des thread, j'ai essayé ceci dans ma méthode run() :

Citation:

if(!(reponseResultUrl.equals("OK")))
{
try {
t.wait(10000);
} catch (InterruptedException e1) {
// TODO Bloc catch auto-généré
e1.printStackTrace();
}

mais j'ai comme erreur :

Citation:

java.lang.IllegalMonitorStateException: JVMLK010: current thread not owner
at java.lang.Object.wait(Native Method)
at sentinelle.appli.MainSentinelle2$RepetSentinelle.run(MainSentinelle2.java:89)
at java.util.TimerThread.mainLoop(Timer.java:445)
at java.util.TimerThread.run(Timer.java:395)

Citation:

Envoyé par maniolo

J'ai donc fait ceci :

Lorsque j'exécute il me créé autant de timer que j'ai d'url mais les requêtes s'exécute de façon aléatoire, sinon je ne vois pas comment dois-je utiliser _urlServeur dans ma méthode run()?
Code:

1 2 3 4 5 6 7 8 run() { resultUrl = CheckUrl.checkUrl(_urlServeur ); reponseResultUrl = resultUrl.getCodeReponse(); }

pour le côté aléatoire ... met de la trace sur la sortie standard avec le nom du thread (cf Thread.getCurrentThread().getName()) et la date et l'heure.
Histoire de bien comprendre ce qui se passe

Pour endormir ton thread 10 secondes :
Code:

1 2 3 4 5 6 7 8 9 10 if(!(reponseResultUrl.equals("OK"))) { try { // Endors le thread courant pendant 10 sec. Thread.sleep(10000); } catch (InterruptedException e1) { // TODO Bloc catch auto-généré e1.printStackTrace(); }
Un tutoriel chez Sun sur les timers : http://java.sun.com/docs/books/tutor...ads/timer.html

Et lire aussi voir les tutoriels et cours de formation pour apprendre Java : http://java.developpez.com/cours/

Pour vous tous, est-il possible d'utiliser la balise [code] et de faire un effort pour formater votre code, merci.

désolé d'habitude c'est Eclipse qui fait le boulot.
Vivement le shift+Ctrl+F sur developpez.com
:mouarf:

(allez promis on fera un effort)

Tu sais je m'en moque je ne répond pas à ce post, mais si jamais des gens veulent de creuser la tête c'est pas facile...

Citation:

Envoyé par thibaut

Tu sais je m'en moque je ne répond pas à ce post, mais si jamais des gens veulent de creuser la tête c'est pas facile...

Pas de problème 8-)
C'est toi qui as raison

:merci: beaucoup manitoba pour ton aide précieuse cela semble fonctionner. je laisse cependant mon post en non résolu pour l'instant , car j'essaye de bien comprendre le fonctionnement. Mon appli a gagné en rapidité, c'est impressionant, les requêtes vont très vite, je ne comprend pas encore vraiment pourquoi elles s'exécutent quand bon leur semble , j'imagine qu'il faut les synchroniser, en tout cas merci encore :P !