带输入/输出流的Java进程

Question

我在下面有以下代码示例.因此,您可以向bash shell输入命令,即将echo test结果回显.但是,在第一次阅读之后.其他输出流不起作用？

为什么这样或者我做错了什么？我的最终目标是创建一个线程调度任务来定期执行的命令/ bash的,因此OutputStream,并InputStream会在协同工作并没有停止工作.我也遇到过java.io.IOException: Broken pipe任何想法的错误？

谢谢.

String line;
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);
}

Answer 1

首先,我建议更换线路

Process process = Runtime.getRuntime ().exec ("/bin/bash");

用线条

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

ProcessBuilder是Java 5中的新增功能,可以更轻松地运行外部进程.在我看来,它最显着的改进Runtime.getRuntime().exec()是它允许您将子进程的标准错误重定向到其标准输出.这意味着你只有一个InputStream可以阅读.在此之前,您需要有两个单独的线程,一个读取stdout和一个读取stderr,以避免标准错误缓冲区填充,而标准输出缓冲区为空(导致子进程挂起),反之亦然.

接下来,循环(你有两个)

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

只有当reader从进程的标准输出读取时才返回文件结尾.这仅在bash进程退出时发生.如果目前没有更多来自进程的输出,它将不会返回文件结尾.相反,它将等待进程的下一行输出,直到它有下一行才返回.

由于您在到达此循环之前向进程发送了两行输入,因此如果在这两行输入之后进程尚未退出,则这两个循环中的第一个将挂起.它将坐在那里等待另一行被读取,但它永远不会有另一行读它.

我编译了你的源代码(我现在在Windows上,所以我替换/bin/bash了cmd.exe,但原则应该是相同的),我发现:

• 键入两行后,出现前两个命令的输出,但程序挂起,
• 如果我输入,比方说,echo test然后exit,程序会从cmd.exe进程退出后的第一个循环中取出.程序然后要求输入另一行(被忽略),直接跳过第二个循环,因为子进程已经退出,然后退出.
• 如果我输入exit然后echo test,我得到一个IOException抱怨管道被关闭.这是预期的 - 第一行输入导致进程退出,并且无处发送第二行.

在我曾经做过的一个程序中,我看到了一个类似于你想要的东西的技巧.该程序保留了许多shell,在其中运行命令并从这些命令中读取输出.使用的技巧是始终写出一条标记shell命令输出结束的"魔术"行,并使用它来确定发送到shell的命令输出何时完成.

我拿了你的代码,然后writer用以下循环替换了分配给它的行之后的所有内容:

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();
    }
    if (line == null) {
        break;
    }
}

执行此操作后,我可以可靠地运行一些命令并让每个命令的输出单独返回给我.

echo --EOF--发送到shell的行中的两个命令用于确保命令的输出--EOF--即使在命令错误的结果中也终止.

当然,这种方法有其局限性.这些限制包括:

• 如果我输入等待用户输入的命令(例如另一个shell),程序似乎挂起,
• 它假设shell运行的每个进程都以换行符结束其输出,
• 如果shell运行的命令恰好写出一行,它会有点混乱--EOF--.
• bash报告语法错误,如果输入一些不匹配的文本,则退出).

如果您想要运行的任何计划任务将被限制为命令或一组永远不会以这种病态方式运行的命令,这些点对您来说可能无关紧要.

编辑:在Linux上运行此操作后,改进退出处理和其他微小更改.

Answer 2

我认为你可以使用像恶魔线程这样的线程来读取你的输入，并且你的输出阅读器将已经在主线程中的 while 循环中，这样你就可以同时读写。你可以像这样修改你的程序：

Thread T=new Thread(new Runnable() {

    @Override
    public void run() {
        while(true)
        {
            String input = scan.nextLine();
            input += "\n";
            try {
                writer.write(input);
                writer.flush();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

        }

    }
} );
T.start();

你可以阅读器将与上面相同，即

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

让你的作者成为最终的，否则它将无法被内部类访问。