在使用 java 的 `runtime.exec` 或 `processbuilder` 执行外部命令时，由 `process` 对象返回的标准输入、输出和错误流必须被显式关闭。未能及时处理或关闭这些流会导致资源泄漏、子进程阻塞甚至死锁，因为操作系统为这些流提供的缓冲区是有限的。此外，子进程不会随 `process` 对象的垃圾回收而自动终止，因此正确管理其生命周期和相关流至关重要。
引言：Runtime.exec 与进程管理
Java 提供了 Runtime.exec() 方法和 ProcessBuilder 类，允许应用程序在操作系统中执行外部命令或程序。当调用这些方法时，Java 会创建一个 Process 对象，该对象代表了新启动的子进程。这个 Process 对象提供了与子进程进行通信的接口，包括获取其标准输入流 (getOutputStream())、标准输出流 (getInputStream()) 和标准错误流 (getErrorStream())。
为何必须关闭进程流？
许多开发者可能会误以为，只要 Process 对象不再被引用，Java 垃圾回收机制就会自动清理所有相关资源，包括这些流。然而，事实并非如此，未能正确管理和关闭这些流会导致一系列严重问题：
- 资源泄漏： 操作系统为每个打开的流分配了文件句柄、内存缓冲区等资源。如果这些流不被显式关闭，即使 Java 侧的 Process 对象被垃圾回收，操作系统层面的资源也可能不会被及时释放，从而导致文件句柄泄漏、内存占用增加，最终可能耗尽系统资源。
- 子进程阻塞与死锁： 操作系统为子进程的标准输入、输出和错误流提供了有限的缓冲区。如果父进程（Java 应用）未能及时从子进程的输出流（getInputStream() 和 getErrorStream()）中读取数据，或者未能及时向子进程的输入流（getOutputStream()）写入数据，这些缓冲区可能会被填满。一旦缓冲区满载，子进程可能会被阻塞，等待父进程读取或写入。如果父进程也在等待子进程完成，而子进程又因缓冲区满而阻塞，就可能发生经典的“生产者-消费者”死锁。
- 进程生命周期独立性： Process 对象在 Java 虚拟机中的生命周期与它所代表的子进程在操作系统中的生命周期是独立的。即使 Process 对象被垃圾回收，子进程也可能仍在后台运行。这意味着，如果子进程的流没有被妥善处理，它可能会持续占用资源，甚至在父进程结束后继续运行，成为“僵尸进程”或“孤儿进程”。
进程流处理机制
Process 对象提供了三个关键方法来访问子进程的流：
- InputStream getInputStream(): 获取子进程的标准输出流。父进程通过读取此流来获取子进程的输出。
- OutputStream getOutputStream(): 获取子进程的标准输入流。父进程通过向此流写入数据来向子进程提供输入。
- InputStream getErrorStream(): 获取子进程的标准错误流。父进程通过读取此流来获取子进程的错误输出。
这些流本质上是 Java 的 InputStream 和 OutputStream 实例，因此它们需要像处理文件流或网络流一样，在不再需要时进行关闭。
立即学习“Java免费学习笔记（深入）”；
最佳实践与示例代码
为了避免上述问题，推荐采用以下最佳实践来管理 Process 及其流：
- 使用 ProcessBuilder： ProcessBuilder 比 Runtime.exec() 提供了更多的灵活性和控制，例如设置工作目录、环境变量等。
- 确保流被读取和关闭： 即使您不关心子进程的输出或错误信息，也应该读取并清空相应的流，以防止缓冲区溢出和死锁。
- 使用 try-with-resources 或 finally 块： 确保在操作完成后，所有打开的流都被关闭。对于 Java 7 及更高版本，try-with-resources 是管理流的推荐方式。
- 并发读取流： 对于可能产生大量输出的子进程，最好使用单独的线程来并发读取其标准输出流和标准错误流，以避免阻塞父进程。
以下是一个示例代码，演示了如何执行一个简单的命令（例如在 Linux/macOS 上是 ls -l，在 Windows 上是 cmd /c dir），并正确处理其输出和错误流：
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
public class ProcessStreamManagement {
public static void main(String[] args) {
// 根据操作系统选择不同的命令
String os = System.getProperty("os.name").toLowerCase();
String[] command;
if (os.contains("win")) {
command = new String[]{"cmd.exe", "/c", "dir"};
} else {
command = new String[]{"ls", "-l"};
}
Process process = null;
ExecutorService executor = Executors.newFixedThreadPool(2); // 用于并发读取输出和错误流
try {
ProcessBuilder builder = new ProcessBuilder(command);
// 可以设置工作目录、环境变量等
// builder.directory(new File("/path/to/workdir"));
process = builder.start();
// 提交任务以并发读取标准输出和标准错误流
Future<String> outputFuture = executor.submit(() -> {
StringBuilder output = new StringBuilder();
try (BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()))) {
String line;
while ((line = reader.readLine()) != null) {
output.append(line).append(System.lineSeparator());
}
} catch (IOException e) {
System.err.println("Error reading process output: " + e.getMessage());
}
return output.toString();
});
Future<String> errorFuture = executor.submit(() -> {
StringBuilder error = new StringBuilder();
try (BufferedReader reader = new BufferedReader(new InputStreamReader(process.getErrorStream()))) {
String line;
while ((line = reader.readLine()) != null) {
error.append(line).append(System.lineSeparator());
}
} catch (IOException e) {
System.err.println("Error reading process error stream: " + e.getMessage());
}
return error.toString();
});
// 如果需要向子进程写入数据，可以使用getOutputStream()
// try (OutputStream os = process.getOutputStream()) {
// os.write("input for subprocess".getBytes());
// os.flush();
// }
// 等待子进程执行完毕，并获取退出码
int exitCode = process.waitFor();
System.out.println("Command exited with code: " + exitCode);
// 获取并发读取的结果
String outputResult = outputFuture.get();
String errorResult = errorFuture.get();
System.out.println("\n--- Standard Output ---");
System.out.println(outputResult);
System.out.println("\n--- Standard Error ---");
System.out.println(errorResult);
} catch (IOException | InterruptedException | java.util.concurrent.ExecutionException e) {
System.err.println("Failed to execute command: " + e.getMessage());
Thread.currentThread().interrupt(); // 重新设置中断状态
} finally {
// 确保线程池关闭
executor.shutdown();
try {
if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
executor.shutdownNow(); // 强制关闭
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
// 显式销毁进程，以防其仍在运行（例如，如果父进程在waitFor()之前中断）
if (process != null) {
process.destroy();
// 也可以使用 destroyForcibly() 来强制终止
}
}
}
}在上述代码中，我们使用了 ExecutorService 来创建独立的线程，分别读取子进程的标准输出和标准错误流。这有效地避免了因缓冲区满而导致的潜在死锁。try-with-resources 模式用于确保 BufferedReader（以及其底层的 InputStream）在读取完成后被关闭。
重要注意事项
- 始终读取流： 即使您对子进程的输出不感兴趣，也必须读取并清空其 getInputStream() 和 getErrorStream()，以防止子进程因输出缓冲区满而阻塞。
- Process.waitFor()： 调用此方法会使当前线程阻塞，直到子进程终止。它返回子进程的退出码，这对于判断命令执行是否成功至关重要。
- Process.destroy() / Process.destroyForcibly()： 如果您需要在子进程完成之前终止它，或者在父进程异常退出时清理子进程，可以使用 destroy() 方法。destroyForcibly() 会尝试更强制地终止进程。
- 异常处理： ProcessBuilder.start() 和流操作都可能抛出 IOException。process.waitFor() 可能抛出 InterruptedException。务必进行适当的异常处理。
- 资源释放顺序： 理想情况下，应该在 process.waitFor() 之后，并且在 Process 对象不再需要时，关闭所有相关的流。在 finally 块中关闭流是一个健壮的策略。
总结
正确管理 Runtime.exec 或 ProcessBuilder 创建的子进程的流是 Java 中执行外部命令的关键。未能及时读取和关闭这些流不仅会导致资源泄漏，还可能引发子进程阻塞和死锁。通过采用 ProcessBuilder、并发读取流、使用 try-with-resources 确保流关闭，并理解 Process 对象的生命周期，可以构建出更加健壮和高效的应用程序。始终记住，即使 Java 对象被垃圾回收，操作系统层面的资源也需要您的代码显式管理。
