如何使用 Java ProcessBuilder 自动化命令行脚本

How do I automate a command line script with Java ProcessBuilder

我是 java 的新手,正在尝试使用 java 自动化命令行。我试图在这里搜索解决方案,但找不到。

我创建了一个简单的测试 shell 脚本,如下所示,用于测试我的程序:


#!/bin/bash
echo "What is your name?";
read name;
echo "Hello, $name"
echo "What is your contact number?";
read num;
echo "Saved contact number $num for $name"

Java代码如下:

import java.io.*;
import java.util.*;

public class CmdLineMain {
    public static void main(String args[]) throws InterruptedException, IOException {
        List<String> command = new ArrayList<String>();
        command.add("./test.sh");

        ProcessBuilder builder = new ProcessBuilder(command);

        final Process process = builder.start();
        InputStream is = process.getInputStream();
        InputStreamReader isr = new InputStreamReader(is);
        BufferedReader br = new BufferedReader(isr);
        String line = "";
        BufferedWriter bw = null;

        while (process.isAlive()) {
            line = br.readLine();
            // since stream may be closed earlier, re-open it
            bw = new BufferedWriter(new OutputStreamWriter(process.getOutputStream()));
            System.out.println(line);

            if (line != null) {
                switch (line) {
                case "What is your name?":
                    bw.write("John Doe");
                    bw.close();
                    break;
                case "What is your contact number?":
                    bw.write("123456789");
                    bw.close();
                    break;

                }
            }

        }

        System.out.println("Program terminated!");
    }
}

问题:进程的第二个输入失败并出现错误:


    What is your name?
    Hello, John Doe
    What is your contact number?
    Exception in thread "main" java.io.IOException: Stream Closed
        at java.io.FileOutputStream.writeBytes(Native Method)
        at java.io.FileOutputStream.write(FileOutputStream.java:326)
        at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:82)
        at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:140)
        at java.io.FilterOutputStream.close(FilterOutputStream.java:158)
        at sun.nio.cs.StreamEncoder.implClose(StreamEncoder.java:320)
        at sun.nio.cs.StreamEncoder.close(StreamEncoder.java:149)
        at java.io.OutputStreamWriter.close(OutputStreamWriter.java:233)
        at java.io.BufferedWriter.close(BufferedWriter.java:266)
        at nkh.app.CmdLineMain.main(CmdLineMain.java:34)

关闭 BufferedWriter 将关闭其基础流,这包括您通过 process.getOutputStream() 获得的进程 OutputStream。因此,一旦它在一个循环中关闭,在下一个循环中,您的 BufferedWriter 将包装一个关闭的流。而是只包装输出流一次并重复使用它。

像这样:

BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(process.getOutputStream()));
// while the stream is open and there is something to read
// probably a better condition than `process.isAlive()`
while ((line = br.readLine()) != null) {
    switch (line) {
        case "What is your name?":
            bw.write("John Doe");
            bw.newLine();
            bw.flush();
            break;
        case "What is your contact number?":
            bw.write("123456789");
            bw.newLine();
            bw.flush();
            break;
    }
}

当你的新 BufferedWriter 包装封闭的底层流时,你的原始代码死于 close() 而不是死于它之前的 write() 的原因是 BufferedOutputStream.write() 可能还没有真正写入底层流,因为它被缓冲了。调用 flush() 应该告诉流实际写入,正如您在堆栈跟踪中看到的那样 close() 调用 flush() 最终将缓冲字节写入底层 FileOutputStream,然后意识到 FileOutputStream 已经关闭。