Java中创建持续运行的进程-java教程-PHP中文网

Java中创建持续运行的进程

霞舞

发布： 2025-07-11 18:28:02

原创

1008人浏览过

java中创建持续运行的进程

本文旨在解决Java程序中子进程意外退出的问题，并提供保持子进程持续运行的有效方法。通过分析常见错误原因，例如在循环内关闭子进程的输入流，以及同步读写可能导致的阻塞，本文将介绍如何正确管理子进程的输入输出流，并提供使用redirectOutput或inheritIO简化流程、以及使用后台线程异步处理输入输出的两种解决方案，确保子进程稳定运行。

在Java程序中，使用ProcessBuilder创建并管理子进程是很常见的需求。然而，如果处理不当，子进程可能会意外退出，导致程序运行不稳定。本文将深入探讨导致子进程退出的常见原因，并提供几种有效的解决方案，确保子进程能够持续运行。

问题根源：资源管理不当和同步阻塞

导致子进程退出的一个常见原因是资源管理不当，尤其是在循环中使用try-with-resources语句时。例如，以下代码片段：

立即学习“Java免费学习笔记（深入）”；

try(PrintWriter stdin = new PrintWriter(Handle.getOutputStream())) {
    stdin.write(getCommand.nextLine()+System.lineSeparator());
    stdin.flush();
}

登录后复制

这段代码在每次循环迭代时都会创建一个新的PrintWriter实例，并在try-with-resources块结束时自动关闭它。这意味着子进程的标准输入流（STDIN）在每次写入一行数据后都会被关闭，这会导致某些程序（如cmd.exe）在输入流关闭后立即退出。

另一个潜在的问题是同步读写可能导致的阻塞。如果在同一个线程中同时向子进程写入数据并从其读取数据，可能会发生阻塞。例如，如果子进程的标准输出（STDOUT）产生大量数据，而你的程序在写入更多数据之前尝试读取这些数据，则子进程可能会被阻塞，反之亦然。

解决方案一：重定向输入输出流

最简单的解决方案是使用ProcessBuilder的redirectOutput或inheritIO方法，避免直接读取子进程的输入输出流。

redirectOutput(ProcessBuilder.Redirect.INHERIT): 将子进程的标准输出重定向到当前进程的标准输出，这样你就不需要手动读取子进程的输出。
inheritIO(): 将子进程的所有输入输出流都重定向到当前进程，这相当于同时使用了redirectInput(ProcessBuilder.Redirect.INHERIT)、redirectOutput(ProcessBuilder.Redirect.INHERIT)和redirectErrorStream(true)。

以下是使用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");
            Handle = new ProcessBuilder("cmd.exe").inheritIO().start(); // 使用 inheritIO()
            PrintWriter stdin = new PrintWriter(Handle.getOutputStream()); // 在循环外部创建 PrintWriter
            while (getCommand.hasNextLine()) {
                stdin.write(getCommand.nextLine() + System.lineSeparator());
                stdin.flush();
            }
            stdin.close(); // 关闭 PrintWriter
            Handle.waitFor(); // 等待进程结束
        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        }
    }
}

登录后复制

在这个例子中，我们使用inheritIO()将子进程的所有输入输出流重定向到当前进程，并确保在循环外部创建PrintWriter实例，并在完成所有写入后关闭它。另外，使用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;
    ExecutorService executor = Executors.newFixedThreadPool(2); // 创建线程池

    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()).useDelimiter("\A")) {
                    while (result.hasNextLine()) {
                        System.out.println(result.nextLine());
                    }
                }
            });

            // 主线程负责写入数据
            while (getCommand.hasNextLine()) {
                stdin.write(getCommand.nextLine() + System.lineSeparator());
                stdin.flush();
            }
            stdin.close();
            Handle.waitFor();
            executor.shutdown(); // 关闭线程池
        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        }
    }
}

登录后复制

在这个例子中，我们使用ExecutorService创建了一个线程池，并使用一个线程负责读取子进程的输出。主线程负责向子进程写入数据。这样可以避免同步阻塞，并确保子进程能够持续运行。使用executor.shutdown()关闭线程池，避免资源泄漏。

总结与注意事项