Java中ProcessBuilder启动进程后保持存活并复用的技术求助

你遇到的核心问题很明确：第一次循环里调用了pw.close()，这会直接关闭Process的标准输入流（对目标进程来说是它的标准输入）。绝大多数命令行程序在标准输入被关闭后会自动退出，所以后续循环时p.isAlive()自然返回false。另外，你读取输出的逻辑也有问题——当进程还存活时，br.readLine()会一直阻塞直到有输出，但进程没退出的话它永远不会返回null，这会导致你的代码卡死在读取步骤。

下面是修复后的完整代码，以及关键注意事项：

修复后的代码示例 #

ProcessBuilder pb = new ProcessBuilder(command);
// 可选：设置进程工作目录或环境变量，根据你的需求调整
// pb.directory(new File("/your/working/dir"));
Process p = pb.start();

// 核心：整个复用周期内保持输入流打开，不要随便关闭
PrintWriter pw = new PrintWriter(p.getOutputStream(), true); // 开启自动flush，避免手动遗漏
BufferedReader br = new BufferedReader(new InputStreamReader(p.getInputStream()));
// 必须处理错误输出：单独开线程读取，防止进程因错误输出缓冲区满而阻塞
BufferedReader errBr = new BufferedReader(new InputStreamReader(p.getErrorStream()));

// 启动后台线程读取错误输出
new Thread(() -> {
    String errLine;
    try {
        while ((errLine = errBr.readLine()) != null) {
            System.err.println("Process error log: " + errLine);
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
}).start();

ServerSocket server = new ServerSocket(8765);

while(true){
    System.out.println("Process is alive: " + p.isAlive());
    // 额外检查：如果进程意外退出，可以在这里重启或抛出告警
    if (!p.isAlive()) {
        throw new IllegalStateException("Target process exited unexpectedly!");
    }

    Socket sock = server.accept();
    DataInputStream dis = new DataInputStream(sock.getInputStream());
    String arg = dis.readUTF();
    System.out.println("Received argument: " + arg);

    // 向进程发送参数
    pw.println(arg);
    // 如果你没开启自动flush，这里要手动调用pw.flush();

    // 读取进程输出：必须和目标进程约定结束标记（比如"END_OF_CMD"）
    // 因为进程持续运行，输入流不会主动关闭，不能读到null
    StringBuilder result = new StringBuilder();
    String outputLine;
    while ((outputLine = br.readLine()) != null) {
        if ("END_OF_CMD".equals(outputLine)) { // 假设进程输出这个标记表示单次命令执行完成
            break;
        }
        result.append(outputLine).append(System.lineSeparator());
    }

    // 返回结果给客户端
    DataOutputStream dout = new DataOutputStream(sock.getOutputStream());
    dout.writeUTF(result.toString());
    dout.flush();

    // 关闭客户端相关资源，不要影响进程的输入输出流
    dis.close();
    dout.close();
    sock.close();
}

// 当你彻底不需要进程时，再关闭所有资源
// pw.close();
// br.close();
// errBr.close();
// p.destroy();

关键注意事项 #

1. 绝不随意关闭Process的输入输出流：只要你需要复用进程，就必须保持p.getOutputStream()、p.getInputStream()、p.getErrorStream全程打开，关闭任何一个都可能导致进程直接退出。
2. 必须处理错误输出：如果目标进程有错误输出，一定要单独开线程读取。否则错误输出缓冲区满了会导致进程阻塞，无法继续处理新的输入。
3. 和进程约定输出结束标记：因为进程持续运行，输入流不会主动关闭，你的代码无法通过br.readLine() == null判断单次命令的输出是否完成。必须和目标进程约定一个特殊标记（比如END_OF_CMD），让进程在每次命令执行完成后输出这个标记，你的代码读到标记就停止读取。
4. 确认目标进程支持交互式运行：如果你的command是单次执行的程序（比如echo、ls），它执行完就会退出，根本没法复用。你需要确保启动的是支持持续接收输入并返回输出的程序，比如Python交互式解释器（记得加-u参数关闭输出缓冲）、Node.js REPL，或者你自己编写的服务端程序。

内容的提问来源于stack exchange，提问作者user_3093890