java - 运行 linux 命令时 Tomcat 问题

Question

我正在尝试在 java 代码中运行 linux 命令。该命令是 raspivid，我已将其放置在服务器上的 test.sh 文件下，用于实时摄像机流式传输。一切正常，但问题是在启动 tomcat 服务器几分钟后流媒体停止。就像在 java 中运行命令时 6-7 分钟后流停止一样，但在后台 raspivid 进程正在运行。另一方面，当我在不使用 java 代码的情况下运行相同的命令时，它工作正常。这是 tomcat 堆的问题还是其他任何停止流式传输的问题？请帮忙看看下面的代码:

try {
         Process p = Runtime.getRuntime().exec(new String[]{"sudo","sh","/home/pi/test.sh"});
            BufferedReader stdInput = new BufferedReader(new
                 InputStreamReader(p.getInputStream()));

            BufferedReader stdError = new BufferedReader(new
                 InputStreamReader(p.getErrorStream()));

            // read the output from the command
            LOGGER.info("Here is the standard output of the command:\n");
            while ((s = stdInput.readLine()) != null) {
                LOGGER.info(s);
            }

            // read any errors from the attempted command
            LOGGER.info("Here is the standard error of the command (if any):\n");
            while ((s = stdError.readLine()) != null) {
                LOGGER.info(s);
            }

        }

Answer 1

问题是 BufferedReader.readLine() 会阻塞，直到可以读取整行(由任何行结束字符序列终止)，并且您不会读取该过程的 2 个输出“并行”，如果它的缓冲区被填满并且进程被阻塞。

你需要读取进程输出的数据。

一个进程有两个输出流:标准输出和错误输出。您必须阅读两者，因为该过程可能会写入这两个输出。

进程的输出流有缓冲区。如果输出流的缓冲区已满，进程将阻止向其写入更多数据的尝试。

做这样的事情:

BufferedReader stdInput = new BufferedReader(
        new InputStreamReader(p.getInputStream()));

BufferedReader stdError = new BufferedReader(
        new InputStreamReader(p.getErrorStream()));

while (p.isAlive()) {
    while (stdInput.ready())
        LOGGER.info(stdInput.readLine());

    while (stdError.ready())
        LOGGER.info(stdError.readLine());

    Thread.sleep(1);
}

此解决方案的问题(并修复它):

这个解决方案有错误。该过程可能不会将整行写入其输出。如果是这种情况，进程可能仍会挂起，例如，如果它向其标准输出写入 1 个字符，则 stdInput.readLine() 将阻塞(因为它会读取直到遇到换行符)并且如果进程继续写入其错误流，当错误流的缓冲区已满时，进程将被阻塞。

所以最好不要按行读取缓冲区的输出流，而是按字符读取(当然这会使记录更难):

StringBuilder lineOut = new StringBuilder(); // std out buffer
StringBuilder lineErr = new StringBuilder(); // std err buffer

while (p.isAlive()) {
    while (stdInput.ready()) {
        // Append the character to a buffer or log if it is the line end
        char c = (char) stdInput.read();
        if (c == '\n') {  // On UNIX systems line separator is one char: '\n'
            LOGGER.info(lineOut.toString());
            lineOut.setLength(0);
        }
        else
            lineOut.append(c);
    }

    while (stdError.ready()) {
        // Append the character to a buffer or log if it is the line end
        char c = (char) stdError.read()
        if (c == '\n') {  // On UNIX systems line separator is one char: '\n'
            LOGGER.info(lineErr.toString());
            lineErr.setLength(0);
        }
        else
            lineErr.append(c);
    }

    Thread.sleep(1);
}

替代(更干净、更简单)的解决方案

或者，您可以启动 2 个线程，一个读取进程的标准输出，一个读取进程的标准错误。这可以简化事情:

private static void consumeStream(final InputStream is) {
    new Thread() {
        @Override
        public void run() {
            BufferedReader r = new BufferedReader(new InputStreamReader(is));
            String line;
            while ((line = r.readLine()) != null)
                LOGGER.info(line);
        }
    }.start();
}

并使用它:

consumeStream(p.getInputStream());
consumeStream(p.getErrorStream());