Java-Process执行脚本,waitFor()卡住不执行

以脚本解压tar文件为例,如果tar包的生成时间在系统时间之后的话,解压就会有很多错误日志,使用java进行解压时,如果没有及时处理input或者是error缓冲区里的数据,那么等到缓冲区中数据满了(主要是error缓冲区)之后,解压操作就不会再继续进行下去了,因此要在解压过程中及时的将缓冲区中的数据清空,防止因为缓冲区爆满导致的解压失败;最终的解决方法是使用两个线程,在解压过程中对缓冲区中的数据读出。

解决代码如下:

public static String getCmdExecuteString(String cmdCommand) throws IOException, InterruptedException {

     StringBuilder sb = new StringBuilder();
     Process ps = cmdCommandExecute(cmdCommand);

     try (InputStreamReader ir = new InputStreamReader(ps.getInputStream());
          InputStreamReader er = new InputStreamReader(ps.getErrorStream());
          LineNumberReader input = new LineNumberReader(ir);
          LineNumberReader error = new LineNumberReader(er)) {

         new Thread(() -> {
             try {
                 String line;
                 while ((line = input.readLine()) != null) {
                     sb.append(line);
                     sb.append("\n");
                 }
             } catch (Exception e) {
                 if (!"Stream closed".equals(e.getMessage())) {
                     log.error(e.getMessage(), e);
                 }
             }
         }).start();

         new Thread(() -> {
             try {
                 String line;
                 while ((line = error.readLine()) != null) {
                     sb.append(line);
                     sb.append("\n");
                 }
             } catch (Exception e) {
                 if (!"Stream closed".equals(e.getMessage())) {
                     log.error(e.getMessage(), e);
                 }
             }
         }).start();

         int status = ps.waitFor();
         log.debug("get cmd execute status is {}", status);
         String result = sb.toString();
         log.debug("get cmd execute result is {}", result);
         return result;
     } finally {
         ps.destroy();
     }
}
上一篇:简单验证码识别(matlab)


下一篇:Java二叉树遍历的非递归算法(前序)