4

我有一个 python 脚本，需要很长时间才能完成。我想从 Java 中运行它，但也在执行时输出脚本的输出，这样我就可以判断它是否正常运行。

我已经搜索并只找到了在系统命令完成后而不是在执行期间输出输出的示例。

脚本运行时有什么办法吗？

这就是我所拥有的

public void doSomething() throws IOException {
    String[] callAndArgs = {"python", "/hi.py"};
    Process p = Runtime.getRuntime().exec(callAndArgs);
    BufferedReader stdInput = new BufferedReader(new InputStreamReader(p.getInputStream()));
    BufferedReader stdError = new BufferedReader(new InputStreamReader(p.getErrorStream()));

    String s;
    while ((s = stdInput.readLine()) != null) {
        System.out.println(s);
    }

    while ((s = stdError.readLine()) != null) {
        System.out.println(s);
    }
}
4

4 回答 4

4

我设法让它像这样工作（注意它需要java7）：

package test;
import java.lang.ProcessBuilder.Redirect;

public class Test {

    public static void main(String... args) throws Exception {
        ProcessBuilder pb = new ProcessBuilder("python","/home/foobar/Programming/test/src/test/test.py");
        pb.redirectOutput(Redirect.INHERIT);
        Process p = pb.start();
        p.waitFor();
    }

}

python（注意我在 python 上刷新以使其使用 sys.stdout.flush() 工作）

import time,sys
c =0
while c<=50:
    time.sleep(1)
    print("----")
    c = c +1
    sys.stdout.flush()

请注意，如果您不想循环刷新，可以使用以下命令：

ProcessBuilder pb = new ProcessBuilder("python","-u","/home/foobar/Programming/NetBeansProjects/test/src/test/test.py");

重定向.INHERIT

表示子进程 I/O 源或目标将与当前进程的相同。这是大多数操作系统命令解释器（shell）的正常行为。

于 2013-09-30T21:27:22.447 回答
2

我已经搜索并只找到了在系统命令完成后而不是在执行期间输出输出的示例。

这很奇怪，因为您的示例应该在命令执行时转储输出。

BufferedReader您可以尝试直接从 中读取，而不是使用，InputStream因为可能直到进程退出后才满足 readLine 所需的条件。

我还建议您直接使用ProcessBuilderover Process，因为除了其他任何内容之外，它还允许您将输出从错误流重定向到输入流，从而允许您只读取一个流而不是两个...

这也可能是 Python 以及它如何刷新输出缓冲区的问题......

例如，与其等待BufferedReader决定何时返回，不如尝试在流发生/报告时打印流中的每个字符

            ProcessBuilder pb = new ProcessBuilder("test.py");
            pb.redirectError();
            Process p = pb.start();

            InputStream is = null;
            try {
                is = p.getInputStream();
                int in = -1;
                while ((in = is.read()) != -1) {
                    System.out.print((char)in);
                }
            } finally {
                try {
                    is.close();
                } catch (Exception e) {
                }
            }

更新

稍微阅读一下，Python 似乎在将其发送到标准输出之前将其缓冲出来。我认为您无法在 Java 端解决此问题，但需要更改 Python 的运行方式或脚本的工作方式。

请参阅如何刷新 Python 打印的输出？更多细节

于 2013-09-30T20:26:16.600 回答
1

我怀疑您正在写入 stderr，因为您阻塞了 stdin，所以您看不到它。使用ProcessBuilder而不是做exec. 这样，您可以将 stderr 和 stdin 重定向到单个流中。

这是一个例子：

import java.io.*;

public class Test {
    public static void main(String... args) throws IOException {

        ProcessBuilder pb =
                new ProcessBuilder("test.py");

        pb.redirectErrorStream(true);
        Process proc = pb.start();

        Reader reader = new InputStreamReader(proc.getInputStream());
        BufferedReader bf = new BufferedReader(reader);
        String s;
        while ((s = bf.readLine()) != null) {
            System.out.println(s);
        }
    }
}

或者，您可以生成线程以分别从标准输入/标准错误中读取。

要寻找的另一件事是python的输出缓冲。您可以通过执行以下操作查看这是否是原因：

import sys
sys.stdout.flush()

在你写到标准输出之后

于 2013-09-30T20:23:30.830 回答
0

不要在 while 循环中使用 #readLine 作为条件。而是将您的 inputStream 包装在扫描仪中并使用 #hasNextLine()

    Scanner in = new Scanner(p.getInputStream());
    while (in.hasNextLine()) {
        System.out.println(in.nextLine());
    }
于 2013-09-30T20:19:20.107 回答