Runtime.getRuntime().exec() vers ProcessConsumer

Version imprimable

Après avoir lu le blog d'adiGuba (un grand merci !) j'en renvoie à mon histoire de Lancement d'un batch.
Mon problème maintenant, c'est de récupérer les flux. Avant, avec Runtime.exec(), je faisais :
Code:

1 2 3 4 5 6 String ligneOK; BufferedReader sortie = new BufferedReader(new InputStreamReader(proc.getInputStream())); while ( (ligneOK = sortie.readLine()) != null ) { this.log(" "+ligneOK); } sortie.close();
et pareil pour le stream d'erreur.

Mais maintenant, (avec l'aide donc d'adiGuba et de mon ancien post), je tente de faire la même chose, mais j'obtiens une erreur "Stream closed".

La partie

Code:

monPC.output( new FileOutputStream("out.txt") ).error( new FileOutputStream("err.txt") )

n'est donc pas intéressante puisque je ne veux pas des fichiers.
Cependant, les fichiers sont crées, donc ça marche.

J'essaie donc
Code:

1 2 3 // On crée les StringBuilder qui contiendront les sorties du process : StringBuilder out = new StringBuilder(); StringBuilder err = new StringBuilder();
mais du coup, je ne sais pas du tout comment traiter mes "BufferedReader sortie" (celui du runtime.exec() normal).
Je tiens à préciser que je ne maitrise pas du tout toutes ces notions de buffer, et que je sais pas trop quoi chercher :aie:

[Edit]
Après un peu plus de recherche, et toujours sur le blog, je test :
Code:

1 2 3 4 PipedReader lignesOk = new PipedReader(); PipedReader lignesErr = new PipedReader(); pc.output(new PipedWriter(lignesOk)).error(new PipedWriter(lignesErr));
mais le

Code:

pc.consume()

reste toujours bloqué, comme avant :aie: (comme par un ancien proc.waitFor()), et apparement toujours au moment du remplissage des flux. Je me doute que le problème vient de la ligne de commande, mais pourquoi dans le cas de fichiers, ça marche, alors qu'avec des readers/writer ça ne marche plus ???

Suis-je obligé de passer par des fichiers temporaires que je lirais après le "monPC.consume()" ?

31/03/2008, 17h02
adiGuba

Salut,

Si tu utilises des StringBuilder il te suffit de lire la chaine générée qui contiendra la totalité de la réponse (mais cela peut être consommateur de mémoire si la sortie est très grande).

Si tu utilises des PipedReader/Writer tu dois faire un consumeInBackground() car la lecture doit être faite en parallèle... mais cela revient au même problème qu'à l'origine...

Sinon si tu as un besoin plus spécifique tu peux définir tes propres "appender".

:arrow: D'où ma question : que va tu faire des données en sortie ?

a++
31/03/2008, 17h19
JohnNC
Alors, en passant par des fichiers (avec lecture tout de suite après), celà fonctionne.

Mais avec PipedReader/Writer en consumeInBackground(), toujours le même problème. Et je serais totalement incapable de définir mes propres "appender".

[EDIT]
En fait non, l'appli se bloque sur le
Code:

