将 InputStream 重用到 Java 中的进程

Question

我正在使用 ProcessBuilder 通过 Java 输入和接收来自 C++ 程序的信息。启动该过程一次后，我希望能够输入新字符串并接收它们的输出，而无需重新启动整个过程。这是我迄今为止采取的方法：

public void getData(String sentence) throws InterruptedException, IOException{
        InputStream stdout = process.getInputStream();
        InputStreamReader isr = new InputStreamReader(stdout);
        OutputStream stdin = process.getOutputStream();
        OutputStreamWriter osr = new OutputStreamWriter(stdin);
        BufferedWriter writer = new BufferedWriter(osr);
        BufferedReader reader = new BufferedReader(isr);

        writer.write(sentence);
        writer.close();

        String ch = reader.readLine();
        preprocessed="";
        while (ch!=null){
            preprocessed = preprocessed+"~"+ch;
            ch = reader.readLine();
        }

        reader.close();
}

每次我想向正在运行的进程发送输入时，我都会调用此方法。但是，有一个问题：我第一次发送输入，很好，输出接收完美。但是，第二次调用它时，我收到错误

java.io.IOException: Stream closed

这是出乎意料的，因为当再次调用该方法时，理论上所有内容都会重新创建。此外，删除关闭 BufferedWriter 的行会导致代码在下一行停止，就好像 BufferedReader 正在等待 BufferedWriter 关闭一样。

最后一件事 - 即使我创建了一个 NEW BufferedWriter 并指示该方法在第二次调用时使用它，我也得到了同样的异常，我完全不明白。

有什么办法可以解决吗？

非常感谢！

Answer 1

发生意外的 IOException 是因为当 Readers 和 Writers 关闭时，它们会依次关闭其底层流。

当您第一次调用您的方法时，似乎一切正常。但是你关闭了 writer，它关闭了进程输出流，从进程的角度来看，它关闭了 stdin。不确定您的 C++ 二进制文件是什么样的，但可能在完成所有输入后它会愉快地退出。

因此对您的方法的后续调用不起作用。

在 Reader 端有一个单独但类似的问题。您调用 readLine() 直到它返回 null，这意味着 Reader 已经感觉到流的结束。但这只发生在进程完全使用其标准输出完成时。

您需要某种方式来确定您何时处理完一个工作单元（无论您所说的“句子”是什么意思），而无需等待整个流结束。流没有输出之间的逻辑暂停的概念。这只是一个连续的流。 Reader 和 Writer 只是在字节和字符之间缓冲的薄薄的一层，但基本上与流相同。

也许输出可能有分隔符。或者您可以在实际发送输出之前发送每个输出块的长度并以这种方式区分输出。或者您可能提前知道每次回复需要多长时间？

您只能通过流获得一枪。所以他们将不得不比这种方法活得更久。如果您想避免每次都重新启动进程，则不能打开和关闭流。 （进程还有其他通信方式，例如套接字，但这可能超出了范围。）

在正交说明中，在累积输出时，附加到 StringBuilder 通常比字符串连接的大循环更有效。

您可能还需要一些线程检查 process.exitValue() 或以其他方式确保进程按预期工作。

Answer 2

不要一直尝试创建和关闭您的信息流，因为一旦您关闭它，它就会永久关闭。创建一次，然后在您的 getData(...) 方法中使用现有的 Streams。仅在完全使用完 Streams 或它们的包装类后才关闭它们。

请注意，您应该以相同的方法打开和关闭 Stream，因此可能需要其他方法或类来帮助您处理 Stream。考虑为此创建一个 Runnable 类，然后从另一个线程中的流中读取。也不要忽略错误流，因为这可能会发送您需要完全了解这里发生的事情的关键信息。