Java 多進程架構實戰：ProcessBuilder 與 Runtime.exec 完整指南

前言：為什麼 Java 需要多進程？

JVM 單進程模型簡單高效，但特定場景下進程隔離是剛需：

• 故障隔離：插件/腳本/第三方庫崩潰不拖垮主服務 (OOM、Native Crash、死鎖)。
• 資源限制：單獨限制子進程 CPU/記憶體 (cgroups/ulimit)，防止佔盡資源。
• 環境隔離：不同 JDK 版本、類路徑、系統屬性、原生庫路徑共存。
• 權限分離：子進程以低權限用戶運行 (沙箱)。
• 技術棧互操作：調用 Python/R/Go/C++ 程式、CLI 工具 (ffmpeg, pdftk, imagemagick)。

一、 兩種啟動方式對比

二、 ProcessBuilder 核心用法全景

1. 基礎啟動與參數傳遞 (安全首選)

ProcessBuilder pb = new ProcessBuilder(
    "java", "-Xmx512m", "-cp", "/app/plugins/*", "com.plugin.Main", "arg1", "arg2"
);
// 等同 pb.command(List.of("java", "-Xmx512m", ...))
Process process = pb.start(); // 異步啟動，立即返回

關鍵：參數列表化，避免字串拼接導致空格/引號/注入問題。

2. 環境變數與工作目錄隔離

Map<String, String> env = pb.environment();
env.put("PLUGIN_HOME", "/opt/plugin");
env.put("JAVA_OPTS", "-Dconfig.file=/etc/plugin.conf");
env.remove("CLASSPATH"); // 清理干擾變數

pb.directory(new File("/var/lib/plugin/work")); // 隔離工作目錄
// 子進程相對路徑、臨時文件均在這裡

3. I/O 重導向：告別手動 Stream 複制

// 1. 直通文件 (最高效，無 Java 堆記憶體拷貝)
pb.redirectOutput(ProcessBuilder.Redirect.appendTo(new File("/var/log/plugin.out")));
pb.redirectError(ProcessBuilder.Redirect.to(new File("/var/log/plugin.err")));

// 2. 繼承父進程控制台 (調試用)
pb.redirectOutput(ProcessBuilder.Redirect.INHERIT);
pb.redirectError(ProcessBuilder.Redirect.INHERIT);

// 3. 管道流 (需 Java 代碼處理輸出)
Process process = pb.start();
// 非阻塞讀取輸出 (Java 8+ try-with-resources)
try (BufferedReader reader = new BufferedReader(
        new InputStreamReader(process.getInputStream(), StandardCharsets.UTF_8))) {
    String line;
    while ((line = reader.readLine()) != null) {
        log.info("[Plugin] {}", line);
    }
}

4. 向子進程寫入輸入 (stdin)

Process process = pb.start();
try (OutputStream stdin = process.getOutputStream();
     BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(stdin, StandardCharsets.UTF_8))) {
    writer.write("input data line 1\n");
    writer.write("input data line 2\n");
    writer.flush(); // 必須 flush，否則子進程 read() 阻塞
} // try-with-resources 自動 close()，發送 EOF，子進程 read() 返回 -1

5. 進程管道鏈 (Java 9+ ProcessBuilder.startPipeline())

// 等同 shell: cat file.txt | grep "error" | wc -l
List<ProcessBuilder> builders = List.of(
    new ProcessBuilder("cat", "file.txt"),
    new ProcessBuilder("grep", "error"),
    new ProcessBuilder("wc", "-l")
);
List<Process> processes = ProcessBuilder.startPipeline(builders);
// 最後一個進程的輸出即為管道結果
try (BufferedReader r = new BufferedReader(new InputStreamReader(processes.get(2).getInputStream()))) {
    System.out.println("Error lines: " + r.readLine());
}

三、 進程生命週期管理與同步

1. 等待結束與獲取退出碼

// 阻塞等待
int exitCode = process.waitFor(); // 0 成功，非 0 失敗

// 超時等待 (Java 8+)
boolean finished = process.waitFor(30, TimeUnit.SECONDS);
if (!finished) {
    process.destroyForcibly(); // 強殺
    throw new TimeoutException("Plugin execution timeout");
}

2. 非阻塞監控 (CompletableFuture / Java 9+ onExit())

// Java 9+ 原生 CompletableFuture
CompletableFuture<Process> future = process.onExit();
future.thenAccept(proc -> {
    int code = proc.exitValue();
    log.info("Plugin exited with code: {}", code);
    // 觸發後續邏輯：清理臨時文件、回調、發送事件
}).exceptionally(ex -> {
    log.error("Plugin process error", ex);
    return null;
});

3. 子進程存活監控 (心跳/看門狗)

// 定時任務檢查
ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
scheduler.scheduleAtFixedRate(() -> {
    if (process.isAlive()) {
        // 可選：發送心跳信號、檢查資源佔用
    } else {
        scheduler.shutdown();
        handleUnexpectedExit(process.exitValue());
    }
}, 10, 10, TimeUnit.SECONDS);

四、 生產環境硬化清單

五、 進階場景：插件沙箱 / 多版本共存

public class PluginProcessManager {
    private final Map<String, Process> runningPlugins = new ConcurrentHashMap<>();
    
    public Process startPlugin(PluginDescriptor desc) throws IOException {
        ProcessBuilder pb = new ProcessBuilder()
            .command(buildJavaCommand(desc)) // 不同 JDK 路徑、類路徑、模組
            .directory(desc.getWorkDir())
            .environment(desc.getEnv())
            .redirectOutput(Redirect.appendTo(desc.getLogFile()))
            .redirectError(Redirect.appendTo(desc.getLogFile()));
        
        Process process = pb.start();
        runningPlugins.put(desc.getId(), process);
        
        // 非阻塞監控
        process.onExit().thenRun(() -> runningPlugins.remove(desc.getId()));
        return process;
    }
    
    private List<String> buildJavaCommand(PluginDescriptor desc) {
        return List.of(
            desc.getJdkPath() + "/bin/java",
            "-Xmx" + desc.getMaxHeapMb() + "m",
            "--add-modules", "java.xml,jdk.unsupported", // 模組化隔離
            "-cp", desc.getClasspath(),
            desc.getMainClass()
        );
    }
}

總結：ProcessBuilder 是 Java 多進程的瑞士軍刀。參數列表化、I/O 重導向文件化、環境隔離、非阻塞監控、超時強殺 六大紀律落地，即可構建穩健的插件沙箱、異構系統集成、離線任務編排系統。