java - 如何从进程中获取输出并设置超时？

Question

如何在设置超时值时获取进程的输出？

我目前正在使用 Apache Commons IO utils 从进程的标准和错误输出中创建一个字符串。

下面的代码(带有注释)适用于终止的进程。但是，如果进程没有终止，主线程也不会终止!

如果我取消对注释代码的注释，而是注释掉 process.waitfor()，该方法将正确销毁非终止进程。但是，对于终止进程，无法正确获得输出。似乎一旦 waitFor 完成，我就无法获取进程的输入和错误流？

最后，如果我试图将注释部分移动到 process.waitFor() 当前所在的位置，请删除 process.waitFor() 并取消注释部分，然后对于非终止进程，主线程也不会停止。这是因为永远不会到达 process.waitFor(15, ...)。

private static Outputs runProcess(String command) throws Exception {
    Process process = Runtime.getRuntime().exec(command);

    // if (!process.waitFor(15, TimeUnit.SECONDS)) {
    // System.out.println("Destroy");
    // process.destroy();
    // }

    // Run and collect the results from the standard output and error output
    String stdStr = IOUtils.toString(process.getInputStream());
    String errStr = IOUtils.toString(process.getErrorStream());

    process.waitFor();

    return new Outputs(stdStr, errStr);
}

Answer 1

正如@EJP 建议的那样，您可以使用不同的线程来捕获流或使用 ProcessBuilder 或从您的命令重定向到文件。
以下是我认为您可以使用的 3 种方法。

1. 对流使用不同的线程。

   Process process = Runtime.getRuntime().exec("cat ");
   
   ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(2);
   
   Future<String> output = newFixedThreadPool.submit(() -> {
       return IOUtils.toString(process.getInputStream());
   });
   Future<String> error = newFixedThreadPool.submit(() -> {
       return IOUtils.toString(process.getErrorStream());
   });
   
   newFixedThreadPool.shutdown();
   
   // process.waitFor();
   if (!process.waitFor(3, TimeUnit.SECONDS)) {
       System.out.println("Destroy");
       process.destroy();
   }
   
   System.out.println(output.get());
   System.out.println(error.get());
   

2. 使用 ProcessBuilder

   ProcessBuilder processBuilder = new ProcessBuilder("cat")
           .redirectError(new File("error"))
           .redirectOutput(new File("output"));
   
   Process process = processBuilder.start();
   
   // process.waitFor();
   if (!process.waitFor(3, TimeUnit.SECONDS)) {
       System.out.println("Destroy");
       process.destroy();
   }
   
   System.out.println(FileUtils.readFileToString(new File("output")));
   System.out.println(FileUtils.readFileToString(new File("error")));
   

3. 在命令中使用重定向运算符将输出和错误重定向到文件，然后从文件读取。

Here是非常好的博客，它解释了处理 Runtime.Exec

的不同方式