Java调用外部Python脚本双向通信问题：输出需进程终止才接收

你遇到的问题核心在于Python的输出缓冲和Java单线程阻塞式读取，导致Java只能等Python进程结束才能拿到输出。下面是具体的解决步骤和完整示例：

一、先解决Python端的输出缓冲问题 #

Python默认会缓冲print()的输出，只有缓冲区满或者进程退出时才会把内容推给标准输出。咱们有两种办法解决：

方法1：手动刷新输出缓冲区 #

每次print之后调用sys.stdout.flush()，强制把内容刷到标准输出：

import sys

for i in range(3):
    print("hello")
    sys.stdout.flush()  # 关键：强制刷新缓冲区，让Java立刻收到
    line = sys.stdin.readline()
    print(f"Got response from Java: {line.strip()}")
    sys.stdout.flush()  # 同样刷新这个输出

方法2：启动Python时禁用全局缓冲 #

在Java调用Python进程时，加上-u参数，这个参数会让Python禁用标准输入输出的缓冲：

// Java里启动进程的命令改成这样
Process process = new ProcessBuilder("python", "-u", "your_script.py").start();

二、Java端实现实时双向通信（多线程处理） #

如果Java用单线程同时处理输入和输出，很容易因为等待用户输入而阻塞读取Python的输出，反之亦然。所以咱们用两个线程分别处理：一个读Python的输出，一个向Python发输入。

完整Java示例代码：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.Writer;

public class JavaPythonChat {
    public static void main(String[] args) throws IOException {
        // 启动Python进程，记得加-u参数禁用缓冲
        Process pythonProcess = new ProcessBuilder("python", "-u", "chat_script.py").start();

        // 线程1：实时读取Python的输出
        new Thread(() -> {
            try (BufferedReader pythonOutput = new BufferedReader(
                    new InputStreamReader(pythonProcess.getInputStream()))) {
                String line;
                // 持续读取直到Python进程结束
                while ((line = pythonOutput.readLine()) != null) {
                    System.out.println("[Python] " + line);
                }
            } catch (IOException e) {
                System.err.println("读取Python输出出错：" + e.getMessage());
            }
        }).start();

        // 线程2：向Python发送输入（从控制台读取用户输入）
        new Thread(() -> {
            try (Writer pythonInput = new OutputStreamWriter(pythonProcess.getOutputStream());
                 BufferedReader consoleInput = new BufferedReader(new InputStreamReader(System.in))) {
                String userInput;
                while ((userInput = consoleInput.readLine()) != null) {
                    // 必须加换行符，因为Python用readline()读取到换行为止
                    pythonInput.write(userInput + "\n");
                    pythonInput.flush();  // 刷新缓冲区，确保Python立刻收到
                }
            } catch (IOException e) {
                System.err.println("向Python发送输入出错：" + e.getMessage());
            }
        }).start();

        // 等待Python进程结束
        try {
            pythonProcess.waitFor();
            System.out.println("Python进程已结束");
        } catch (InterruptedException e) {
            System.err.println("进程等待被中断：" + e.getMessage());
        }
    }
}

关键注意点 #

• 不管用哪种Python缓冲解决方案，一定要确保输出能实时推给Java，否则还是会出现延迟。
• Java向Python发送输入时，必须加上\n换行符，因为Python的sys.stdin.readline()是读取到换行符才会返回的，不然Python会一直卡在读取步骤。
• 用多线程分离输入输出逻辑，避免单线程阻塞导致的“假死”情况。

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