1 2 3 4 // lignesOk est le PipedReader BufferedReader sortie = new BufferedReader(lignesOk); while ( (ligneOK = sortie.readLine()) != null ) // etc ...
Ce qui est bizarre, c'est que suivant ce que donne le batch, il bloque soit au flux, soit à l'exécution (que ce soit runtime.exec() ou ta librairie) (sauf dans le cas où les flux sont des fichiers, comme je l'ai dis précédement)
[/EDIT]

Les données en sorties sont en fait pour un affichage dans un compte rendu de l'application.

Petite remarque : Je test donc en passant par des fichiers. Mon batch est du style :
Code:

1 2 3 4 @echo off echo lancement "c:/BLABLABLA/prog.exe" echo termine
J'ai bien les 2 echo dans le "output", mais l'affichage du "prog.exe" part directement dans le "error" :?
31/03/2008, 17h24
adiGuba

Citation:

Envoyé par JohnNC

Mais avec PipedReader/Writer en consumeInBackground(), toujours le même problème.

Comme tu utilises cela sur les 2 sorties (standards et erreurs), il faut créer deux threads de lecture sinon tu peux avoir des interblocages (cela revient au même problème qu'utilsier exec() directement).

Citation:

Envoyé par JohnNC

Les données en sorties sont en fait pour un affichage dans un compte rendu de l'application.

Oui mais comment ?
Dans tous tes codes tu essayes de faire des lectures lignes par lignes ? C'est une volonté particulière ou pas ?

Citation:

Envoyé par JohnNC

J'ai bien les 2 echo dans le "output", mais l'affichage du "prog.exe" part directement dans le "error" :?

Ca ca dépend complètement de ton "prog.exe"...

a++

Désolé j'ai fais une petite édition entre temp, sur le "blocage".

Alors :

Citation:

Envoyé par adiGuba

Oui mais comment ?
Dans tous tes codes tu essayes de faire des lectures lignes par lignes ? C'est une volonté particulière ou pas ?

par un
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 String ligneOK; BufferedReader sortie = new BufferedReader(lignesOk); //BufferedReader sortie = new BufferedReader(new InputStreamReader(new FileInputStream(ficSTD))); while ( (ligneOK = sortie.readLine()) != null ) { // cr est un objet de compteRendu : un JPanel avec un JTextPane cr.log(" "+ligneOK); } sortie.close(); // Suivi de String ligneErreur; BufferedReader sortieErr = new BufferedReader(lignesErr); //BufferedReader sortieErr = new BufferedReader(new InputStreamReader(new FileInputStream(ficERR))); while ( (ligneErreur = sortieErr.readLine()) != null ) { cr.logErreur(" "+ligneErreur); } sortieErr.close();
Et ligne par ligne, heu bah parceque celui qui travaillait avant moi faisait comme ça et que j'ai copié/collé :aie:

Citation:

Envoyé par adiGuba

Ca ca dépend complètement de ton "prog.exe"...

Ben là, je vais laisser comme ça alors (il s'agit de pg_restore de postgres).

Si c'est pour afficher la sortie dans un JTextPane tu peux l'y envoyer directement plutôt que de faire une lecture ligne par ligne.

Il te suffit d'implémenter l'interface Appendable et ses méthodes append(), sachant que ces méthodes seront appelées lorsque des données seront lu depuis le process, ce qui peut donner :

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
class DocumentAppendable implements Appendable {
 
	private final JTextComponent textComponent;
 
	public DocumentAppendable(JTextComponent component) {
		this.textComponent = component;
	}
 
	/**
         * Insertion d'un chaine dans un document,
         * en déplacant les scrollbars si neccessaire
         */
	private void insertString(final String text) {
		SwingUtilities.invokeLater(new Runnable() {
			public void run() {
				// On récupèrel e composant graphique
				JTextComponent comp = DocumentAppendable.this.textComponent;
				// On récupère le document associé
				Document doc = comp.getDocument();
				try {
					// On insert le text recu à la fin du document :
		            doc.insertString(doc.getLength(), text, null);
		            // Et on déplace les scrollbars :
		            comp.scrollRectToVisible( comp.modelToView(doc.getLength()));
		        } catch (BadLocationException e) {
		        	throw new RuntimeException(e); // Ne devrait pas arriver
		        }
			}
		});
	}
 
 
	/*
	 * On implémente les diverses méthodes de l'interface Appendable
	 * en se contentant de renvoyer vers la méthode insertString() :
	 * 
	 */
 
	public Appendable append(char c) throws IOException {
		insertString(Character.toString(c));
		return this;
	}
	public Appendable append(CharSequence csq) throws IOException {
		insertString(csq.toString());
		return this;
	}
	public Appendable append(CharSequence csq, int start, int end) throws IOException {
		insertString(csq.subSequence(start, end).toString());
		return this;
	}
}

Exemple :

Code:

1
2
3
4
5
6
	sh.command("ma ligne de commande")
		// On redirige la sortie standard vers le textpane
		.output(new DocumentAppendable(monTextPane))
		// On redirige la sortie d'erreur vers la sortie standard
		.errorRedirect() 
		.consume();

a++

01/04/2008, 09h18
JohnNC
Merci pour cette info !

[EDIT]Le errorRedirect() me donne un
Code:

1 2 Caused by: java.lang.IllegalStateException: No ProcessBuilder at com.developpez.adiguba.shell.ProcessConsumer.errorRedirect(ProcessConsumer.java:448)
[/EDIT]

Dernière question, est-ce que j'ai les messages dans l'ordre d'apparition du batch avec le errorRedirect ? (Ou si je met par exemple le même objet Appendable en output et error) ?
01/04/2008, 10h07
adiGuba
Citation:
Envoyé par JohnNC

[EDIT]Le errorRedirect() me donne un

Code:

1 2 Caused by: java.lang.IllegalStateException: No ProcessBuilder at com.developpez.adiguba.shell.ProcessConsumer.errorRedirect(ProcessConsumer.java:448)

[/EDIT]
Quel est le code correspondant et le stacktrace complet de l'exception ?

Citation:

Envoyé par JohnNC

Dernière question, est-ce que j'ai les messages dans l'ordre d'apparition du batch avec le errorRedirect ? (Ou si je met par exemple le même objet Appendable en output et error) ?

Si tu rediriges tout vers le même Appendable il est préférable d'utiliser errorRedirect() car la "redirection" est faite au lancement de l'exécutable et tout est lu par un seul thread. Sinon tu as deux threads de lecture et l'ordre peut donc varier quelque peu...

a++

Voici le code :

Code:

1
2
3
4
5
6
7
8
ProcessBuilder proc2 = new ProcessBuilder(new String[] {batch});
Process proc = proc2.start();
proc2.redirectErrorStream(true);
 
ProcessConsumer pc = new ProcessConsumer(proc) ;
 
pc.output( new FileOutputStream("c:/tempSTD.txt") ).errorRedirect();
pc.consume();

Et le stackTrace :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
 // Catch général dans l'appli
noyau.exception.NRuntimeException
	at noyau.panneau.NPanneauExécution.exécuterDansMêmeThread(NPanneauExécution.java:208)
	at noyau.panneau.NPanneauExécution.access$0(NPanneauExécution.java:197)
	at noyau.panneau.NPanneauExécution$1.run(NPanneauExécution.java:176)
// Exception levée
Caused by: java.lang.IllegalStateException: No ProcessBuilder
	at com.developpez.adiguba.shell.ProcessConsumer.errorRedirect(ProcessConsumer.java:448)
	at maintenance.menus.MTBaseRestaurer.restaurer(MTBaseRestaurer.java:308)
	at maintenance.menus.MTBaseRestaurer.restaurer(MTBaseRestaurer.java:277)
	at maintenance.menus.MTBaseRestaurer.restaurer(MTBaseRestaurer.java:256)
	at maintenance.menus.MTBaseRestaurer.lancerRestauration(MTBaseRestaurer.java:171)
	at maintenance.menus.MTBaseRestaurer.exécuterAction(MTBaseRestaurer.java:80)
	at noyau.panneau.NPanneauExécution.exécuterDansMêmeThread(NPanneauExécution.java:203)
	... 2 more

A noter peut être : Je n'utilise pas "Shell", j'utilise directement "ProcessConsumer"

01/04/2008, 11h34
adiGuba
Citation:

Envoyé par JohnNC

A noter peut être : Je n'utilise pas "Shell", j'utilise directement "ProcessConsumer"

Dans ce cas passe lui directement le ProcessBuilder plutôt que le Process, sinon la redirection du flux d'erreur n'est pas possible...
Code:

1 2 3 4 ProcessConsumer pc = new ProcessConsumer(new ProcessBuilder(new String[] {batch})) ; pc.output( new FileOutputStream("c:/tempSTD.txt") ).errorRedirect(); pc.consume();
a++
01/04/2008, 12h10
JohnNC

Merci, ça marche ! (heu sauf toujours quand j'utilise des "flux" au lieu de fichiers, mais je m'en contenterais)

Et un grand bravo pour le boulot fait sur l'API !