在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关闭一样。

最后一件事——即使我创建了一个新的BufferedWriter，并指示该方法在第二次调用时使用它，我也会得到同样的异常，这一点我完全不理解。

有没有办法解决这个问题？

非常感谢！

Answer 1

不要一直试图创建和关闭你的流，因为一旦你关闭它，它就会永远关闭。创建一次，然后在getData（…） 方法使用现有的流。只有当你完全处理完你的流或它们的包装类后，才能关闭它们。

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

Answer 2

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

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

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

在Reader方面有一个单独但类似的问题。您调用readLine（），直到它返回null，这意味着Reader已经感觉到流的结束。但是只有当过程完全完成其标准输出时，这种情况才会发生。

当你处理完一个工作单元（不管你所说的“句子”是什么意思）时，你需要某种方式来识别，而不需要等待整个流结束。流没有输出之间逻辑暂停的概念。它只是一个连续的流。Reader和Writer只是一个薄薄的表皮，用来缓冲字节和字符，但基本上与流一样工作。

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

你只有一次机会穿过溪流。因此，它们必须比这种方法更有效。如果想避免每次都重新启动流程，就不能打开和关闭流。（进程还有其他通信方式，例如套接字，但这可能超出了范围。）

在一个正交的注释中，当您累积输出时，附加到StringBuilder通常比字符串串联的大循环更有效。

您可能还有一些线程检查过程。exitValue（）或以其他方式确保流程按预期工作。