首页 >Java >java教程 >如何正确处理Java进程中的输入/输出流以避免阻塞?

如何正确处理Java进程中的输入/输出流以避免阻塞?

Mary-Kate Olsen
Mary-Kate Olsen原创
2024-12-17 18:00:16690浏览

How to Properly Handle Input/Output Streams in Java Processes to Avoid Blocking?

具有输入/输出流的 Java 进程

考虑以下代码片段:

Scanner scan = new Scanner(System.in);

Process process = Runtime.getRuntime().exec("/bin/bash");
OutputStream stdin = process.getOutputStream();
InputStream stderr = process.getErrorStream();
InputStream stdout = process.getInputStream();

BufferedReader reader = new BufferedReader(new InputStreamReader(stdout));
BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(stdin));

String input = scan.nextLine();
input += "\n";
writer.write(input);
writer.flush();

input = scan.nextLine();
input += "\n";
writer.write(input);
writer.flush();

while ((line = reader.readLine()) != null) {
    System.out.println("Stdout: " + line);
}

input = scan.nextLine();
input += "\n";
writer.write(input);
writer.close();

while ((line = reader.readLine()) != null) {
    System.out.println("Stdout: " + line);
}

此代码允许您在 bash shell 中输入命令并接收其输出。然而,在初始输入和输出之后,后续的输入不会产生预期的输出。

为什么会出现这种情况

出现这个问题是因为代码没有正确处理bash 进程的标准输出的文件结束 (EOF) 条件。循环 while ((line = reader.readLine()) != null) 仅当进程退出时才会退出,这意味着如果进程没有进一步的输出,循环将无限期阻塞。

建议的解决方案 - ProcessBuilder 和 --EOF-- 处理

要解决此问题,请考虑以下内容修改:

ProcessBuilder builder = new ProcessBuilder("/bin/bash");
builder.redirectErrorStream(true);
Process process = builder.start();

通过使用 ProcessBuilder 而不是 Runtime.getRuntime().exec(),您可以将 bash 进程的标准错误重定向到其标准输出,确保您只需要一个输入流。

此外,可以修改代码以发送特殊分隔符 --EOF--,以表示命令输出的结束。这允许代码可靠地将输出与多个命令分开。

while (scan.hasNext()) {
    String input = scan.nextLine();
    if (input.trim().equals("exit")) {
        // Putting 'exit' amongst the echo --EOF--s below doesn't work.
        writer.write("exit\n");
    } else {
        writer.write("((" + input + ") & echo --EOF-- || echo --EOF--)\n");
    }
    writer.flush();

    line = reader.readLine();
    while (line != null && !line.trim().equals("--EOF--")) {
        System.out.println("Stdout: " + line);
        line = reader.readLine();
    }
}

通过这些更改,代码将可靠地处理多个命令及其输出,提供所需的功能。

以上是如何正确处理Java进程中的输入/输出流以避免阻塞?的详细内容。更多信息请关注PHP中文网其他相关文章!

声明:
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn