Как получить вывод в реальном времени из консольного приложения на Java - PullRequest
Новая
       21

Как получить вывод в реальном времени из консольного приложения на Java

1 голос
/ 25 октября 2019

У меня есть EXE, написанный на python, а затем преобразованный в exe. Когда я запускаю exe direclty, я могу видеть вывод в консоли в реальном времени, но когда я запускаю exe в java, я не могу видеть вывод до exeзавершить процесс.

У меня есть поиск в Интернете, но замечание работает, вот пример кода. 

package com.imviewer.ai;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.PrintStream;
import java.util.ArrayList;
import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

открытый класс FaceAnalysis реализует AILibrary {частный статический окончательный журнал Logger = LoggerFactory.getLogger (FaceAnalysis.class); 

private static final String KILL = "taskkill /F /IM ";
private static final String EXE_CPU = "FaceAnalysis-CPU.exe";
private static final String EXE_GPU = "FaceAnalysis-GPU.exe";

List<String> paths = new ArrayList<>();

public FaceAnalysis() {

}

@Override
public void setArguments() {

    log.info("Setting arguments");
    paths.add(new File(AIUtils.FACE, EXE_CPU).getAbsolutePath());
    paths.add("--images=yes");
    paths.add("--videos=yes");
    paths.add("--csv=no");
    paths.add("--folderpath=\"Face\"");
    paths.add("--algo=cnn");
    paths.add("--gpu=no");
    paths.add("--cpus=6");
    paths.add("--debug=no");
    paths.add("--fpstoproces=5");
    paths.add("--upsample=0");
    paths.add("--onlydetection=yes");
    paths.add("--savefullimages=no");
    paths.add("--savefaceimage=no");
    paths.add("--enablebox=no");
    paths.add("--maxarea=640000");
    paths.add("--imageextensions=jpg,png,jpeg,tiff,raw,bmp");
    paths.add("--videoextensions=mp4,avi,flv,mpeg,mpg,wmv");
    paths.add("--age=1");
    paths.add("--gender=1");
    paths.add("--expression=1");

}

@Override
public void run() {

}

@Override
public void runEXE() {
    log.info("Running Face Exe");

    ProcessBuilder builder = new ProcessBuilder(paths);
    builder.directory(new File(AIUtils.FACE));
    builder.redirectOutput(ProcessBuilder.Redirect.INHERIT);
    builder.redirectInput(ProcessBuilder.Redirect.INHERIT);
    builder.redirectErrorStream(true);

    Process proc;
    try {
        proc = builder.start();
        proc.getOutputStream().close();

         // Any error message?
        Thread errorGobbler
          = new Thread(new StreamGobbler(proc.getErrorStream(), System.err));

        // Any output?
        Thread outputGobbler
          = new Thread(new StreamGobbler(proc.getInputStream(), System.out));

        errorGobbler.start();
        outputGobbler.start();

        // Any error?
        int exitVal = proc.waitFor();
        errorGobbler.join();   // Handle condition where the
        outputGobbler.join();  // process ends before the threads finish

        log.info("Exit Value: "+ exitVal);

    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

    log.info("End Running Face EXE");
}

@Override
public boolean checkAlreadyRunning() {
    // TODO Auto-generated method stub
    return false;
}

@Override
public void close() {
    // TODO Auto-generated method stub

}

class StreamGobbler implements Runnable {
    private final InputStream is;
    private final PrintStream os;

    StreamGobbler(InputStream is, PrintStream os) {
        this.is = is;
        this.os = os;
    }

    public void run() {
        try {
            int c;
            while ((c = is.read()) != -1)
                os.print((char) c);
        } catch (IOException x) {
            // Handle error
        }
    }
}

public static void main(String[] args) {
    FaceAnalysis face = new FaceAnalysis();
    face.setArguments();
    face.runEXE();
}
}

1 Ответ

0 голосов
/ 25 октября 2019

Попробуйте такой подход: 

public static void main(String[] args) throws IOException {
    Process p = new ProcessBuilder().command("ping", "webelement.click").start();
    InputStream i = p.getInputStream();
    Scanner scanner = new Scanner(i);           
    while (scanner.hasNextLine()){              
        System.out.println(scanner.nextLine()); 
    }
}
...