Discussion :

[Nalfeim]

Bonjour tout le monde.

Je travaille sur deux trois classes destinés à faire communiquer deux processus de mon API via des objects.

Le fonctionnement se veut le plus simple possible : une classe du process A crée le process B. Ce faisant, A se garde sous le coude un object input stream et un object output stream correspondant à B, et les deux communiquent à l'aide d'object serializés prévus à cet effet.

Histoire de rester propre j'ai donc prévu les dites deux trois classes dédié à la comm'. Et je bloque bêtement au début :

Code :

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

1
2
3
4
5
6
7
8
9
	public StreamChannel(InputStream stdInput, OutputStream 
		try {					
			objectOutput = new ObjectOutputStream(stdOutput);
			objectInput = new ObjectInputStream(stdInput);	
		} catch (IOException e) {
			getLog().getLogger().severe(
			    "Unable to create object stream ! " + e.getMessage());
		}
	}

Pour tester j'appelle ce constructeur avec System.in, System.out et System.err. Le ObjectOutputStream passe, puis ça freeze sur le ObjectInputStream(stdInput). Pas de message d'erreur, pas de plantage, juste bloque - plus rien.
Ce n'est pas l'usage normal prévu qui lui s'apparente plutôt à ça

Code :

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

1
2
3
process = rt.exec("D:\\...\\start.bat");	
InputStream is = process.getInputStream();
StreamChannel st = new StreamChannel(is,...)

Mais j'aimerai bien savoir quel est le problème quand même, si quelqu'un sait ?

[X-plode]

En fait se que tu essaies de faire c'est un pipe c'est ca ?

Tu veux que se que retourne process soit mis dans le Input c'est ca ?

[Nalfeim]

Il me semble oui, mais je ne connais pas spécialement le mécanisme des pipes donc je ne l'ai pas mentionné.

[X-plode]

Alors la solution serait d'utiliser PipedOutputStream je pense

[Nalfeim]

Okay, du coup je pensais avoir trouvé mon bonheur avec cet exemple :

http://prevert.upmf-grenoble.fr/Prog...putStream.html

Mais en fin de compte, j'ai quand même besoin d'ObjectInputStream et ObjectOutputStream pour faire du transfert d'objet. Et du coup j'ai toujours un freeze à la création

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
public PipeChannel(PipedInputStream input, PipedOutputStream output) {

		this.input = input;
		this.output = output;
		
		try {								
			objectOutput = new ObjectOutputStream(output);	
			objectInput = new ObjectInputStream(input); // Freeze sur cette ligne		
		} catch (IOException e) {
			getLog().getLogger().severe(
			    "Unable to create object stream ! " + e.getMessage());
		}

	}

[X-plode]

Et si tu fais

Code :

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

ObjectInputStream objectInput = new ObjectInputStream(PipedInputStream(objectOutput));

[tchize_]

new ObjectInputStream() lit les header dans le stream. Tant que l'application lancée n'a pas écrit ses header, cette ligne ne retournera pas:

Code :

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

1
2
3
4
5
6
7
8
9
10
public ObjectInputStream(InputStream in) throws IOException {
	verifySubclass();
	bin = new BlockDataInputStream(in);
	handles = new HandleTable(10);
	vlist = new ValidationList();
	enableOverride = false;
	readStreamHeader();
	bin.setBlockDataMode(true);
    }

Ce header doit etre écrit par l'autre applicaiton dans le cadre de new ObjectOutputStream(stream).

Note que la particularité des stdout et stdin, c'est qu'ils ne sont pas flushé automatiquement par l'os. Faut donc penser à faire un out.flush() après chaque opération pour être sur que l'autre process recoive ce que t'as envoyé.