Java线程问题——监听n个错误流

Question

首先让我说，我在线程方面的经验非常低。

我有一个应用程序可以通过Runtime.exec 方法启动其他几个Java jar。问题是启动的 jars 需要同时运行，但为了获得启动 jars 的错误流，您基本上必须有一个循环“坐下来听”，直到过程完成。

这就是我现在拥有的：

_processes.add( Runtime.getRuntime().exec( commandList.toArray( new String[ commandList.size() ] ) ) );
Thread thread = new Thread( new Runnable() {
    private final int _processNumber = _processes.size() - 1;
    public void run() {
        String streamData = _processNumber + " : ";
        streamData += "StdError [\r";
        BufferedReader bufferedReader =
                new BufferedReader( new InputStreamReader( _processes.get( _processNumber ).getErrorStream() ) );
        String line = null;
        try {
            while ( ( line = bufferedReader.readLine() ) != null ) {
                streamData += line + "\r";
            }
            bufferedReader.close();
            streamData += "]\r";
            LOG.error( streamData );
        }
        catch ( Exception exception ) {
            LOG.fatal( exception.getMessage() );
            exception.printStackTrace();
        }
    }
} );
thread.start();

谁能解释如何让“错误流侦听器线程”正常工作？

TIA

Answer 1

不要使用 Runtime.getRuntime().exec()，而是使用 Process 来启动外部进程。它会让你的生活变得更轻松。

我的一个项目的示例代码：

    //Build command 
    List<String> commands = new ArrayList<String>();
    commands.add("my_application");
    commands.add("arg1");
    commands.add("arg2");
    log.debug("{}", commands);

    //Run command with arguments
    ProcessBuilder pb = new ProcessBuilder(commands);
    pb.directory(directory);
    pb.redirectErrorStream(true);
    Process process = pb.start();

    //Read output
    StringBuilder out = new StringBuilder();
    BufferedReader br = new BufferedReader(new InputStreamReader
        (process.getInputStream()));

    //Only log unique lines (you might not need this)
    String line = null, previous = null;
    while ((line = br.readLine()) != null)
        if (!line.equals(previous)) {
            previous = line;
            out.append(line).append('\n');
            log.debug(line);
        }

    //Check result
    if (process.waitFor() == 0)
        return 0;

    //Abnormal termination: Log command parameters and output and throw ExecutionException
    log.error("{}", commands);
    log.error("\n{}", out.toString());
    throw new ExecutionException(new IllegalStateException("MyApplication exit code 1"));

Answer 2

有一个很好的教程here 关于如何使用 Runtime.exec()。通读所有内容，尤其是第 4 页，其中解释了如何使用在单独线程中运行的“StreamGobbler”来消耗正在执行的进程中的 std out 和 std err 流。

基本上，您应该希望在伪代码中实现的是：

Runtime rt1 = Runtime.getRuntime().exec("my command")
new StreamGobbler(rt1.getOutputStream()).start()
new StreamGobbler(rt1.getErrorStream()).start()
//repeat for each external process (rt2, rt3 etc)
...
rt1.waitFor()
rt2.waitFor()
rt3.waitFor()

即您启动每个进程，并立即开始在单独的线程中使用每个进程的输出。随着消费线程的启动，只需等待每个进程完成并返回。