本文将介绍如何在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进程。根据实际需求选择合适的方案，并注意资源管理和异常处理，确保程序的稳定性和安全性。
© 版权声明
文章版权归作者所有，未经允许请勿转载。
THE END
