最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Java中Process類的使用與注意事項說明

 更新時間:2021年12月14日 09:45:17   作者:Kevin.Yang  
這篇文章主要介紹了Java中Process類的使用與注意事項說明,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教

Process類的使用與注意事項說明

1、在項目開發(fā)中

經常會遇到調用其它程序功能的業(yè)務需求,在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類提供獲取子進程的輸入流、子進程的輸出流、子進程的錯誤流、等待進程完成、檢查進程的推出狀態(tài)以及銷毀進程的方法;在這里需要提及的是創(chuàng)建的子進程沒有自己的控制臺或終端,其所有的io操作都是通過(輸入流、輸出流、錯誤流)重定向到父進程中。

3、來說說今天業(yè)務需求[waitfor()]:

我需要在linux下首先將一個文件copy到指定的文件夾下面,之后需要將該文件夾下面的文件加入指定的jar中,那么問題就來了,必須保證其先后順序,也就書說再執(zhí)行第二個命令的時候第一個命令必須完成。

    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到了指定的文件夾中,也就是誰兩個命令都執(zhí)行了,問題的關鍵就是“異步”,這時候需要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創(chuàng)建的子進程沒有自己的控制臺或終端,其所有的io操作都是通過(輸入流、輸出流、錯誤流)重定向到父進程中,如果該可執(zhí)行程序的輸入、輸出或者錯誤輸出比較多的話,而由于運行窗口的標準輸入、輸出等緩沖區(qū)有大小的限制,則可能導致子進程阻塞,甚至產生死鎖,其解決方法就是在waitfor()方法之前讀出窗口的標準輸出、輸出、錯誤緩沖區(qū)中的內容。

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對象中使用?static?和?String?基礎探究

    JAVA對象中使用?static?和?String?基礎探究

    這篇文章主要介紹了JAVA對象中使用static和String基礎探究,文章圍繞主題展開詳細的內容介紹,具有一定的參考價值,需要的小伙伴可以參考一下
    2022-09-09
  • Springboot?返回文件給前端的示例代碼

    Springboot?返回文件給前端的示例代碼

    這篇文章主要介紹了Springboot?返回文件給前端的示例代碼,本文結合示例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2023-07-07
  • 探索Java中的IP屬地獲取技術

    探索Java中的IP屬地獲取技術

    這篇文章主要為大家介紹了Java中的IP屬地獲取的技術探索,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-10-10
  • Spring中Transactional注解使用的心得(推薦)

    Spring中Transactional注解使用的心得(推薦)

    這篇文章主要介紹了Spring中Transactional注解使用的心得,事務是用來控制數據的ACID特性的,用于保證數據的正確性和完整性,需要的朋友可以參考下
    2022-10-10
  • Mybatis -如何處理clob類型數據

    Mybatis -如何處理clob類型數據

    這篇文章主要介紹了Mybatis 如何處理clob類型數據的操作,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-06-06
  • hibernate查詢緩存詳細分析

    hibernate查詢緩存詳細分析

    這篇文章主要介紹了hibernate查詢緩存詳細分析,包括查詢緩存配置方法及關閉二級緩存的詳細介紹,需要的朋友參考下本文吧
    2017-09-09
  • 詳解SpringBoot?統(tǒng)一后端返回格式的方法

    詳解SpringBoot?統(tǒng)一后端返回格式的方法

    今天我們來聊一聊在基于SpringBoot前后端分離開發(fā)模式下,如何友好的返回統(tǒng)一的標準格式以及如何優(yōu)雅的處理全局異常,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友參考下吧
    2022-05-05
  • Mybatis-Plus自動生成代碼的實現示例

    Mybatis-Plus自動生成代碼的實現示例

    在工作中,程序員很多時候都是在寫類似的代碼,可以使用自動生成代碼,本文主要介紹了Mybatis-Plus自動生成代碼的實現示例,具有一定的參考價值,感興趣的可以了解一下
    2023-11-11
  • java去除字符串中的空格、回車、換行符、制表符的小例子

    java去除字符串中的空格、回車、換行符、制表符的小例子

    java去除字符串中的空格、回車、換行符、制表符的小例子,需要的朋友可以參考一下
    2013-06-06
  • 你真的懂java的日志系統(tǒng)嗎

    你真的懂java的日志系統(tǒng)嗎

    日志管理的第一件事,就是日志的收集,日志收集是開發(fā)者必備的技巧,不管是哪個開發(fā)語言,哪個開發(fā)平臺,日志收集的插件都是有很多選擇的,下面這篇文章主要給大家介紹了關于java日志系統(tǒng)的相關資料,需要的朋友可以參考下
    2022-02-02

最新評論

琼结县| 即墨市| 沂水县| 湘潭市| 邢台县| 和静县| 长海县| 西城区| 高碑店市| 泰安市| 专栏| 绥中县| 鄂伦春自治旗| 金湖县| 栖霞市| 祁东县| 大新县| 屯昌县| 无锡市| 皋兰县| 同仁县| 定边县| 小金县| 兰考县| 乌拉特后旗| 南宫市| 夹江县| 曲水县| 云梦县| 墨玉县| 宜春市| 沙田区| 惠来县| 新巴尔虎左旗| 宿松县| 黎川县| 龙川县| 三江| 株洲市| 大安市| 剑川县|