Java 输出流到子进程刷新导致 IOException

Question

我有一个子进程从 stdin 逐行接收数据。然后它收到 $X$ 行，停止读取输入流，对其执行内部任务，然后退出。现在我为它编写了一些测试器:

public class MessageShowTester {

    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) throws IOException {
        Process p = Runtime.getRuntime().exec("java -jar \"/home/user/NetBeansProjects/MessageShow/dist/MessageShow.jar\"");
        p.getOutputStream().write("Hi\n$X$\n".getBytes());
        p.getOutputStream().flush();

    }

}

结果我在 p.getOutputStream().flush() 行收到 IOException 。更奇怪的是，我使用相同结构的另一个应用程序不具有这种行为。

有一个 MessageShow 的有限版本作为示例，在测试器上以同样的方式失败，但在 IDE 上运行良好。

public class MessageShow {

    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        String message="";
        String temp="";

        while(true)
        {
            temp = new Scanner(System.in).nextLine();


            if("$X$".equals(temp)) break;


                message+=temp;
                message+="\n";


        }


        JOptionPane.showMessageDialog(null, message);
    }

}

堆栈跟踪:

Exception in thread "main" java.io.IOException: Broken pipe
    at java.io.FileOutputStream.writeBytes(Native Method)
    at java.io.FileOutputStream.write(FileOutputStream.java:315)
    at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:82)
    at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:140)
    at messageshowtester.MessageShowTester.main(MessageShowTester.java:23)
Java Result: 1

Answer 1

如果子进程很快完成，父进程可能还没有完成刷新。在这种情况下，进程之间的管道已经在子进程端关闭，您将看到

 Exception in thread "main" java.io.IOException: Stream closed

或类似的。

您不应该需要显式刷新。要将单行传递给子流程，请考虑流程参数。

对什么有效、什么无效不太有信心，但我发现使用

    PrintWriter pw = new PrintWriter( p.getOutputStream() );
    pw.println("hifile.dat");
    pw.println("$X$");
    pw.close();

成功地将两行传递给子进程。

在子流程中，

 Scanner scanner = new Scanner(System.in);
 while(true){
    temp = scanner.nextLine();
    if("$X$".equals(temp)) break;
    message+=temp;
}

比为每行重新创建扫描仪更好，尽管它不会影响子进程的命运。