本文旨在解决Java程序中子进程意外退出的问题，并提供保持子进程持续运行的有效方法。通过分析常见错误原因，例如在循环内关闭子进程的输入流，以及同步读写可能导致的阻塞，本文将介绍如何正确管理子进程的输入输出流，并提供使用redirectOutput或inheritIO简化流程、以及使用后台线程异步处理输入输出的两种解决方案，确保子进程稳定运行。
在Java程序中，使用ProcessBuilder创建并管理子进程是很常见的需求。然而，如果处理不当，子进程可能会意外退出，导致程序运行不稳定。本文将深入探讨导致子进程退出的常见原因，并提供几种有效的解决方案，确保子进程能够持续运行。
问题根源：资源管理不当和同步阻塞
导致子进程退出的一个常见原因是资源管理不当，尤其是在循环中使用try-with-resources语句时。例如，以下代码片段：
立即学习“Java免费学习笔记（深入）”；
try(PrintWriter stdin = new PrintWriter(Handle.getOutputStream())) {
stdin.write(getCommand.nextLine()+System.lineSeparator());
stdin.flush();
}这段代码在每次循环迭代时都会创建一个新的PrintWriter实例，并在try-with-resources块结束时自动关闭它。这意味着子进程的标准输入流（STDIN）在每次写入一行数据后都会被关闭，这会导致某些程序（如cmd.exe）在输入流关闭后立即退出。
另一个潜在的问题是同步读写可能导致的阻塞。如果在同一个线程中同时向子进程写入数据并从其读取数据，可能会发生阻塞。例如，如果子进程的标准输出（STDOUT）产生大量数据，而你的程序在写入更多数据之前尝试读取这些数据，则子进程可能会被阻塞，反之亦然。
解决方案一：重定向输入输出流
最简单的解决方案是使用ProcessBuilder的redirectOutput或inheritIO方法，避免直接读取子进程的输入输出流。
redirectOutput(ProcessBuilder.Redirect.INHERIT): 将子进程的标准输出重定向到当前进程的标准输出，这样你就不需要手动读取子进程的输出。
inheritIO(): 将子进程的所有输入输出流都重定向到当前进程，这相当于同时使用了redirectInput(ProcessBuilder.Redirect.INHERIT)、redirectOutput(ProcessBuilder.Redirect.INHERIT)和redirectErrorStream(true)。
以下是使用inheritIO()的示例代码：
import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
class CommandLine {
Process Handle;
Scanner getCommand;
Socket socket;
public CommandLine(Socket socket) throws IOException {
this.socket = socket;
}
public void executeCommand() {
try {
getCommand = new Scanner(socket.getInputStream()).useDelimiter("\A");
Handle = new ProcessBuilder("cmd.exe").inheritIO().start(); // 使用 inheritIO()
PrintWriter stdin = new PrintWriter(Handle.getOutputStream()); // 在循环外部创建 PrintWriter
while (getCommand.hasNextLine()) {
stdin.write(getCommand.nextLine() + System.lineSeparator());
stdin.flush();
}
stdin.close(); // 关闭 PrintWriter
Handle.waitFor(); // 等待进程结束
} catch (IOException | InterruptedException e) {
e.printStackTrace();
}
}
}在这个例子中，我们使用inheritIO()将子进程的所有输入输出流重定向到当前进程，并确保在循环外部创建PrintWriter实例，并在完成所有写入后关闭它。 另外，使用Handle.waitFor()等待子进程完成，避免资源泄漏。
解决方案二：使用后台线程异步处理输入输出
如果需要更精细地控制子进程的输入输出，可以使用后台线程异步处理。创建一个线程专门负责读取子进程的输出，另一个线程负责向子进程写入数据。这样可以避免同步阻塞，并提高程序的响应速度。
以下是一个使用后台线程读取子进程输出的示例代码：
import java.io.*;
import java.net.Socket;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
class CommandLine {
Process Handle;
Scanner getCommand;
Socket socket;
ExecutorService executor = Executors.newFixedThreadPool(2); // 创建线程池
public CommandLine(Socket socket) throws IOException {
this.socket = socket;
}
public void executeCommand() {
try {
getCommand = new Scanner(socket.getInputStream()).useDelimiter("\A");
Handle = new ProcessBuilder("cmd.exe").redirectErrorStream(true).start();
PrintWriter stdin = new PrintWriter(Handle.getOutputStream());
// 创建线程读取子进程输出
executor.submit(() -> {
try (Scanner result = new Scanner(Handle.getInputStream()).useDelimiter("\A")) {
while (result.hasNextLine()) {
System.out.println(result.nextLine());
}
}
});
// 主线程负责写入数据
while (getCommand.hasNextLine()) {
stdin.write(getCommand.nextLine() + System.lineSeparator());
stdin.flush();
}
stdin.close();
Handle.waitFor();
executor.shutdown(); // 关闭线程池
} catch (IOException | InterruptedException e) {
e.printStackTrace();
}
}
}在这个例子中，我们使用ExecutorService创建了一个线程池，并使用一个线程负责读取子进程的输出。主线程负责向子进程写入数据。这样可以避免同步阻塞，并确保子进程能够持续运行。 使用executor.shutdown()关闭线程池，避免资源泄漏。
总结与注意事项
- 避免在循环内部关闭子进程的输入流。
- 使用redirectOutput或inheritIO简化输入输出处理。
- 使用后台线程异步处理输入输出，避免同步阻塞。
- 确保关闭所有打开的流和线程池，避免资源泄漏。
- 使用Handle.waitFor()等待子进程完成，避免僵尸进程。
通过遵循这些最佳实践，你可以确保Java程序中的子进程能够持续运行，并提高程序的稳定性和可靠性。
