Démarrage d'un processus avec stdin/stdout/stderr hérité en Java 6

Question

Si je démarre un processus via la classe ProcessBuilder de Java, j'ai un accès complet aux flux d'erreur standard, standard et standard de ce processus en tant que Java InputStreams et OutputStreams. Cependant, je ne peux pas trouver un moyen de connecter de façon transparente ces flux à System.in, System.out, et System.err.

Il est possible d'utiliser redirectErrorStream() pour obtenir un seul InputStream qui contient la norme de subprocess résultats et les erreurs standard, et la boucle juste par cela et l'envoyer par ma sortie standard, mais je ne peux pas trouver un moyen de le faire et laisser le type d'utilisateur dans le processus, comme il ou elle pourrait si j'ai utilisé l'appel C system().

Cela semble être possible dans Java SE 7 quand il sortira - je me demande simplement s'il existe une solution de contournement maintenant. Points bonus si le résultat de isatty() dans le processus enfant passe par la redirection.

Answer 1

Vous devrez copier les flux de sortie, d'erreur et d'entrée Process vers les versions du système. La méthode la plus simple consiste à utiliser la classe IOUtils du package Commons IO. Le copy method semble être ce dont vous avez besoin. Les invocations de méthode de copie devront être dans des threads séparés.

Voici le code de base:

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

Une variante de la réponse de John qui compile et ne vous oblige pas à utiliser Commons 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

Pour System.in utiliser la pipein() suivante au lieu de pipe()

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

Mise en oeuvre:

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(); 

}