Iniciar un proceso con stdin/stdout/stderr heredado en Java 6

Question

Si comienzo un proceso a través de la clase ProcessBuilder de Java, tengo acceso completo a las corrientes de error estándar estándar, estándar y de proceso estándar como Java InputStreams y OutputStreams. Sin embargo, no puedo encontrar una forma de conectar esas transmisiones sin problemas a System.in, System.out y System.err.

Es posible utilizar redirectErrorStream() para obtener un único InputStream que contiene la norma del subproceso y error estándar, y el bucle sólo a través de eso y enviarlo a través de mi nivel fuera, pero no puedo encontrar una manera de hacer eso y dejar el usuario escribe en el proceso, como podría hacerlo si usara la llamada C system().

Esto parece ser posible en Java SE 7 cuando sale, me pregunto si hay una solución ahora. Puntos de bonificación si el resultado de isatty() en el proceso hijo lleva a cabo la redirección.

Answer 1

Tendrá que copiar el Process de salida, errar y las secuencias de entrada a las versiones del sistema. La forma más fácil de hacerlo es usar la clase IOUtils del paquete Commons IO. El copy method parece ser lo que necesita. Las invocaciones del método de copia deberán estar en hilos separados.

Aquí es el código básico:

// Assume you already have a processBuilder all configured and ready to go 
final Process process = processBuilder.start(); 
new Thread(new Runnable() {public void run() { 
    IOUtils.copy(process.getOutputStream(), System.out); 
} }).start(); 
new Thread(new Runnable() {public void run() { 
    IOUtils.copy(process.getErrorStream(), System.err); 
} }).start(); 
new Thread(new Runnable() {public void run() { 
    IOUtils.copy(System.in, process.getInputStream()); 
} }).start(); 

Answer 2

Una variación en la respuesta de Juan que compila y no requieren el uso de los Comunes IO:

private static void pipeOutput(Process process) { 
    pipe(process.getErrorStream(), System.err); 
    pipe(process.getInputStream(), System.out); 
} 

private static void pipe(final InputStream src, final PrintStream dest) { 
    new Thread(new Runnable() { 
     public void run() { 
      try { 
       byte[] buffer = new byte[1024]; 
       for (int n = 0; n != -1; n = src.read(buffer)) { 
        dest.write(buffer, 0, n); 
       } 
      } catch (IOException e) { // just exit 
      } 
     } 
    }).start(); 
} 

Answer 3

Para System.in usa la siguiente pipein() en lugar de pipe()

pipein(System.in, p.getOutputStream()); 

Implementación:

private static void pipein(final InputStream src, final OutputStream dest) { 

    new Thread(new Runnable() { 
     public void run() { 
      try { 
       int ret = -1; 
       while ((ret = System.in.read()) != -1) { 
        dest.write(ret); 
        dest.flush(); 
       } 
      } catch (IOException e) { // just exit 
      } 
     } 
    }).start(); 

}