使用Java ProcessBuilder调用sqlcmd时无法获取OutputStream内容

你的核心问题是Java调用交互式sqlcmd进程时，输入流读取方法read()一直阻塞，无法获取到1>这类提示符，原因有两个：

1. sqlcmd是交互式控制台程序，默认依赖终端环境的缓冲机制，Java的Process默认没有模拟终端，导致输出（包括提示符）可能被缓冲而不立即输出。
2. 你的response()方法使用了阻塞式的循环读取，直到read()返回-1才停止，但sqlcmd进程未退出时，输入流不会关闭，read()会一直等待新的输出，导致阻塞。

具体解决方案 #

1. 用异步线程实时读取输出 #

启动sqlcmd后，单独开启一个线程来持续读取其输出，避免主线程被阻塞，同时能实时捕获包括提示符在内的所有输出内容。

2. 调整sqlcmd启动参数 #

添加参数确保sqlcmd在非终端环境下也能正常输出提示符，比如指定本地实例、启用错误输出重定向等，示例参数：sqlcmd -S . -E -r 1

• -S .：连接本地SQL Server实例
• -E：使用Windows身份验证
• -r 1：将错误输出重定向到标准输出（配合redirectErrorStream(true)确保错误和正常输出都能被捕获）

修改后的代码示例 #

package org.example;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;

public class Main {
    public static Process process = null;
    public static StringBuilder outputBuffer = new StringBuilder();
    public static BufferedReader reader;
    public static OutputStream writer;

    public static void main(String[] args) throws Exception {
        start("sqlcmd -S . -E -r 1");
        // 等待提示符出现，实际场景可根据输出内容判断，无需固定延迟
        Thread.sleep(500);
        System.out.println("当前输出：" + getOutput());
        
        send("select * from spt_monitor\ngo\n");
        // 等待命令执行完成
        Thread.sleep(1000);
        System.out.println("执行命令后输出：" + getOutput());
    }

    public static void start(String command) throws Exception {
        if (process != null && process.isAlive()) {
            throw new Exception("已有活跃会话");
        }
        ProcessBuilder builder = new ProcessBuilder(command.split(" "));
        builder.redirectErrorStream(true);
        process = builder.start();
        
        // 初始化IO流
        reader = new BufferedReader(new InputStreamReader(process.getInputStream()));
        writer = process.getOutputStream();
        
        // 启动异步读取线程
        new Thread(() -> {
            String line;
            try {
                while ((line = reader.readLine()) != null) {
                    outputBuffer.append(line).append("\n");
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }).start();
    }

    public static void send(String command) throws Exception {
        if (process == null || !process.isAlive()) {
            throw new Exception("无活跃会话");
        }
        writer.write(command.getBytes());
        writer.flush();
    }

    // 获取当前累积的输出，并清空缓冲（可选）
    public static String getOutput() {
        String content = outputBuffer.toString();
        outputBuffer.setLength(0);
        return content;
    }
}

关键修改说明 #

• 新增异步读取线程：持续读取sqlcmd的输出，将内容存入缓冲，避免主线程阻塞。
• 使用BufferedReader.readLine()按行读取：更适合处理控制台输出，包括1>这类提示符。
• 新增getOutput()方法：用于获取累积的输出内容，按需清空缓冲。
• 添加延迟等待：sqlcmd启动和命令执行需要时间，实际场景中可以根据输出内容判断是否完成，而非固定延迟。

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