Java Process调用底层进程时如何获取InputStream？无法读取子进程输出

核心问题 #

你遇到的情况本质是交互式程序（MySQL shell）的输出缓冲机制导致的：

• MySQL shell作为交互式终端程序，默认采用行缓冲或全缓冲策略，不会将命令执行结果立即flush到标准输出，直到遇到特定触发条件（比如退出shell、出现交互提示符）。
• 你使用的input.ready()方法仅在流中有可立即读取的数据时返回true，MySQL未flush输出时该方法直接返回false，导致读取循环直接跳过，根本没尝试读取数据。

可行解决方案 #

方案1：直接执行单条MySQL命令（推荐REST场景） #

不要进入交互式MySQL shell，而是通过mysql命令的-e参数直接执行SQL语句。这种方式下Process执行完毕后会直接输出结果，无需维持会话，完全适配REST应用的无状态需求。

示例代码：

public static void main(String[] args) throws IOException, InterruptedException {
    // 直接执行MySQL命令，无需进入交互式shell
    ProcessBuilder processBuilder = new ProcessBuilder("mysql", "-u", "root", "-e", "select * from some_table limit 1;");
    processBuilder.redirectErrorStream(true);
    Process process = processBuilder.start();

    BufferedReader input = new BufferedReader(new InputStreamReader(process.getInputStream()));
    String line;
    // 阻塞读取所有输出，直到进程结束
    while ((line = input.readLine()) != null) {
        System.out.println(line);
    }
    // 等待进程结束并获取退出码
    int exitCode = process.waitFor();
    System.out.println("进程退出码: " + exitCode);
}

方案2：用独立线程持续读取输入流 #

如果必须维持交互式MySQL会话（比如需要连续执行多条命令），要启动独立线程持续读取输入流，而非依赖input.ready()的判断。线程会阻塞在readLine()方法上，一旦有输出就会立即读取。

示例代码：

public static void main(String[] args) throws IOException, InterruptedException {
    ProcessBuilder processBuilder = new ProcessBuilder("/bin/bash");
    processBuilder.redirectErrorStream(true);
    Process process = processBuilder.start();

    BufferedReader input = new BufferedReader(new InputStreamReader(process.getInputStream()));
    BufferedWriter output = new BufferedWriter(new OutputStreamWriter(process.getOutputStream()));

    // 启动线程持续读取输出
    new Thread(() -> {
        String line;
        try {
            while ((line = input.readLine()) != null) {
                System.out.println("输出: " + line);
                // 可通过判断mysql>提示符标记命令执行完成
                if (line.trim().equals("mysql>")) {
                    System.out.println("MySQL命令执行完成，等待下一条命令");
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }).start();

    // 进入MySQL shell
    output.write("mysql -u root\n");
    output.flush();
    // 短暂等待提示符出现（也可通过线程内的标记判断）
    Thread.sleep(1000);

    // 执行第一条SQL
    output.write("select * from some_table limit 1;\n");
    output.flush();
    Thread.sleep(1000);

    // 执行第二条SQL
    output.write("select * from some_table limit 1;\n");
    output.flush();
    Thread.sleep(1000);

    // 如需退出会话可取消注释
    // output.write("exit\n");
    // output.flush();
}

方案3：调整终端缓冲模式（复杂度高，不推荐） #

对于bash终端，可通过stty -icanon echo命令关闭规范模式和回显，强制输出立即flush。但这种方式需要处理大量终端交互细节，不适合REST应用场景。

关键注意事项 #

• 不要依赖input.ready()判断输出，它仅适合非阻塞场景，交互式程序用阻塞式readLine()更可靠。
• REST应用优先采用无状态的命令执行方式（方案1），避免维持长期进程会话，减少资源占用和异常风险。

内容的提问来源于stack exchange，提问作者Mykyta Hupalo