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

77 阅读 0 评论 51 点赞

我是靠谱客的博主顺心指甲油，最近开发中收集的这篇文章主要介绍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();
}
}