Java ProcessBuilder如何复用子进程避免重复创建JVM实例

核心思路是把子进程从「启动-接参-执行-退出」的单次运行模式，改成「首次启动初始化-常驻循环接任务-处理-返回结果」的长驻模式，完全避免重复创建JVM、重复加载classpath依赖的开销，有三种成熟实现路径可选：

方案1：基于标准IO流通信（改造成本最低，推荐优先用） #

这个方案不需要引入额外依赖，只需要改造父子进程的交互逻辑即可：

• 改造子进程入口逻辑：删除原来读取命令行参数、执行完即退出的逻辑，启动后先完成所有依赖加载、上下文初始化动作，之后进入无限循环，持续从System.in读取父进程传入的任务输入，完成业务处理后将结果写入System.out，单条任务处理完必须主动调用flush()刷新输出流，避免缓冲区驻留导致父进程读不到结果。
• 父进程侧仅在首次请求时通过ProcessBuilder.start()启动一次子进程，长期持有该Process对象的引用，后续所有任务都不需要重新创建进程：直接通过子进程的输出流（父进程视角的process.getOutputStream()）写入任务参数，通过子进程的输入流（父进程视角的process.getInputStream()）读取处理结果即可。
• 必须注意几个坑：
  • 要自定义简单的消息边界规则解决流的粘包问题：比如约定每条消息前固定4字节存储消息长度，或者用业务内容中不会出现的特殊标记（如|||MSG_END|||）作为单条消息的结束标识，不要直接按行读（如果输入内容本身带换行就会解析错误）。
  • 一定要单独启动守护线程消费子进程的标准错误流（process.getErrorStream()），否则错误流缓冲区写满后会直接阻塞子进程的所有运行，这是Java Process类的经典坑。
  • 子进程内的业务异常不要直接打印到标准输出流，会干扰正常结果解析，可以把异常封装为结构化的错误结果返回，或者只输出到标准错误流。
  • 子进程启动完成后可以先往标准输出打印一个固定的READY标识，父进程读到这个标识后再发送第一个任务，避免初始化阶段发的请求丢失。

方案2：基于本地Socket通信（稳定性更高，适合高并发场景） #

如果任务调用频次很高、或者需要支持多任务并行处理，可以选这个方案：

• 子进程启动完成后，绑定本地环回地址的一个随机空闲TCP端口，把端口号通过标准输出打印给父进程，之后启动监听循环接收端口上的请求，处理完后返回结果。
• 父进程首次启动子进程后读取到端口号，后续所有任务直接通过本地TCP连接发送请求、接收结果即可，不需要持续占用标准流。
• 这个方案的优势是通信稳定性比标准IO更好，不需要手动处理流的边界问题（可以直接用TCP的长短连接机制），还能很方便地做健康检查：如果端口连不通就说明子进程异常退出，直接重新拉起即可，容错性更强。如果需要并行处理，子进程内部直接开线程池处理端口收到的请求就行。

方案3：基于轻量本地RPC（开发成本最低，适合不想手写通信逻辑的场景） #

如果不想自己写流处理、协议解析、边界拆分的逻辑，可以直接用轻量RPC框架封装本地调用：

• 把你的输入输出处理逻辑封装成一个本地服务接口，子进程启动后自动在本地环回地址暴露这个RPC服务。
• 父进程侧直接注入这个RPC服务的客户端，后续调用和调用本地方法没有区别，框架会自动完成底层的通信、序列化、异常处理，不需要自己写底层交互逻辑。

最小实现示例（标准IO模式） #

子进程侧核心代码：

import java.io.*;
import java.nio.charset.StandardCharsets;

public class ResidentWorker {
    public static void main(String[] args) throws IOException {
        BufferedReader inReader = new BufferedReader(
                new InputStreamReader(System.in, StandardCharsets.UTF_8)
        );
        BufferedWriter outWriter = new BufferedWriter(
                new OutputStreamWriter(System.out, StandardCharsets.UTF_8)
        );

        // 这里提前完成所有初始化动作：加载依赖、初始化连接、加载模型等
        // initYourBusinessContext();

        // 通知父进程初始化完成，可以发任务了
        outWriter.write("READY\n");
        outWriter.flush();

        String inputLine;
        while ((inputLine = inReader.readLine()) != null) {
            if ("__EXIT__".equals(inputLine)) {
                // 收到退出指令，正常结束进程
                break;
            }
            String result;
            try {
                // 替换成你的实际业务处理逻辑
                result = processBusiness(inputLine);
            } catch (Exception e) {
                result = "ERROR:" + e.getMessage();
            }
            outWriter.write(result + "\n");
            outWriter.flush();
        }
    }

    private static String processBusiness(String input) {
        return "PROCESS_RESULT:" + input;
    }
}

父进程侧只需要在初始化时启动一次子进程，后续复用该Process对象即可，不需要重复调用start()。如果对吞吐量要求更高，还可以提前启动多个常驻子进程组成简单的进程池，给不同任务分配空闲进程处理，进一步降低单进程的排队延迟。

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