blocage du programme sur méthode getConnexion

**smith_dev** · 01/12/2008, 17h46

Bonjour,
j'ai un problème avec la méthode getConnexion de la classe DriverManager. Mon programme comprend deux threads qui exécutent chacun une méthode synchronized différente toutes les secondes. Dans chacune des méthodes il y a un appel à getConnexion. La base est volontairement inaccessible puisque je souhaite effectuer un traitetement particulier en mode déconnecté.

Le problème c'est qu'au bout d'un certain nombres d'éxécutions la méthode getConnexion se bloque (plus d'exception SQLException levée). J'ai lu qu'il fallait pour utiliser une même connexion en multithread passer par des méthodes synchronized ce que je pense avoir fait donc je chercher toujours mon erreur. Merci de pour vos lumières !

J'utilise le driver com.mysql.jdbc.Driver et le connector myslql 5.1.7 (j'ai essayé avec le 5.1.6 sans succès).

Voici mes deux threads :

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
 
public class SurvProductionFichier extends Thread{
 
    private SurvMetier monSurvMetier;
    public SurvProductionFichier(SurvMetier lInterface)
    {
        monSurvMetier = lInterface;
    }
 
    public void run()
    {
        Random rnd;
        int tempo = 0;
        while(Thread.currentThread().isInterrupted() == false)
        {
            //Je lance la surveillance des fichiers 
            monSurvMetier.traiterFichierProduit();
            try
            {
                //TEST
                tempo = 0;
                //NON TEST
                //On endors le thread pendant un temps aléatoire entre 1 et 30 secondes
                //rnd = new Random();
                //tempo = rnd.nextInt(29);
                sleep((tempo+1)*1000);
            }
            catch(InterruptedException e)
            {
                    GestionLoggerProductionFichier.getLogger().log(Level.WARNING,"Thread SurvProjet interrompu dans son sommeil",e);
                    Thread.currentThread().interrupt();
            }
        }
        GestionLoggerProductionFichier.getLogger().log(Level.INFO,"Thread SurvProjet arrete");
    }
}

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
 
public class SurvMajBdd extends Thread{
 
    private SurvMetier monSurvMetier;
    public SurvMajBdd(SurvMetier lInterface)
    {
        monSurvMetier = lInterface;
    }
 
 
    public void run()
    {
        Random rnd;
        int tempo = 0;
        while(Thread.currentThread().isInterrupted() == false)
        {
            //Je lance la surveillance de la bdd
            monSurvMetier.recupererMajListe();
            try
            {
                //TEST
                //tempo = 0;
                //NON TEST
                //On endors le thread pendant un temps aléatoire entre 1 et 30 secondes
                rnd = new Random();
                tempo = rnd.nextInt(29);
                sleep((tempo+1)*1000);
            }
            catch(InterruptedException e)
            {
                    GestionLoggerBdd.getLogger().log(Level.WARNING,"Thread SurvProjet interrompu dans son sommeil",e);
                    Thread.currentThread().interrupt();
            }
        }
        GestionLoggerBdd.getLogger().log(Level.INFO,"Thread SurvProjet arrete");
    }
}

La classe SurvMetier

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
public class SurvMetier {
 
    GestionDonnee monGestionnaire;
 
    public SurvMetier()
    {
        monGestionnaire = new GestionDonnee();
    }
 
    synchronized void recupererMajListe()
    {
        GestionLoggerProductionFichier.getLogger().log(Level.INFO, "#########    DEBUT recupererMajListe         #########");
        monGestionnaire.creerFichierMAJ();
        GestionLoggerProductionFichier.getLogger().log(Level.INFO, "#########    FIN recupererMajListe         #########");
    }
 
    synchronized void traiterFichierProduit()
    {
        GestionLoggerProductionFichier.getLogger().log(Level.INFO, "#########    DEBUT traiterFichierProduit         #########");
        monGestionnaire.traiterFichierProduit();
        GestionLoggerProductionFichier.getLogger().log(Level.INFO, "#########    FIN traiterFichierProduit         #########");
    }
}

La classe qui effectue les traitements

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
 
public class GestionDonnee {
 
 
	//-- Donnée de l'application --//
        private int nbTentativeInsertionEnBase;
        private int NB_MAX_TENTATIVE = 2;
 
	public GestionDonnee()
	{
        maBDD = new BddMySql();
	}
 
 
 
   public void traiterFichierProduit()
	{
		GestionLoggerProductionFichier.getLogger().log(Level.FINE, "Debut méthode");
		LinkedList<TempsSurv> lesTemps = null;
		TempsSurv leTemps = null;
		String leFichier = "";
		String lePath = "";
		boolean premierErreur = false;
		//On essaye d'ouvrir la connexion
		try
		{
			//Ouverture de la connexion avec la BDD
			maBDD.connexion(GestionLoggerProductionFichier.getLogger());
			//On regarde si il y a un fichier TempsSurv dans le rep final
			lePath = monXML.getPathExploitationFinal();
			leFichier = monXML.fichierTempsSurvFinalExiste();
		}
		catch(Exception e)
		{
		   GestionLoggerProductionFichier.getLogger().log(Level.INFO, "La BDD distante n'est pas atteignable, travail en mode déconnecté");
		   premierErreur = true;
		}
		GestionLoggerProductionFichier.getLogger().log(Level.FINE, "Fin méthode");
	}
 
