中文日韩亚洲欧美制服_91麻豆国产免费观看_国产欧美精品一区二区三区-老狼_欧美黄色片网址

首頁 行業 活動 項目 快訊 文娛 時尚 娛樂 科技 汽車 綜合 生活

今日快訊:使用 ProcessBuilder API 優化你的流程

2023-06-14 09:17:37 來源:博客園
ProcessBuilder 介紹

Java 的 Process API 為開發者提供了執行操作系統命令的強大功能,但是某些 API 方法可能讓你有些疑惑,沒關系,這篇文章將詳細介紹如何使用 ProcessBuilder API 來方便的操作系統命令。

ProcessBuilder 入門示例

我們通過演示如何調用 java -version命令輸出 JDK 版本號,來演示 ProcessBuilder的入門用法。

package com.wdbyte.os.process;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import org.apache.commons.io.IOUtils;/** * Process 輸出Java 版本號 * @author https://www.wdbyte.com */public class ProcessBuilderTest1 {    public static void main(String[] args) throws IOException, InterruptedException {        // 構建執行命令        ProcessBuilder processBuilder = new ProcessBuilder("java","-version");        // 重定向 ERROR 流(有些 JDK 版本 Java 命令通過 ERROR 流輸出)        processBuilder.redirectErrorStream(true);        // 運行命令 java -version        Process process = processBuilder.start();        // 獲取PID,這是一個 Java 9 方法        long pid = process.pid();        // 一次性獲取運行結果        String result = IOUtils.toString(process.getInputStream());        // 等到運行結束        int exitCode = process.waitFor();        System.out.println("pid:" + pid);        System.out.println("result:" + result);        System.out.println("exitCode:" + exitCode);    }}

在這段代碼中,首先使用 ProcessBuilder 對象包裝了要執行的命令 java -version,緊接著重定向 了要執行的進程的 ERROR 輸出流(有些 JDK 版本 Java 命令通過 ERROR 流輸出)。最后通過 start方法執行命令,得到一個用于進程管理的 Process對象,可以獲取其 pid和輸出結果。


【資料圖】

注意 IOUtils.toString(process.getInputStream());

這里使用了 commons-io 中的工具類把 InputStream 轉為字符串。

commons-ioMaven 依賴:

    commons-io    commons-io    2.12.0

運行得到輸出:

pid:80885result:java version "1.8.0_151"Java(TM) SE Runtime Environment (build 1.8.0_151-b12)Java HotSpot(TM) 64-Bit Server VM (build 25.151-b12, mixed mode)exitCode:0
ProcessBuilder 環境變量

在下面這個示例中,演示如何獲取當前環境變量,以及如何修改環境變量并傳入子進程中。

輸出當前環境變量

ProcessBuilder processBuilder = new ProcessBuilder();Map environment = processBuilder.environment();environment.forEach((k, v) -> System.out.println(k + ":" + v));processBuilder.environment().put("my_website","www.wdbyte.com");

這會打印出當前所有環境變量。

JAVA_HOME:/Library/Java/JavaVirtualMachines/jdk1.8.0_151.jdk/Contents/HomeCOMMAND_MODE:unix2003JAVA_MAIN_CLASS_81717:com.wdbyte.os.process.ProcessBuilderTest2LOGNAME:darcy.....

添加一個環境變量

processBuilder.environment().put("my_website","www.wdbyte.com");

打印出剛才添加的環境變量

// Linux 或 MacOS 下 ,Windows 下無此命令processBuilder.command("/bin/bash", "-c", "echo $my_website");Process process = processBuilder.start();long pid = process.pid();String result = IOUtils.toString(process.getInputStream());int exitCode = process.waitFor();System.out.println("pid:" + pid);System.out.println("result:" + result);System.out.println("exitCode:" + exitCode);

這會輸出:

pid:81719result:www.wdbyte.comexitCode:0
ProcessBuilder 工作目錄

使用 directory方法可以修改子進程默認的工作目錄,下面的示例中修改進程工作目錄為 process文件夾。

package com.wdbyte.os.process;import java.io.File;import java.io.IOException;import org.apache.commons.io.IOUtils;/** * 修改工作目錄 * @author https://www.wdbyte.com */public class ProcessBuilderTest3 {    private static String BASE_DIR = "/Users/darcy/git/JavaNotes/core-java-modules/core-java-os/src/main/java/com/wdbyte/os/process";    public static void main(String[] args) throws IOException, InterruptedException {        ProcessBuilder processBuilder = new ProcessBuilder();        processBuilder.directory(new File(BASE_DIR));        // /bin/bash 命令只在 linux or macos 下有效        processBuilder.command("/bin/bash", "-c", "pwd");        Process process = processBuilder.start();        long pid = process.pid();        String result = IOUtils.toString(process.getInputStream());        int exitCode = process.waitFor();        System.out.println("pid:" + pid);        System.out.println("result:" + result);        System.out.println("exitCode:" + exitCode);    }}

輸出:

pid:82456result:/Users/darcy/git/JavaNotes/core-java-modules/core-java-os/src/main/java/com/wdbyte/os/processexitCode:0
ProcessBuilder I/O

在上面的示例中,都是把運行的新進程的輸出通過 getInputStream的方式讀取到當前進程,然后輸出,這種方式很不方便。日志輸出常見的方式是輸出到指定日志文件,ProcessBuilder對此也有很好的支持。

輸出到文件

使用 redirectOutput可以指定日志輸出的文件,這個方法會自動創建日志文件。下面的例子在指定目錄下執行 ls-l命令列出目錄下的所有文件。

package com.wdbyte.os.process;import java.io.File;import java.io.IOException;import java.nio.file.Files;/** * 輸出日志到指定文件 * @author https://www.wdbyte.com */public class ProcessBuilderTest4 {    private static String BASE_DIR = "/Users/darcy/git/JavaNotes/core-java-modules/core-java-os/src/main/java/com/wdbyte/os/process";    public static void main(String[] args) throws IOException, InterruptedException {        ProcessBuilder processBuilder = new ProcessBuilder();        processBuilder.directory(new File(BASE_DIR));        processBuilder.command("/bin/bash", "-c", "ls -l");        File logFile = new File(BASE_DIR + "/process_log.txt");        // 輸出到日志文件        processBuilder.redirectOutput(logFile);        // 追加日志到文件        // processBuilder.redirectOutput(ProcessBuilder.Redirect.appendTo(logFile));        // 是否輸出ERROR日志到文件        processBuilder.redirectErrorStream(true);        Process process = processBuilder.start();        long pid = process.pid();        int exitCode = process.waitFor();        System.out.println("pid:" + pid);        System.out.println("exitCode:" + exitCode);        // 讀取日志文件        Files.lines(logFile.toPath()).forEach(System.out::println);    }}

輸出日志:

pid:30609exitCode:0total 96-rw-r--r--  1 darcy  staff   749 Jun  6 22:34 ExecDemo.java-rw-r--r--  1 darcy  staff   445 Jun  7 14:59 ExecDemo2.java-rw-r--r--  1 darcy  staff  2011 Jun  7 15:33 ProcessBuilder10.java-rw-r--r--  1 darcy  staff  1807 Jun  6 22:54 ProcessBuilderTest1.java-rw-r--r--  1 darcy  staff  1054 Jun  6 23:01 ProcessBuilderTest2.java-rw-r--r--  1 darcy  staff   963 Jun  6 23:05 ProcessBuilderTest3.java-rw-r--r--  1 darcy  staff  1295 Jun  7 17:02 ProcessBuilderTest4.java-rw-r--r--  1 darcy  staff  1250 Jun  6 22:34 ProcessBuilderTest5.java-rw-r--r--  1 darcy  staff   929 Jun  6 22:34 ProcessBuilderTest6.java-rw-r--r--  1 darcy  staff   911 Jun  6 22:34 ProcessBuilderTest7.java-rw-r--r--  1 darcy  staff  1305 Jun  6 22:34 ProcessBuilderTest8.java-rw-r--r--  1 darcy  staff  1278 Jun  7 14:59 ProcessBuilderTest9.java-rw-r--r--  1 darcy  staff     0 Jun  7 17:03 process_log.txt

如果想要追加日志到指定文件,應該使用:

processBuilder.redirectOutput(ProcessBuilder.Redirect.appendTo(logFile));

使用 processBuilder也可以指定 INFOERROR日志到不同的文件。

ProcessBuilder processBuilder = new ProcessBuilder();processBuilder.directory(new File(BASE_DIR));// 執行命令 xxx,命令不存在,會報 ERROR 日志processBuilder.command("/bin/bash", "-c", "xxx");File infoLogFile = new File(BASE_DIR + "/process_log_info.txt");File errorLogFile = new File(BASE_DIR + "/process_log_error.txt");// 日志輸出到文件processBuilder.redirectOutput(infoLogFile);processBuilder.redirectError(errorLogFile);Process process = processBuilder.start();// 讀取 ERROR 日志Files.lines(errorLogFile.toPath()).forEach(System.out::println);

運行輸出:

/bin/bash: xxx: command not found
輸出到當前進程

在這個示例中,將看到 inheritIO()方法的作用。當我們想將子進程的 I/O 重定向到當前進程的標準 I/O 時,可以使用這個方法:

package com.wdbyte.os.process;import java.io.File;import java.io.IOException;/** * 子線程 I/O 重定向到當前線程 * @author https://www.wdbyte.com */public class ProcessBuilderTest6 {    public static void main(String[] args) throws IOException, InterruptedException {        ProcessBuilder processBuilder = new ProcessBuilder();        processBuilder.directory(new File("./"));        processBuilder.command("/bin/bash", "-c", "ls -l");        // 把子線程 I/O 輸出重定向當前進程        processBuilder.inheritIO();        Process process = processBuilder.start();        int exitCode = process.waitFor();        System.out.println("exitCode:" + exitCode);    }}

這會輸出:

total 2904-rw-r--r--   1 darcy  staff     5822 May  2 22:33 ArrayList.uml-rw-r--r--   1 darcy  staff    16555 May 16 16:07 README.md-rw-r--r--   1 darcy  staff      333 May  4 19:30 core-java-20.imldrwxr-xr-x  16 darcy  staff      512 Jun  2 22:03 core-java-modulesexitCode:0

在這個示例中,通過使用inheritIO()方法,我們在 IDE 的控制臺中看到了一個簡單命令結果的輸出。

ProcessBuilder 管道操作

從 Java 9 開始,ProcessBuilder 引入了管道概念,可以把一個進程的輸出作為另一個進程的輸入再次操作。

public static List startPipeline(List builders)

使用這個方法我們可以進行如這樣的常見操作:ls -l | wc -l

ls -l | wc -l:列出文件目錄,然后統計輸出的行數。

下面演示如何使用 startPipeline.

package com.wdbyte.os.process;import java.io.File;import java.io.IOException;import java.lang.ProcessBuilder.Redirect;import java.nio.file.Files;import java.util.Arrays;import java.util.List;/** * Java 9 中新增的管道操作 * @author https://www.wdbyte.com */public class ProcessBuilderTest8 {    private static String BASE_DIR = "/Users/darcy/git/JavaNotes/core-java-modules/core-java-os/src/main/java/com/wdbyte/os/process";    public static void main(String[] args) throws IOException, InterruptedException {        ProcessBuilder ls = new ProcessBuilder("/bin/bash", "-c", "ls -l");        ProcessBuilder wc = new ProcessBuilder("wc", "-l");        // 追加日志到文件        File pipeLineLogFile = getFile(BASE_DIR + "/pipe_line_log.txt");        wc.redirectOutput(Redirect.appendTo(pipeLineLogFile));        List processes = ProcessBuilder.startPipeline(Arrays.asList(ls, wc));        Process process = processes.get(processes.size() - 1);        System.out.println("pid:" + process.pid());        System.out.println("exitCode:" + process.waitFor());        Files.lines(pipeLineLogFile.toPath()).forEach(System.out::println);    }    public static File getFile(String filePath) throws IOException {        File logFile = new File(filePath);        if (!logFile.exists()) {            logFile.createNewFile();        }        return logFile;    }}

這會輸出:

pid:33518exitCode:0      21
ProcessBuilder 超時與終止

進程有時不能按照自己想要的情況運行,需要對進程進行管理,常見的操作是超時控制以及進程退出。下面通過一個例子來演示如何操作。

先編譯一個用于測試的 Java 類 ExecDemo.java,此類每隔一秒輸出一個數字,共輸出10個數字,預計需要10s輸出完畢。

下面是代碼部分:

import java.io.IOException;/** * @author https://www.wdbyte.com */public class ExecDemo {    public static void main(String[] args) throws InterruptedException {        System.out.println("開始處理數據...");        for (int i = 0; i < 10; i++) {            Thread.sleep(1000);            System.out.println(i);        }        System.out.println("數據處理完畢");    }}

再編寫一個 ProcessBuilder來執行 ExceDemo,但是在執行 3 秒后就判斷是否運行完成,如果沒有則殺死進程。

package com.wdbyte.os.process;import java.io.File;import java.io.IOException;import java.util.concurrent.TimeUnit;/** * 運行一個 Java 程序 * 等待一定時間后檢查狀態,未結束則直接殺死進程。 * * @author https://www.wdbyte.com */public class ProcessBuilderTest9 {    private static String BASE_DIR = "/Users/darcy/git/JavaNotes/core-java-modules/core-java-os/src/main/java/com/wdbyte/os/process";    public static void main(String[] args) throws IOException, InterruptedException {        ProcessBuilder processBuilder = new ProcessBuilder();        processBuilder.directory(new File(BASE_DIR));        processBuilder.command("java", "ExecDemo.java");        // 把子線程 I/O 輸出重定向當前進程        processBuilder.inheritIO();        Process process = processBuilder.start();        // 等待一定時間        boolean waitFor = process.waitFor(3, TimeUnit.SECONDS);        System.out.println("waitFor:" + waitFor);        // 若未退出,殺死子進程        if (!waitFor) {            process.destroyForcibly();            process.waitFor();            System.out.println("殺死進程:" + process);        }    }}

這會輸出:

開始處理數據...01waitFor:false殺死進程:Process[pid=35084, exitValue=137]

在這段代碼中,destroyForcibly()用于殺死進程,但是殺死進程并不是瞬間完成的,所以接著使用 waitFor()來等待程序真正被殺死退出。

ProcessBuilder 異步處理

很多情況下,在執行一個命令啟動一個新線程后,我們不想阻塞等待進程的完成,想要異步化,在進程執行完成后進行通知回調。這時可以使用 CompletableFuture來實現這個功能。

package com.wdbyte.os.process;import java.io.File;import java.io.IOException;import java.util.concurrent.CompletableFuture;/** * @author https://www.wdbyte.com */public class ProcessBuilderTest10 {    private static String BASE_DIR = "/Users/darcy/git/JavaNotes/core-java-modules/core-java-os/src/main/java/com/wdbyte/os/process";    public static void main(String[] args) throws InterruptedException {        ProcessBuilder processBuilder = new ProcessBuilder();        processBuilder.directory(new File(BASE_DIR));        processBuilder.command("java", "ExecDemo.java");        // 把子線程 I/O 輸出重定向當前進程        processBuilder.inheritIO();        // 創建 CompletableFuture 對象        CompletableFuture future = CompletableFuture.supplyAsync(() -> {            try {                // 命令執行                Process process = processBuilder.start();                // 任務超時時間                process.waitFor();            } catch (IOException e) {                throw new RuntimeException(e);            } catch (InterruptedException e) {                throw new RuntimeException(e);            }            return null;        });        // 注冊回調函數,處理異步等待的結果        future.thenAccept(result -> {            System.out.println("進程執行結束");        });        System.out.println("主進程等待");        Thread.sleep(20 * 1000);    }}

這會輸出:

主進程等待開始處理數據...0123456789數據處理完畢進程執行結束
ProcessBuilder 總結

在這篇文章中,我們詳細介紹了 ProcessBuilder 的具體用法,并且給出了常用的操作示例。同時也介紹了 Java 9 開始為 ProcessBuilder 引入的管道操作,最后介紹如何對 Process 進程進行異步處理。

一如既往,文章中代碼存放在 Github.com/niumoo/javaNotes.

本文原發于網站:https://www.wdbyte.com/java/os/processbuilder/我的公眾號:ProcessBuilder API 使用教程

關鍵詞:

上一篇:世界播報:中建五局安裝公司工會舉辦公益培訓

下一篇:售價9.49萬元起 2024款雪佛蘭科魯澤上市

責任編輯:

最近更新

點擊排行
推薦閱讀

中文日韩亚洲欧美制服_91麻豆国产免费观看_国产欧美精品一区二区三区-老狼_欧美黄色片网址

    亚洲777理论| 国产精品亚洲一区二区三区妖精 | 亚洲欧美在线视频| 日韩成人一级片| 91丨九色丨蝌蚪富婆spa| 亚洲精品一二三| 欧美一区二区成人6969| 亚洲视频一区在线| 国产麻豆9l精品三级站| 国产精品成人免费在线| 欧美日韩国产成人在线免费| 国产精品伦理在线| 精品一区二区三区在线观看| 欧美国产成人精品| 欧美性猛交一区二区三区精品| 日本一区二区三区高清不卡| 黄色资源网久久资源365| 国产精品午夜免费| 欧美日韩二区三区| 亚洲精品国产精华液| 成人午夜免费电影| 亚洲一二三四久久| 久久久久国产一区二区三区四区| 日产国产欧美视频一区精品| 久久精品人人爽人人爽| 欧美日韩中字一区| 亚洲视频每日更新| 成人国产精品免费| 午夜精品在线视频一区| 国产精品少妇自拍| 国产精品一区二区在线看| 亚洲欧美偷拍卡通变态| 亚洲精品一区二区三区99| 日韩va亚洲va欧美va久久| 欧美高清在线视频| 日韩一区二区在线播放| 视频一区二区三区入口| 国产蜜臀av在线一区二区三区| 欧美日韩免费一区二区三区| 亚洲综合在线视频| 99久久精品久久久久久清纯| 91黄色在线观看| 亚洲日本乱码在线观看| 99九九99九九九视频精品| 在线观看国产一区二区| 一区二区三区免费观看| 久久亚洲精品小早川怜子| 欧美日韩精品综合在线| 亚洲国产精品久久一线不卡| 欧美国产日韩一二三区| 日韩精品一区二区三区在线观看 | 色婷婷久久99综合精品jk白丝| 国产精品久久久久国产精品日日| 成人免费av资源| 欧美午夜在线一二页| 亚洲午夜在线视频| 亚洲国产精品成人综合| 精品国产乱码久久久久久闺蜜| 久久国产剧场电影| 亚洲午夜激情网页| 亚洲免费资源在线播放| 91网站视频在线观看| 欧美二区在线观看| 美腿丝袜在线亚洲一区| 亚洲综合男人的天堂| 亚洲欧洲日产国码二区| 久久你懂得1024| 日韩精品一区二区三区中文精品| 国产一区二区福利| 在线观看国产91| 天堂蜜桃一区二区三区| 亚洲美女淫视频| 日韩理论片网站| 国产欧美一区二区精品忘忧草 | av一区二区三区| 制服丝袜在线91| 狠狠色丁香婷综合久久| 色婷婷国产精品| 日韩专区欧美专区| 亚洲成人你懂的| 亚洲成人你懂的| 亚洲精品少妇30p| 悠悠色在线精品| 日韩毛片视频在线看| 中文字幕亚洲不卡| 国产精品毛片久久久久久久| 欧美国产丝袜视频| 国产午夜精品一区二区三区四区| 久久影院视频免费| 99久久国产综合精品麻豆| 日韩免费观看高清完整版| 福利电影一区二区| 欧美一级生活片| 高清不卡在线观看| 日韩欧美一级精品久久| 成人免费高清在线观看| 精品剧情在线观看| 99精品视频在线观看| 精品福利一区二区三区免费视频| 成人av电影在线网| 久久综合色婷婷| 久久综合色8888| 国产日韩欧美制服另类| 国产丝袜美腿一区二区三区| 亚洲国产精品传媒在线观看| 欧美国产日产图区| 亚洲日本青草视频在线怡红院| 亚洲人成精品久久久久久| 一区二区激情视频| 亚洲影视在线播放| 日韩中文字幕麻豆| 欧洲一区在线观看| 国产一区二区三区在线观看精品 | 无吗不卡中文字幕| 五月开心婷婷久久| 久久国产三级精品| 欧美一级视频精品观看| 97成人超碰视| 国产精品久久久久四虎| 亚洲天堂av老司机| 午夜成人免费电影| 欧美性高清videossexo| 国产精品538一区二区在线| 精品区一区二区| 国产亚洲一二三区| 亚洲欧美成人一区二区三区| 亚洲第一在线综合网站| 激情国产一区二区| 精品少妇一区二区三区| 国产日韩精品一区二区浪潮av | 中文字幕不卡一区| 亚洲欧美国产77777| 视频一区欧美精品| 欧美女孩性生活视频| 99久久99久久精品免费观看| 国产精品久久久久9999吃药| 亚洲一二三四区| 国产精品综合网| 国产日韩欧美精品一区| 亚洲精品国产精华液| 美女网站在线免费欧美精品| 欧美一级二级在线观看| 久久精品一区二区三区不卡牛牛| 亚洲精品ww久久久久久p站| 亚洲一二三四在线观看| 国产一区二区三区在线看麻豆| 久久蜜臀中文字幕| 亚洲女同女同女同女同女同69| 免费在线观看成人| 欧美刺激脚交jootjob| 国产免费久久精品| 日日夜夜精品视频免费| 6080午夜不卡| 国产欧美日韩在线看| 无码av免费一区二区三区试看| 欧美精品日韩一区| 国产女人18水真多18精品一级做| 视频一区二区三区在线| 精品欧美乱码久久久久久1区2区| 国产精品毛片大码女人| 日韩电影在线免费看| 精品国产三级a在线观看| 亚洲人成小说网站色在线| 国内精品久久久久影院一蜜桃| 久久久久国产精品免费免费搜索| 一区二区三区国产| 国产精品99久久久久| 日韩一区有码在线| 欧美日韩三级在线| 久久久久9999亚洲精品| 日精品一区二区| 久久久久久久国产精品影院| 亚洲国产精品久久人人爱| 国产二区国产一区在线观看| 国产精品久久毛片a| 欧洲av一区二区嗯嗯嗯啊| 国产视频一区二区在线| 久久国产成人午夜av影院| 中文成人av在线| 欧美最猛黑人xxxxx猛交| 久久久久久久综合色一本| 人人狠狠综合久久亚洲| 国产视频亚洲色图| 色欧美88888久久久久久影院| 久久久无码精品亚洲日韩按摩| 日日噜噜夜夜狠狠视频欧美人| 久久久99精品免费观看不卡| 色综合天天视频在线观看| 久久精品在线免费观看| 久久精品国产精品亚洲综合| 国产精品久久久久久久久免费樱桃| 欧美午夜精品一区| 亚洲欧洲av一区二区三区久久| 国产精品伊人色| 亚洲一区在线播放| www国产成人| 欧美亚洲国产怡红院影院| 国产精品久久久久久久久图文区 | 久久成人羞羞网站| 日韩毛片一二三区|