Java 进程的输入/输出流处理：高效方法和常见问题解答

2024-03-24 10:04:10

如何在 Java 中有效处理进程的输入/输出流

概述

在 Java 中，ProcessBuilder 类允许我们启动进程并控制它们的输入、输出和错误流。通过正确处理这些流，我们可以与外部进程进行通信，并从它们那里获取信息。本文将探讨如何高效地使用这些流，并解决与写入输出流时进程未结束的问题。

读取进程的输出流

要读取进程的输出流，我们需要使用 Process.getInputStream() 方法获取输入流，然后使用 BufferedReader 类包装它，如下所示：

BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));

使用 BufferedReader，我们可以通过调用 reader.readLine() 方法逐行读取输出流中的文本。

向进程的输出流写入

类似地，要向进程的输出流写入，我们需要使用 Process.getOutputStream() 方法获取输出流，然后使用 BufferedWriter 类包装它：

BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(process.getOutputStream()));

使用 BufferedWriter，我们可以通过调用 writer.write() 和 writer.flush() 方法向输出流写入文本。

解决写入输出流失败的问题

如果你遇到写入输出流后进程未结束执行的问题，这可能是由于写入流未正确关闭造成的。要解决此问题，请确保在完成写入操作后关闭写入流和读取流：

writer.close();
reader.close();

完整示例

以下是一个完整示例，展示了如何在 Java 中处理进程的输入/输出流：

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.util.concurrent.TimeUnit;

public class ProcessStreamDemo {

    public static void main(String[] args) throws IOException, InterruptedException {
        // 启动进程
        String command = "/path/to/command";
        ProcessBuilder processBuilder = new ProcessBuilder(command);
        Process process = processBuilder.start();

        // 读取进程输出
        BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));
        String line;
        while ((line = reader.readLine()) != null) {
            System.out.println(line);
        }

        // 向进程输出写入
        BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(process.getOutputStream()));
        writer.write("Hello from Java");
        writer.flush();

        // 关闭流并等待进程结束
        writer.close();
        reader.close();
        int exitCode = process.waitFor();

        System.out.println("Process exited with code " + exitCode);
    }
}

交互式 Javascript 输入

在 Javascript 中，你可以使用 readline 模块创建交互式界面，从用户那里读取输入：

const readline = require('readline');

const rl = readline.createInterface({
  input: process.stdin,
  output: process.stdout
});

rl.question('What is your name? ', (name) => {
  console.log(`Hello, ${name}!`);
  rl.close();
});