Java读取Python子进程输出受阻，子进程管理器多线程读写问题

这个问题我之前帮不少开发者解决过——核心原因是Python的标准输出缓冲机制，加上Java端没有正确处理子进程的多流读取，导致输出被卡在缓冲区里，直到你关闭输入流才触发刷新。咱们一步步来解决：

问题根源 #

当Python脚本的标准输入是管道（也就是Java Process提供的管道）时，Python会把标准输出从行缓冲切换为全缓冲。这意味着print的内容会先存在内存缓冲区里，直到缓冲区填满、进程结束，或者输入流被关闭（触发缓冲区刷新），才会把内容发送给Java端。这就是为什么你必须关闭输入流才能读到输出的原因。

解决方案 #

1. 让Python禁用输出缓冲 #

有两种方式可以实现：

方式A：修改Python脚本，手动刷新缓冲区

在每个print后调用sys.stdout.flush()，强制把缓冲区内容输出：

import sys
if __name__ == "__main__":
    print("START TEST SCRIPT")
    sys.stdout.flush()  # 强制刷新
    print("SOME STRING")
    sys.stdout.flush()
    for line in sys.stdin:
        print("DEBUG>>> " + line)
        sys.stdout.flush()

方式B：用-u参数启动Python

在Java的ProcessBuilder中，给Python命令加上-u参数，直接禁用所有标准流的缓冲：

ProcessBuilder builder = new ProcessBuilder("python", "-u", "test.py");
// 如果是Python3环境，换成"python3"

2. Java端正确处理多流读取 #

如果Java只在主线程读取标准输出，而子进程同时有错误输出（stderr），当stderr的缓冲区填满时，子进程会被阻塞，导致你也读不到stdout的内容。所以必须用独立线程分别读取stdout和stderr：

完整的Java测试类示例：

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

public class Test {
    public static void main(String[] args) throws IOException, InterruptedException {
        // 构建子进程，使用-u参数禁用Python缓冲
        ProcessBuilder builder = new ProcessBuilder("python", "-u", "test.py");
        Process process = builder.start();

        // 启动线程读取标准输出
        new Thread(() -> readStream(process.getInputStream(), "STDOUT")).start();
        // 启动线程读取错误输出，避免阻塞子进程
        new Thread(() -> readStream(process.getErrorStream(), "STDERR")).start();

        // 向Python子进程发送输入
        OutputStream stdin = process.getOutputStream();
        stdin.write("Hello from Java\n".getBytes());
        stdin.flush();  // 确保数据发送到Python

        // 如果需要持续交互，不要关闭stdin，后续可以继续发送数据
        // stdin.close();

        // 等待子进程执行完成
        int exitCode = process.waitFor();
        System.out.println("子进程退出码: " + exitCode);
    }

    // 通用的流读取方法
    private static void readStream(InputStream stream, String streamName) {
        try (BufferedReader reader = new BufferedReader(new InputStreamReader(stream))) {
            String line;
            while ((line = reader.readLine()) != null) {
                System.out.printf("[%s] %s%n", streamName, line);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

效果验证 #

运行修改后的代码，你会发现不需要关闭输入流，Java就能实时读到Python输出的START TEST SCRIPT和SOME STRING，发送输入后也能立刻收到DEBUG>>> Hello from Java的反馈。

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