Discussion :

[The_GuiGui]

Bonjour,
Depuis quelques jours je me prends pas mal la tête.
J'ai un jar inclus dans mon programme java.
Je lance une commande du jar depuis mon programme java et les résultats sortent sur la sortie stdout et stderr.
Comme j'ai besoin de ce résultat je me suis dis, pas de problème on va capturer les sorties en mémoire via ByteArrayOutputStream.
Sous eclipse -> pas de pb
En production, cela ne fonctionne pas, la sortie err n'est pas capturé et la commande est lancée avec du retard par rapport aux suites d'instructions de mon programme.
Je me suis dis : problème de thread.
Donc vas y implémente un thread. Bon, toujours pas de résultat. J'ai arrêté de vouloir charger la mémoire, j'ai suivi ce tuto https://blogs.oracle.com/nickstephen...system_out_and pour rediriger les sorties vers un fichier.
La je crée le thread à partir d'une fonction, la redirection, la commande et ré-applique System.out, Sytem.err aux anciennes valeurs.
Puis le thread est lance et .
Je ne capture toujours pas la sortie stderr mais la sortie sdtout, oui.

Désolé si je suis confus,
Là je suis perdu...
Merci

[joel.drigo]

Salut,

Quand tu parles de lancer une commande du jar, tu veux dire que tu exécutes une méthode main() d'une classe du jar avec une commande du type "java -jar ..." ? Dans ce cas utilise un ProcessBuilder, et

Code :

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

1
2
3
4
5
ProcessBuilder pb = new ProcessBuilder( "java", "-jar"...);
 
pb.redirectError(Redirect.toFile( errfile ));
pb.redirectOutput(Redirect.toFile( stdfile ));
pb.start();

[The_GuiGui]

Effectivement j'avais pensé à cette possibilité. Je ne l'ai pas tester car j'aimerais vraiment inclure le jar dans le projet et de directement appeler une commande de ce jar. Ca m’évite de vérifier le path du jar, et je maîtrise cette version. Tant que je ne recompile pas mon projet j'utilise toujours la même version.
J'ai réussi à capturer ce flux d'erreur quelquefois mais je pense que c'est aléatoire.
Y a t il une suite logique entre Thread - Capture du flux d'erreur - Tache ?

[joel.drigo]

de directement appeler une commande de ce jar.

Tu ne répoonds pas directement à ma question ! Je déduis du fait que tu ne confirmes pas sur le fait que tu exécutes un "java -jar" que tu parles en fait d'invoquer directement une méthode d'une classe de ce jar.

Normalement, il n'y a pas de raison d'invoquer la méthode dans un thread. Il y a une problématique à prendre en compte : les sorties standard et erreur sont bufferisées, rien ne garantit donc que l'invocation terminée, le flux soit complètement vidé dans ton fichier. Essaye simplement de forcer le vidage par appel de flush(), au retour de l'appel de la méthode du jar. En revanche, il méthode utilisé pose un autre problème, la fermeture du fichier. Il faudrait faire une implémentation hybride qui te permet d'indiquer un fichier avant invocation, et de fermer après (ce qui forcera le flush() par la même occasion), ainsi, après invocation, les sorties repartiraient normalement vers la console.

Si cela ne fonctionne pas, montre-nous alors ton code.

PS une autre voie serait de faire une invocation par ligne de commande en déterminant dynamiquement l'emplacement du jar. S'il est inclus dans ton application, tu peux en contrôler facilement l'emplacement.

[The_GuiGui]

Oui effectivement, je ne fais pas d'appel à "java -jar". Je ne passe pas par "Process Builder" ou par "Runtime".
J'ai essayé avec un flush sur les 2 sorties et c'est sans effet. Avec ou sans thread c'est le même résultat.
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
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
105
106
107
108
109
110
111
112
113
114
115
public static void Main(String args){
 
	RedirectStream redirect = RedirectStream(new File(path));
	redirect.CallRedirect();
 
	Program.Call(args);
 
	redirect.CallClose();
}
 
public class Program{
 
