Java实现MySQL控制台交互式REPL会话的技术求助

我来帮你解决这个问题！你遇到的核心问题是没有正确处理外部进程的输入输出流，以及错误地提前关闭了输入流。下面是完整的解决方案和详细解释：

问题根源分析 #

你之前的代码存在两个核心问题：

1. 过早关闭输入流：每次循环调用writer.close()会直接关闭MySQL进程的标准输入，导致进程终止，自然只能运行一次命令。
2. 未处理输出流阻塞：如果不读取MySQL进程的标准输出/错误流，当缓冲区被填满时，外部进程会被阻塞，进而导致你的Java程序无响应。

完整解决方案代码 #

下面是可以保持交互式会话的完整代码，它会启动MySQL控制台，实时输出结果，直到你输入exit或quit主动结束会话：

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

public class MySQLInteractiveShell {
    public static void main(String[] args) {
        // 配置MySQL命令，根据你的实际情况修改用户名、密码等参数
        ProcessBuilder processBuilder = new ProcessBuilder("mysql", "-u", "root", "-p");
        // 将错误流重定向到输出流，方便统一处理
        processBuilder.redirectErrorStream(true);

        try {
            Process process = processBuilder.start();

            // 启动线程处理MySQL的输出流（实时打印结果）
            new Thread(() -> {
                try (BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()))) {
                    String line;
                    while ((line = reader.readLine()) != null) {
                        System.out.println(line);
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }).start();

            // 获取MySQL的输入流，用于发送命令
            try (BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(process.getOutputStream()));
                 Scanner scanner = new Scanner(System.in)) {

                System.out.println("已进入MySQL交互式控制台，输入exit/quit退出");
                String input;
                while (true) {
                    // 读取用户输入的命令
                    input = scanner.nextLine().trim();

                    // 检测退出命令
                    if ("exit".equalsIgnoreCase(input) || "quit".equalsIgnoreCase(input)) {
                        // 发送退出命令并关闭输入流
                        writer.write(input + "\n");
                        writer.flush();
                        break;
                    }

                    // 发送命令到MySQL，并刷新缓冲区（必须flush，否则命令不会立即发送）
                    writer.write(input + "\n");
                    writer.flush();
                }

                // 等待进程结束
                int exitCode = process.waitFor();
                System.out.println("MySQL控制台已退出，退出码：" + exitCode);

            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                e.printStackTrace();
            }

        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

关键要点解释 #

1. 不要提前关闭输入流：只有当你要结束会话时，才需要关闭BufferedWriter（或者发送exit命令后让进程自行终止）。在交互式会话中，输入流要保持打开状态，才能持续发送命令。
2. 用独立线程处理输出流：MySQL进程的输出会不断写入到标准输出流，如果主线程去读取，会阻塞用户输入的逻辑。所以我们单独开一个线程来实时读取并打印输出，避免缓冲区阻塞。
3. 必须flush输入流：BufferedWriter默认是带缓冲的，调用write()后内容会存在缓冲区中，只有调用flush()才会立即发送给MySQL进程，否则命令不会被执行。
4. 合并错误流：通过processBuilder.redirectErrorStream(true)将错误流和输出流合并，这样我们只需要处理一个流就能同时看到正常输出和错误信息。

注意事项 #

• 确保你的系统环境变量中已经配置了MySQL的bin目录，或者在ProcessBuilder中指定mysql命令的完整路径（比如C:\mysql\bin\mysql.exe或/usr/bin/mysql）。
• 根据你的MySQL配置修改命令参数，比如添加-h指定主机、-P指定端口等。

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