java在企业级项目开发中,无论是强制性的功能需要,还是为了简便java的实现,需要调用服务器命令脚本来执行。在java中,RunTime.getRuntime() .exec() 就实现了这个功能。
用法:
public Process exec(String command)//在单独的进程中执行指定的字符串命令。
public Process exec(String [] cmdArray)//在单独的进程中执行指定命令和变量
public Process exec(String command, String [] envp)//在指定环境的独立进程中执行指定命令和变量
public Process exec(String [] cmdArray, String [] envp)//在指定环境的独立进程中执行指定的命令和变量
Linux下:
String[] envp = { "LANG=UTF-8" };
String[] comands = new String[] { "/bin/sh", "-c", args};
Process process = Runtime.getRuntime().exec(comands, envp);
Windows下:
String[] envp = { "LANG=UTF-8" };
String[] comands = new String[] { "cmd", "/c", args};
Process process = Runtime.getRuntime().exec(comands, envp);
进阶:
Process的几种方法:
destroy():杀掉子进程
exitValue():返回子进程的出口值,值 0 表示正常终止
getErrorStream():获取子进程的错误流
getInputStream():获取子进程的输入流
getOutputStream():获取子进程的输出流
waitFor():导致当前线程等待,如有必要,一直要等到由该 Process 对象表示的进程终止。如果子进程结束,此方法立即返回。如果该子进程没结束,调用的线程将被阻塞,直到子进程退出,
笔者在用mysql和mysqldump指令进行智能和服时,遇到主键冲突没法正常返回,后来发现是因为没有读取错误流导致。
根据惯例,0 表示正常终止(即使比如mysql指令的主键冲突,只要是指令的返回也算是正常终止),
注意:在java中,调用runtime线程执行脚本是非常消耗资源的,所以切忌不要频繁使用!
在调用runtime去执行脚本的时候,其实就是JVM开了一个子线程去调用JVM所在系统的命令,其中开了三个通道: 输入流、输出流、错误流,其中输出流就是子线程走调用的通道。
process的阻塞:
在runtime执行大点的命令中,输入流和错误流会不断有流进入存储在JVM的缓冲区中,如果缓冲区的流不被读取被填满时,就会造成runtime的阻塞。所以在进行比如:大文件复制等的操作时,我们还需要不断的去读取JVM中的缓冲区的流,来防止Runtime的死锁阻塞。
最后附上在linux 上封装的方法供参考:
/**
* @param daemon true,后台执行,false,直接执行
* @param args 指令行
*/
public static Result sendCommand(boolean daemon,String args) {
logger.info("args={}", args);
StringBuilder builder = new StringBuilder();
// InputStreamReader ir = null;
// LineNumberReader input = null;
try {
String[] envp = { "LANG=UTF-8" };
Process process=null;
if(daemon) {
String[] comands = new String[] { "/bin/sh", "-c", args};
process = Runtime.getRuntime().exec(comands, envp);
process.waitFor();
}else {
process = Runtime.getRuntime().exec(args, envp);
process.waitFor(60,TimeUnit.SECONDS);
}
try (InputStreamReader ir = new InputStreamReader(process.getInputStream(), Charset.forName("UTF-8"));LineNumberReader input = new LineNumberReader(ir)) {
String tmp = "";
while ((tmp = input.readLine()) != null) {
builder.append(tmp).append("\n");
}
}catch (Exception e) {
logger.error(e.getMessage(), e);
return new Result(ErrorCode.EC_FAILED, e.getMessage());
}
try (InputStreamReader ir = new InputStreamReader(process.getErrorStream(), Charset.forName("UTF-8"));LineNumberReader input = new LineNumberReader(ir)) {
String tmp = "";
while ((tmp = input.readLine()) != null) {
builder.append(tmp).append("\n");
}
}catch (Exception e) {
logger.error(e.getMessage(), e);
return new Result(ErrorCode.EC_FAILED, e.getMessage());
}
} catch (Exception e) {
logger.error(e.getMessage(), e);
return new Result(ErrorCode.EC_FAILED, e.getMessage());
}
String result = builder.toString();
if (StringUtils.isNotEmpty(result)&&StringUtils.containsIgnoreCase(result, "ERROR")) {
logger.info("result={}", result);
return new Result(ErrorCode.EC_FAILED, result);
} else {
return new Result(ErrorCode.EC_OK);
}
}
标签:调用,JAVA,String,exec,process,envp,Process,new,服务器 From: https://blog.51cto.com/u_4176761/5973332