	public void creerFichierMAJ()
	{
		GestionLoggerBdd.getLogger().log(Level.INFO, "Debut méthode");
		boolean premierErreur = false;
		long laDateMaj = -1;
		try
		{
			//Ouverture de la connexion avec la BDD
			GestionLoggerBdd.getLogger().log(Level.INFO, "Je tente la connexion");
			maBDD.connexion(GestionLoggerBdd.getLogger());
		}
		catch(Exception e)
		{
			GestionLoggerProductionFichier.getLogger().log(Level.INFO, "La BDD distante n'est pas atteignable, travail en mode déconnecté");
		   premierErreur = true;
		}
	}
}

et la méthode d'accès à la bdd présente dans la classe BddMySql

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
 
public void connexion(Logger leLogger) throws Exception
	{
            leLogger.log(Level.INFO, "Debut methode");
            conn = null;
            st = null;
            try
            {
                leLogger.log(Level.INFO, "Class.forName(com.mysql.jdbc.Driver)");
                nbConnection++;
                leLogger.log(Level.INFO, "NB CONNECTION : "+nbConnection);
                DriverManager.setLoginTimeout(5);
                leLogger.log(Level.INFO, "TIMEOUT: "+DriverManager.getLoginTimeout());
 
                conn = DriverManager.getConnection(strConnexion, user, strMdp);
 
                leLogger.log(Level.INFO, "conn.createStatement()");
                st = conn.createStatement();
                leLogger.log(Level.INFO, "Apres");
            }
            catch(SQLException e)
            {
                leLogger.log(Level.WARNING, "CONNEXION IMPOSSIBLE : ",e);
                fermerConnexion(leLogger);
                throw e;
            }
            catch(Exception e){
               leLogger.log(Level.WARNING, "CONNEXION IMPOSSIBLE : ",e);
               throw e;
            }
            leLogger.log(Level.INFO, "Fin methode");
	}

**tchize_** · 01/12/2008, 20h21

alors, évite d'envoyer autant de code, ca prend beaucoup de temps à lire, commence par simplifier ce que tu envoie. Car là, non seulement y a une tartine énorme, mais il manque le principal. Le code où tu lance tes deux threads, qu'on vois ce que tu leur passe.

**smith_dev** · 01/12/2008, 20h47

A ok désolé c'est vrai que j'ai mis bcp de code.
Voilà le lancement de mes deux threads :

Code :

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

1
2
3
4
5
6
 
leMetier = new SurvMetier();
SurvProductionFichier monThreadSurvGestionSurveillance= new SurvProductionFichier(leMetier);
monThreadSurvGestionSurveillance.start();
SurvMajBdd monThreadSurvBDD= new SurvMajBdd(leMetier);
monThreadSurvBDD.start();

Deuxième erreur de ma part, ce n'est pas forcément lié aux threads puisque quand j'éxécute soit l'un soit l'autre des threads, il se passe la même chose, le prog s'arrête et à chaque fois la dernière trace que j'obtiens c'est celle juste avant l'appel à

Code :

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

DriverManager.getConnection(strConnexion, user, strMdp);

**tchize_** · 01/12/2008, 22h39

combien de connection demande tu au total? Au delà d'un certain nombre de connections, c'est le serveur de base de donnée qui va, soit te mettre en attente qu'une connection se libère, soit t'envoyer péter (too many connections). Quand tu as fini d'utiliser une connection n'oublie pas d'appeler close() dessus, pour la libérer!

**smith_dev** · 01/12/2008, 22h50

Ok merci pour l'info mais là dans mon problème aucune connexion n'est établie, je teste juste la dispo de la bdd pour pouvoir faire un traitement si la bdd n'est pas accessible.

Dans mon test, je n'ai jamais accès à la bdd, en gros j'ai toujours l'exception SQLException qui est levée mais au bout d'un certain nombre de tentative qui varie entre 1600 et 3800 (je fais une tentative toutes les secondes), tout s'arrête sur la méthode getConnection et je ne reçois pas d'exception.

J'espère être assez claire mais merci de m'aider en tout cas.

**tchize_** · 01/12/2008, 23h11

si tu travaille dans un ide, lors du blocage, tu peux faire un "pause" de ton application et regarder où en sont les threads pour avoir une idée de ce qui bloque. Si t'es en mode console, il va falloir faire un thread dump. Essaie aussi d'attendre un moment pour voir si un timeout ne se déclenche pas.

Au fait, comme la connection (ou tout du moins la tentative) se fait sur le réseau, n'y a-t-il pas une sécurité sur le système cible qui conclue à une tentative de flood et ne répond simplement plus à tes paquets?

**djsnipe** · 02/12/2008, 22h28

Envoyé par smith_dev

Ok merci pour l'info mais là dans mon problème aucune connexion n'est établie, je teste juste la dispo de la bdd pour pouvoir faire un traitement si la bdd n'est pas accessible.

Ha si, la méthode connexion de ta classe BddMySql ouvre bien une connexion, et peut être sans la fermer. Au bout de 1600 à 3800 connexions, plus ou moins simultanées (que fait le garbage collector exactement si la connexion n'était pas fermée ?), je comprendrai que ta BDD ne réponde plus.

Au passage, si c'est pour tester ta BDD, tu peux ajouter l'exécution d'une requête très simple, pour vérifier que le moteur de ta bdd fonctionne, et pas uniquement la partie purement réseau.

blocage du programme sur méthode getConnexion

JDBC Java

Vue hybride

Discussions similaires

Partager

Partager