# commons-user mailing list archives

##### Site index · List index
Message view
Top
From Arun Ramakrishnan <aramakrish...@languageweaver.com>
Subject [exec] Piping to Input Stream using PipedInputStream
Date Wed, 23 Sep 2009 23:06:06 GMT
I am trying to build java wrapper around a binary. The idea is that I can stream in and out
of this binary that has heavy startup time.

1)      I used to be able to achieve this using ProcessBuilder ( refer to code snippet 1 )

2)      I trying to use Apache Commons Exec instead to start the binaries ( it see from the
code that it has separate threads to deal with the various streams so that the binary dosent
block due to full output or error buffers ). But, it  seems extremely complicated to open
a stream/pipe to the input of the binary. I am not sure if Code snippert 2 is the right approach
to it using Piped Streams classes.

3)      One of the problems I am having is that I don't understand why the pipe seems to close
prematurely after only one write to it. Please refer to code snippet 3 for a concise code
that demonstrates the problem I am having.

Any suggestions would be appreciated.

######################## Code Snippet 1 ##############################

Process p = "tool.exe".execute()  // uses processBuilder
BufferedOutputStream pout = new BufferedOutputStream( p.getOutputStream() )

// then use pout to send input to the tool.exe's input stream

########################  Code Snippet 3 ##############################

PipedOutputStream ps = new PipedOutputStream();
PipedInputStream is = new PipedInputStream(ps);
BufferedWriter os = new BufferedWriter(new OutputStreamWriter(ps));
String s = "hi there \n hi \n";
[1..1000].each{
println it
os.write(s);
}
os.close();
println is.getText();

######################## Code Snippet 2 ################################
import org.apache.commons.exec.*;

String line = "F:\\Suggester\\bin\\langid.bat" ;
String infile = "F:\\Suggester\\bin\\in.txt" ;
CommandLine commandLine = CommandLine.parse(line);

DefaultExecutor executor = new DefaultExecutor();
FileInputStream fis = new FileInputStream( infile )
PipedOutputStream ps = new PipedOutputStream();
PipedInputStream is = new PipedInputStream(ps);
PrintStream os = new PrintStream(ps);
String s = "hi there \n--#--\nwhatup";
[1..1000].each{
println it
os.append(s);
os.flush();
}
os.close();
println is.getText()
PumpStreamHandler ioh = new PumpStreamHandler(System.out,System.err,is);
//ioh.setProcessInputStream(System.out) his will not work
ioh.start()
executor.setStreamHandler(ioh)
//pis.write( s.getBytes() );
int exitValue = executor.execute(commandLine);
println " execution started"
println exitValue;

####################### End ##########################################


Mime
• Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message