Discussion :

[JohnNC]

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 :

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

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 :

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

	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 :

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

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

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

Code :

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

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

mais le

Code :

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

	pc.consume()

reste toujours bloqué, comme avant (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()" ?

[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".



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


a++

[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 :

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

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 :

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

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"

[adiGuba]

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).

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 ?

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++

[JohnNC]

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

Alors :

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 :

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
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é

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).

[adiGuba]

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 :

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
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 :

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

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++