• 官網(wǎng)： Apache Commons Exec ?

<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-exec</artifactId>
    <version>1.3</version>
</dependency>

• 作用：在java程序中開(kāi)啟進(jìn)程執(zhí)行外部程序。

• 使用舉例：

  • 1.在java程序中開(kāi)啟打印機(jī)程序打印文件。
  • 2.在java程序中執(zhí)行外部腳本程序。

• java支持：
  java提供了Runtime.exec() API來(lái)調(diào)用外部程序，Apache Commons Exec只是對(duì)其進(jìn)行了封裝。

• 優(yōu)點(diǎn)：（提供了對(duì)開(kāi)啟進(jìn)程的管理）

• 提供watchdog（看門狗）關(guān)閉掛起的進(jìn)程。（比如打印機(jī)程序缺少紙，但是程序會(huì)處于阻塞狀態(tài)無(wú)法結(jié)束）

• 通過(guò)ExecuteResultHandler提供了異步執(zhí)行外部程序的能力。默認(rèn)是同步。

• 使用更方便。

• 參考案例：Java執(zhí)行外部程序(Apache Commons Exec)

我的案例：

• 在程序中執(zhí)行本來(lái)通過(guò)run.bat腳本執(zhí)行的內(nèi)容。
  在run.bat中的內(nèi)容：

spark-submit   --class "SimpleApp"   --master local[4]   D:/study/sparkstudy/simple-project/target/simple-project-1.0.jar

• 通過(guò)程序完成run.bat腳本的內(nèi)容
• 第一種：

                    String line = "spark-submit.cmd   --class \"SimpleApp\"   --master local[4]  D:\\study\\sparkstudy\\simple-project\\target\\simple-project-1.0.jar";
                   
                     CommandLine cmdLine =   CommandLine.parse(line);
                     DefaultExecutor executor = new DefaultExecutor();
                     executor.setExitValues(null);
                     ExecuteWatchdog watchdog = new ExecuteWatchdog(60000);
                     executor.setWatchdog(watchdog);

                     ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
                     ByteArrayOutputStream errorStream = new ByteArrayOutputStream();
                     PumpStreamHandler streamHandler = new PumpStreamHandler(outputStream,errorStream);

                     executor.setStreamHandler(streamHandler);
                     executor.execute(cmdLine);
                     String out = outputStream.toString("gbk");//獲取程序外部程序執(zhí)行結(jié)果
                     String error = errorStream.toString("gbk");

第二種：

                     File file = new File("D:\\study\\sparkstudy\\simple-project\\target\\simple-project-1.0.jar");
                     Map map = new HashMap();
                     map.put("FILE", file);
                     CommandLine cmdLine =  new CommandLine("spark-submit.cmd");
                     cmdLine.addArgument("--class");
                     cmdLine.addArgument("\"SimpleApp\"");
                     cmdLine.addArgument("--master");
                     cmdLine.addArgument("local[4]");
                     cmdLine.addArgument("${FILE}");
                     cmdLine.setSubstitutionMap(map);

                     DefaultExecutor executor = new DefaultExecutor();
                     executor.setExitValues(null);
                     ExecuteWatchdog watchdog = new ExecuteWatchdog(60000);
                     executor.setWatchdog(watchdog);

                     ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
                     ByteArrayOutputStream errorStream = new ByteArrayOutputStream();
                     PumpStreamHandler streamHandler = new PumpStreamHandler(outputStream,errorStream);
                     executor.setStreamHandler(streamHandler);
                     executor.execute(cmdLine);
                     String out = outputStream.toString("gbk");//獲取程序外部程序執(zhí)行結(jié)果
                     String error = errorStream.toString("gbk");

• 擴(kuò)展：Java進(jìn)程Runtime、Process、ProcessBuilder調(diào)用外部程序