	public static void Call(String[] args){
		//Programme contenu dans un jar dans le projet
		CommandLine c = CommandLine(args);	
	}
 
public class RedirectStream {
 
	private PrintStream oldout;
	private PrintSteam olderr;
	private File f;
 
	public RedirectStream(File f){
		this.oldout=System.out;
		this.olderr=System.err;
		this.f=f;
	}
 
	public void CallRedirect(){
        LogManager logManager = LogManager.getLogManager();
        logManager.reset();
 
        // log file max size 10K, 3 rolling files, append-on-open
        Handler fileHandler = new FileHandler(this.f, 10000, 3, true);
        fileHandler.setFormatter(new SimpleFormatter());
        Logger.getLogger("").addHandler(fileHandler);    
        PrintStream stdout = System.out;                                       
        PrintStream stderr = System.err;                                       
 
        Logger logger;                                                         
        LoggingOutputStream los;                                               
 
        logger = Logger.getLogger("stdout");                                   
        los = new LoggingOutputStream(logger, StdOutErrLevel.STDOUT);          
        System.setOut(new PrintStream(los, true));                             
 
        logger = Logger.getLogger("stderr");                                   
        los= new LoggingOutputStream(logger, StdOutErrLevel.STDERR);           
        System.setErr(new PrintStream(los, true));                             
	}
 
	public void CloseRedirect(){
 
	System.out.flush();
	System.err.flush();
	System.setOut(this.oldout);
	System.setErr(this.olderr);
	}
    }                                                                          
}                                                                              
public class StdOutErrLevel extends Level {
 
    private StdOutErrLevel(String name, int value) {
        super(name, value);
    }
 
    public static Level STDOUT =
        new StdOutErrLevel("STDOUT", Level.INFO.intValue()+53);
 
    public static Level STDERR =
        new StdOutErrLevel("STDERR", Level.INFO.intValue()+54);
 
 
protected Object readResolve()
        throws ObjectStreamException {
        if (this.intValue() == STDOUT.intValue())
            return STDOUT;
        if (this.intValue() == STDERR.intValue())
            return STDERR;
        throw new InvalidObjectException("Unknown instance :" + this);
    }   
}
 
class LoggingOutputStream extends ByteArrayOutputStream { 
 
    private String lineSeparator; 
 
    private Logger logger; 
    private Level level; 
 
    public LoggingOutputStream(Logger logger, Level level) { 
        super(); 
        this.logger = logger; 
        this.level = level; 
        lineSeparator = System.getProperty("line.separator"); 
    } 
 
    public void flush() throws IOException { 
 
        String record; 
        synchronized(this) { 
            super.flush(); 
            record = this.toString(); 
            super.reset(); 
 
            if (record.length() == 0 || record.equals(lineSeparator)) { 
                // avoid empty records 
                return; 
            } 
 
            logger.logp(level, "", "", record); 
        } 
    } 
}

Beaucoup du code est inspiré du blog mentionné.
Penses tu que faire appel à la méthode du jar en passant par une méthode "static" puisse être le problème. Je n'aurais pas l'ensemble du code sous la main ce week end pour tester...
Vois tu quelque chose qui puisse être le problème ?

[The_GuiGui]

Bonjour,
Le fait de passer par une méthode static ne semble pas poser problème car le problème persiste sans.

[joel.drigo]

Oui, ça, le fait de passer en static ou pas n'a pas de raison de changer quoique ce soit.
C'est quoi le code de la classe CommandLine ?

Je n'ai pas le temps de regarder le reste du code du logging pour le moment. Mais j'ai deux autres questions : c'est quoi le jar exactement ? Le code source est-il disponible ?

[The_GuiGui]

Oui
Voici le github du code source, la classe c'est CommandLineGatk
https://github.com/broadgsa/gatk/tre...te/gatk/engine

[The_GuiGui]

Bon j'aurais du lire la doc du soft. Ils détournent leur OutputStream, je vais voir avec eux.
Merci beaucoup, j'ai pu ecarter une erreur de code de mon cote, je n'aurais pas su avancer sans cela