Java读取进程输出无缓冲/实时

我想在进程生成时正确读取其标准输出。 我知道以前有人问过这个问题,但没有人回答。

您可能想先看看StreamGobblerOutput类。

    public List<String> executeCall(String fileName) 
    {
    StringBuilder sbOutput = new StringBuilder();
    StringBuilder sbError = new StringBuilder();

    File file = new File(fileName);
    try ( BufferedReader br = new BufferedReader(new FileReader(file)) ) {
        String line;
        while ((line = br.readLine()) != null) {
           String [] parts = line.split("\\s");
           if(parts.length<2) {
               sbError.append("Command too short for call: " + parts[0]);
               continue;
           }

            List<String> args = new ArrayList<String>();
            args.add ("sfb.exe");
            for(int i = 1; i <parts.length; ++i) {
                args.add (parts[i]);
            }
            args.add (sfbPassword);

            ProcessBuilder pb = new ProcessBuilder (args);
            pb.directory(new File(Support.getJustThePathFromFile(file)));
            Map<String, String> envs = pb.environment();
            String path = envs.get("Path");
            envs.put("Path", Paths.get(".").toAbsolutePath().normalize().toString() + ";" +path);


            //pb.redirectOutput(new Redirect() {});
            Process p = pb.start();

            String outputPathPrefix = pb.directory().getCanonicalPath();

            // any output?
            StreamGobblerOutput outputGobbler = new StreamGobblerOutput(p.getInputStream(), outputPathPrefix);
            outputGobbler.start();

            // any errors?
            StreamGobblerError errorGobbler = new StreamGobblerError(p.getErrorStream());
            errorGobbler.start();


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

            sbOutput = outputGobbler.getOutput();
            sbError = errorGobbler.getErrors();

            String rootPath= Support.getJustThePathFromFile(new File(fileName));
            File rootFile = new File(rootPath + "/..");
            String rootFolder = rootFile.getCanonicalFile().getName();
            System.err.println("rootFolder: " + rootFolder);
            mainApp.addModifiedFiles(outputGobbler.getModifiedFileNames(), rootFolder);

        }
    } catch ( IOException ex) {
        sbError.append(ex.getMessage());
    }

    mainApp.addOutput(sbOutput.toString());
    mainApp.addError(sbError.toString());

    return;

}

    private class StreamGobblerOutput extends Thread {
        private InputStream is;
        private String outputPathPrefix;
        private StringBuilder sbOutput;
        private List<String> modifiedFileNames;
        private Scanner scanner;

        private StreamGobblerOutput(InputStream is, String outputPathPrefix) {
            this.is = is;
            this.outputPathPrefix = outputPathPrefix;
            sbOutput = new StringBuilder();
            modifiedFileNames = new ArrayList<String>();
            scanner = new Scanner(is);
        }

        public StringBuilder getOutput() {
            return sbOutput;    
        }

        public List<String> getModifiedFileNames() {
            return modifiedFileNames;       
        }

        @Override
        public void run() {
            //create pattern
            Pattern patternProgress = Pattern.compile("\\((\\d+)%\\)");

            //InputStreamReader isr = new InputStreamReader(is);
            //BufferedReader br = new BufferedReader(isr);
            String ligne = null;
            while (scanner.hasNextLine()) {
                ligne = scanner.nextLine();

                sbOutput.append(ligne);
                sbOutput.append("\r\n");
                //bw.write("\r\n");

                Matcher mProgress = patternProgress.matcher(ligne);
                if (mProgress.find()) {
                    int percentage = Integer.parseInt(mProgress.group(1));
                    System.err.println("percentage=" + percentage);
                    mainApp.mainWindowController.setProgressExecute(percentage/100.0);
                }
            }
            mainApp.mainWindowController.setProgressExecute(1.0);
            if (scanner != null) {
                scanner.close();
             }
        }
    }

    private class StreamGobblerError extends Thread {
        private InputStream is;
        private StringBuilder sbError;
        private Scanner scanner;

        private StreamGobblerError(InputStream is) {
            this.is = is;
            sbError = new StringBuilder();
            scanner = new Scanner(is);
        }

        public StringBuilder getErrors() {
            return sbError;     
        }

        @Override
        public void run() {
            //InputStreamReader isr = new InputStreamReader(is);
            //BufferedReader br = new BufferedReader(isr);
            String ligne = null;
            while (scanner.hasNextLine()) {
                ligne = scanner.nextLine();
                sbError.append(ligne);
                sbError.append("\r\n");
            }
            if (scanner != null) {
                scanner.close();
             }
        }
    }

作为一种解决方法,我必须要求.exe的创建者在显示进度的每行中额外包含4100个字符。