欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Java中Process类的使用与注意事项说明

程序员文章站 2022-06-16 22:04:29
目录process类的使用与注意事项说明1、在项目开发中2、在这里就需要认识一下process类3、来说说今天业务需求[waitfor()]:4、前不久遇到一个奇怪的问题就是ajax调用没有返回值ja...

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 Process类