本文将介绍如何在Java中创建一个能够持续运行的进程，并解决子进程在循环中意外终止的问题。通过修改代码结构，避免在循环中关闭子进程的输入流，并利用重定向或后台线程处理输入输出，确保进程的稳定运行。本文提供详细的代码示例和解决方案，帮助读者理解并实现这一目标。
在Java中创建一个能够持续运行的进程，尤其是在需要与外部命令交互的场景下，需要特别注意进程的生命周期管理和输入输出处理。以下是一些关键点和示例代码，帮助你实现这一目标。
问题分析
原始代码的问题在于，在while循环内部使用了try-with-resources语句创建PrintWriter stdin。 每次循环迭代结束时，try块会自动关闭stdin，这会导致子进程（例如cmd.exe）的输入流关闭，从而导致子进程终止。
立即学习“Java免费学习笔记（深入）”；
解决方案
为了解决这个问题，需要将PrintWriter stdin的创建移到循环外部，避免在每次迭代时都关闭输入流。此外，需要注意标准输入（STDIN）和标准输出（STDOUT）的同步问题，避免阻塞。
以下提供两种解决方案：使用重定向和使用后台线程。
方案一：使用重定向
利用ProcessBuilder的redirectOutput或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");
ProcessBuilder builder = new ProcessBuilder("cmd.exe");
// 关键：将输出重定向到父进程
builder.redirectOutput(ProcessBuilder.Redirect.INHERIT);
builder.redirectErrorStream(true); // 将错误流也合并到输出流
Handle = builder.start();
try (PrintWriter stdin = new PrintWriter(Handle.getOutputStream())) { // 将PrintWriter移到循环外，确保不重复关闭
while (getCommand.hasNextLine()) {
String command = getCommand.nextLine();
stdin.println(command);
stdin.flush();
}
}
Handle.waitFor(); // 等待进程结束
} catch (IOException | InterruptedException e) {
e.printStackTrace();
}
}
}代码解释：
- builder.redirectOutput(ProcessBuilder.Redirect.INHERIT);：这行代码将子进程的标准输出重定向到父进程的标准输出，省去了手动读取输出流的步骤。redirectErrorStream(true) 将错误流合并到输出流，方便查看错误信息。
- try (PrintWriter stdin = new PrintWriter(Handle.getOutputStream()))：将PrintWriter的创建放在try-with-resources块中，确保在使用完毕后自动关闭，但将其移到循环外部，避免在每次迭代时都关闭输入流。
- 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;
private final ExecutorService executor = Executors.newCachedThreadPool();
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())) {
while (result.hasNextLine()) {
System.out.println(result.nextLine());
}
}
});
while (getCommand.hasNextLine()) {
String command = getCommand.nextLine();
stdin.println(command);
stdin.flush();
}
stdin.close(); // 关闭输入流，通知子进程输入结束
Handle.waitFor();
executor.shutdown();
} catch (IOException | InterruptedException e) {
e.printStackTrace();
}
}
}代码解释：
- ExecutorService executor = Executors.newCachedThreadPool();：创建一个线程池来执行后台任务。
- executor.submit(() -> { ... });：提交一个任务到线程池，该任务负责读取子进程的输出流，并将结果打印到控制台。
- stdin.close();：在循环结束后，需要显式关闭输入流，通知子进程输入结束。
- Handle.waitFor();：等待子进程执行完毕。
- executor.shutdown();：关闭线程池。
注意事项
- 资源管理： 确保在使用完毕后关闭所有输入输出流，避免资源泄露。
- 异常处理： 完善异常处理机制，捕获并处理可能出现的IOException和InterruptedException。
- 线程安全： 如果多个线程同时访问同一个Process对象，需要注意线程安全问题。
- 命令注入： 务必对接收到的命令进行安全检查，防止命令注入攻击。
- 进程退出： 需要考虑如何优雅地停止持续运行的进程，例如通过发送特定的命令或信号。
总结
通过合理地管理子进程的输入输出流，并使用重定向或后台线程处理输出，可以有效地解决子进程意外终止的问题，从而创建一个持续运行的Java进程。根据实际需求选择合适的方案，并注意资源管理和异常处理，确保程序的稳定性和安全性。
