Java中Process类的使用与注意事项说明
process类的使用与注意事项说明
1、在项目开发中
经常会遇到调用其它程序功能的业务需求,在java中通常有两种实现方法
runtime runtime = runtime.getruntime(); process p = runtime.exec(cmd);
process p=new processbuilder(cmd).start();
2、在这里就需要认识一下process类
process是一个抽象的类,它包含6个抽象的方法
abstract public outputstream getoutputstream(); abstract public inputstream getinputstream(); abstract public inputstream geterrorstream(); abstract public int waitfor() throws interruptedexception; abstract public int exitvalue(); abstract public void destroy();
process类提供获取子进程的输入流、子进程的输出流、子进程的错误流、等待进程完成、检查进程的推出状态以及销毁进程的方法;在这里需要提及的是创建的子进程没有自己的控制台或终端,其所有的io操作都是通过(输入流、输出流、错误流)重定向到父进程中。
3、来说说今天业务需求[waitfor()]:
我需要在linux下首先将一个文件copy到指定的文件夹下面,之后需要将该文件夹下面的文件加入指定的jar中,那么问题就来了,必须保证其先后顺序,也就书说再执行第二个命令的时候第一个命令必须完成。
public void cmd(string cmd){ try { process ps= runtime.getruntime().exec(cmd); } catch (exception e) { logger.info(e.getmessage(),e); } }
main函数如下:
public static void main(string[] args){ string copy="cp -rf "+source+" "+target; string jar="jar -uvf "+jar+" "+file; cmd(copy); cmd(jar); }
但是结果是新生成的jar中压根没有新加入的文件,但是文件确实copy到了指定的文件夹中,也就是谁两个命令都执行了,问题的关键就是“异步”,这时候需要waitfor()的介入
public void cmd(string cmd){ try { process ps= runtime.getruntime().exec(cmd); ps.waitfor(); } catch (exception e) { logger.info(e.getmessage(),e); } }
那么问题就解决了!
4、前不久遇到一个奇怪的问题就是ajax调用没有返回值
我在service中实现了process的调用。
string[] commands = { commandgenerate,commandpublish}; printwriter printwriter = response.getwriter(); for (string comm : commands) { runtime runtime = runtime.getruntime(); try { logger.info("command is :{}",comm); process process = runtime.exec(comm, null, null); bufferedinputstream inputstream = new bufferedinputstream( process.getinputstream()); bufferedreader bufferedreader = new bufferedreader( new inputstreamreader(inputstream)); string line; while (bufferedreader.read() != -1) { line = bufferedreader.readline(); system.out.println(line); } bufferedreader.close(); inputstream.close(); printwriter.println("success"); } catch (ioexception e) { logger.error(e.getmessage(), e); printwriter.println(e.getmessage()); } } printwriter.flush(); printwriter.close();
对应的controller为:
state state = new state(); string message=""; try { message = missionservice.syntax(taskname, response); } catch (interruptedexception e) { e.printstacktrace(); } state.setsuccess(true); state.setmessage(message.trim()); return state;
打印state.getmessage()确实可以获得值,但是state返回就是空,刚开始以为是ajax的timeout时间的问题:修改了ajax的timeout时间仍然不行;将message直接赋值,然thread等待20s,结果是可以返回的,所以问题最终定为于service的这段实现。
原因分析:在上面提及了,process创建的子进程没有自己的控制台或终端,其所有的io操作都是通过(输入流、输出流、错误流)重定向到父进程中,如果该可执行程序的输入、输出或者错误输出比较多的话,而由于运行窗口的标准输入、输出等缓冲区有大小的限制,则可能导致子进程阻塞,甚至产生死锁,其解决方法就是在waitfor()方法之前读出窗口的标准输出、输出、错误缓冲区中的内容。
for (string comm : commands) { logger.info("the comm time is:"+new date().gettime()+" the comm is:"+comm); runtime runtime = runtime.getruntime(); process p=null; try { p = runtime.exec(comm ,null,null); final inputstream is1 = p.getinputstream(); final inputstream is2 = p.geterrorstream(); new thread() { public void run() { bufferedreader br1 = new bufferedreader(new inputstreamreader(is1)); try { string line1 = null; while ((line1 = br1.readline()) != null) { if (line1 != null){ logger.info("p.getinputstream:"+line1); if(line1.indexof("syntax check result:")!=-1){ builder.append(line1); } } } } catch (ioexception e) { e.printstacktrace(); } finally{ try { is1.close(); } catch (ioexception e) { e.printstacktrace(); } } } }.start(); new thread() { public void run() { bufferedreader br2 = new bufferedreader(new inputstreamreader(is2)); try { string line2 = null ; while ((line2 = br2.readline()) != null ) { if (line2 != null){ } } } catch (ioexception e) { e.printstacktrace(); } finally{ try { is2.close(); } catch (ioexception e) { e.printstacktrace(); } } } }.start(); p.waitfor(); p.destroy(); } catch (exception e) { try{ p.geterrorstream().close(); p.getinputstream().close(); p.getoutputstream().close(); } catch(exception ee){} } }
java的process深入讲解
package cn.itcast.process; import java.io.bufferedreader; import java.io.ioexception; import java.io.inputstream; import java.io.inputstreamreader; import java.io.outputstream; public class processtest implements runnable{ private process process = null; public processtest() { try { process = runtime.getruntime().exec("java mytest"); new thread(this).start(); } catch (ioexception e) { e.printstacktrace(); } } public static void main(string[] args) { processtest processtest = new processtest(); processtest.send(); } public void send() { outputstream outputstream = process.getoutputstream(); while(true) { try { outputstream.write("this is good\r\n".getbytes()); } catch (ioexception e) { // todo auto-generated catch block e.printstacktrace(); } } } public void run() { inputstream inputstream = process.getinputstream(); bufferedreader bufferedreader = new bufferedreader(new inputstreamreader(inputstream)); string str = null; try { while(true) { str = bufferedreader.readline(); system.out.println(str); } } catch (ioexception e) { e.printstacktrace(); } } }
//理解下面这句话就能更加容易的理解上面的代码
在java程序中可以用process类的实例对象来表示子进程,子进程的标准输入和输出不在连接到键盘和显示器,而是以管道流的形式连接到父进程的
一个输出流和输入流对象上-à好好理解这句代码就能看懂那个程序。
以上为个人经验,希望能给大家一个参考,也希望大家多多支持。
推荐阅读
-
Java中数组操作 java.util.Arrays 类常用方法的使用
-
Java日期时间API系列11-----Jdk8中java.time包中的新的日期时间API类,使用java8日期时间API重写农历LunarDate
-
Linux中目录的创建与删除命令使用说明
-
举例说明Java多线程编程中读写锁的使用
-
Java的类与对象定义和使用
-
C#使用LINQ中Enumerable类方法的延迟与立即执行的控制
-
Java中的类、对象与继承
-
Java日期时间API系列30-----Jdk8中java.time包中的新的日期时间API类,减少时间精度方法性能比较和使用。
-
Java中stream处理中map与flatMap的比较和使用案例
-
java对集合中的某个类的属性按首字母分组排序(可直接使用)