运行时执行程序进程挂起

如何解决运行时执行程序进程挂起

我正在尝试制作一个Javafx应用程序，该应用程序显示来自kubernetes的日志。我使用Runtime.getRuntime().exec通过以下方式获取kubetail servicename的输出：

 Process exec = Runtime.getRuntime().exec(new String[]{"kubetail","serviceName"});
        InputStream inputStream = exec.getInputStream();
        int read;
        try {
            while (((read = inputStream.read()) != -1)) {
                System.out.print((char) read);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }

该过程正常开始，我看到“将拖尾2个豆荚...”。当我在该服务上发出请求并出现很多日志时，就会出现问题。该服务将返回一个报告，并且该报告将被存档并记录。报告很大，有40K个字符。尾部以某种方式挂在记录的报告的中间，我再也没有得到任何数据，但是如果我发送另一个请求，它将从挂起的位置继续，并再次停在第二个请求的报告上。

我尝试使用缓冲读取器，并用NIO包装了输入流，但是问题仍然存在。我也尝试使用kubectl logs并且可以使用，但是我对日志行没有任何标识（我不知道它属于哪个容器）。 kubetail给出了应用程序中所有吊舱的日志流，这些日志通过颜色和吊舱名称进行标识。

谢谢

解决方法

您没有正确使用stdout和stderr流，如果不阅读就填充了它们，它们将导致进程输出挂起。您可以尝试在使用ProcessBuilder

时将stderr设置为进入stdout类

ProcessBuilder pb = new ProcessBuilder(new String[]{"kubetail","serviceName"});
pb.redirectErrorStream(true);
Process exec = pb.start();
... Your reading code
int rc = exec.waitFor();

OR：添加线程以同时使用stdout和stderr流：

Process exec = Runtime.getRuntime().exec(new String[]{"kubetail","serviceName"});        
new Thread(() -> copy(exec.getInputStream(),System.out),"STDOUT").start();
new Thread(() -> copy(exec.getErrorStream(),System.err),"STDERR").start();
int rc = exec.waitFor();

with方法：

static void copy(InputStream in,OutputStream out)
{
    try(var autoClose = in; var autoClose2 = out)
    {
        in.transferTo(out);
    }
    catch(IOException io)
    {
        throw new UncheckedIOException(io);
    }
}