锐客网

  1. 首页 > 睿知 > it技术 > >

java代码运行sh命令 java执行java代码( 二 )

IT技术代码


} catch (IOException e) {
}
}
}
}
}
CommandHelper类使用了CommandResult对象输出结果错误信息 。该类实现
复制代码代码如下:
package javaapplication3;
/**
*
* @author chenshu
*/
public class CommandResult {
public static final int EXIT_VALUE_TIMEOUT=-1;
private String output;
void setOutput(String error) {
output=error;
}
String getOutput(){
return output;
}
int exitValue;
void setExitValue(int value) {
exitValue=https://www.04ip.com/post/value;
}
int getExitValue(){
return exitValue;
}
private String error;
/**
* @return the error
*/
public String getError() {
return error;
}
/**
* @param error the error to set
*/
public void setError(String error) {
this.error = error;
}
}
怎么通过java去调用并执行shell脚本以及问题总结对于第一个问题：java抓?。⑶野呀峁虬?。那么比较直接的做法就是 ， java接收各种消息（db，metaq等等），然后借助于jstorm集群进行调度和抓取 。
最后把抓取的结果保存到一个文件中，并且通过调用shell打包，回传 。也许有同学会问，
为什么不直接把java调用odps直接保存文件，答案是，我们的集群不是hz集群，直接上传odps速度很有问题，因此先打包比较合适 。（这里不纠结设计了，我们回到正题）
java调用shell的方法
通过ProcessBuilder进行调度
这种方法比较直观，而且参数的设置也比较方便，比如我在实践中的代码(我隐藏了部分业务代码)：
ProcessBuilderpb = new ProcessBuilder("./" + RUNNING_SHELL_FILE, param1,
param2, param3);
pb.directory(new File(SHELL_FILE_DIR));
int runningStatus = 0;
String s = null;
try {
Process p = pb.start();
try {
runningStatus = p.waitFor();
} catch (InterruptedException e) {
}
} catch (IOException e) {
}
if (runningStatus != 0) {
}
return;
这里有必要解释一下几个参数：
RUNNING_SHELL_FILE：要运行的脚本
SHELL_FILE_DIR：要运行的脚本所在的目录； 当然你也可以把要运行的脚本写成全路径 。
runningStatus：运行状态，0标识正常 。详细可以看java文档 。
param1, param2, param3：可以在RUNNING_SHELL_FILE脚本中直接通过1,2,$3分别拿到的参数 。
直接通过系统Runtime执行shell
这个方法比较暴力，也比较常用，代码如下：
p = Runtime.getRuntime().exec(SHELL_FILE_DIR + RUNNING_SHELL_FILE + " "+param1+" "+param2+" "+param3);
p.waitFor();
我们发现 ， 通过Runtime的方式并没有builder那么方便 ， 特别是参数方面，必须自己加空格分开，因为exec会把整个字符串作为shell运行 。
可能存在的问题以及解决方法
如果你觉得通过上面就能满足你的需求，那么可能是要碰壁了 。你会遇到以下情况 。
没权限运行
这个情况我们团队的朱东方就遇到了，在做DTS迁移的过程中，要执行包里面的shell脚本， 解压出来了之后 ， 发现执行不了 。那么就按照上面的方法授权吧
java进行一直等待shell返回
这个问题估计更加经常遇到 。原因是，shell脚本中有echo或者print输出 ，  导致缓冲区被用完了! 为了避免这种情况，一定要把缓冲区读一下，好处就是，可以对shell的具体运行状态进行log出来 。比如上面我的例子中我会变成：
ProcessBuilderpb = new ProcessBuilder("./" + RUNNING_SHELL_FILE, keyword.trim(),
taskId.toString(), fileName);
pb.directory(new File(CASPERJS_FILE_DIR));

推荐阅读


上一篇：什么片子视频可以看，什么视频可以看所有电影

下一篇：云蹦迪无人直播间直播，云蹦迪网站