Apache commons exec 簡介和簡單ping命令方法調用實現

pooi 9年前發布 | 8K 次閱讀 Java

Apache commonsexec提供一些常用的方法用來執行外部進程。Apache commons exec庫提供了監視狗Watchdog來設監視進程的執行超時,同時也還實現了同步和異步功能。

Apache commonsexec涉及到多線程,比如新啟動一個進程,Java中需要再開三個線程來處理進程的三個數據流,分別是標準輸入,標準輸出和錯誤輸出。

需要使用該功能需要引入commons-exec-1.3.jar包,目前最新的版本為1.3版本。

 

在日常工作和生活中,我們經常需要用到網絡,網絡有時候會出現不穩定的情況,這個時候我們可以用ping命令查看網絡情況,如果需要自動化檢測網絡,那么下面這個例子可以參考。

packagetest.ffm83.commons.exec;



importorg.apache.commons.exec.CommandLine;

importorg.apache.commons.exec.DefaultExecutor;

importorg.apache.commons.exec.PumpStreamHandler;

importorg.apache.commons.io.output.ByteArrayOutputStream;

/**

 * 通過commons exec啟動ping命令來查看網絡情況

 * @author 范芳銘

 */

public classEasyExecPing {

         public static void main(String[] args){

                   EasyExecPing exec = newEasyExecPing();

                   exec.ping("127.0.0.1");

         }



         public void ping(String ip) {

                   String command = "ping" + ip;

                   try {

                            ByteArrayOutputStreamoutputStream = new ByteArrayOutputStream();

                            ByteArrayOutputStreamerrorStream = new ByteArrayOutputStream();



                            //命令行處理

                            CommandLinecommandline = CommandLine.parse(command);

                            //進行執行體

                            DefaultExecutor exec= new DefaultExecutor();



                            exec.setExitValues(null);



                            PumpStreamHandlerstreamHandler = new PumpStreamHandler(

                                               outputStream,errorStream);



                            exec.setStreamHandler(streamHandler);

                            exec.execute(commandline);//執行



                            String out =outputStream.toString("gbk");

                            String error =errorStream.toString("gbk");



                            System.out.println(out);

                            System.err.println(error);

                   } catch (Exception e) {

                            e.printStackTrace();

                   }



         }

}


運行情況如下:

正在 Ping 127.0.0.1 具有 32 字節的數據:

來自 127.0.0.1 的回復: 字節=32 時間<1msTTL=64

來自 127.0.0.1 的回復: 字節=32 時間<1msTTL=64

來自 127.0.0.1 的回復: 字節=32 時間<1msTTL=64

來自 127.0.0.1 的回復: 字節=32 時間<1msTTL=64

 

127.0.0.1 的 Ping 統計信息:

    數據包: 已發送 = 4,已接收 = 4,丟失 = 0 (0% 丟失),

往返行程的估計時間(以毫秒為單位):

    最短 = 0ms,最長 = 0ms,平均 = 0ms

 

結果非常不錯。但是ping命令還有其他寫法,比如ping 127.0.0.1 –t  ,這個表示一直查看。加到我們的程序中試一下。

我泡了一杯茶,看了下,程序還在執行;

召集了一次項目例會,會開完了,程序還在執行;

看下時間,從開始運行到現在已經過去了3小時。

一不小心就搞出了死循環了,趕緊想辦法吧。

 

開頭的地方提到,有監視狗Watchdog可以控制超時,我們試一下吧。

加入監控狗的ping代碼:

packagetest.ffm83.commons.exec;



importorg.apache.commons.exec.CommandLine;

importorg.apache.commons.exec.DefaultExecutor;

importorg.apache.commons.exec.ExecuteWatchdog;

importorg.apache.commons.exec.PumpStreamHandler;

importorg.apache.commons.io.output.ByteArrayOutputStream;

/**

 * 通過commons exec啟動ping命令來查看網絡情況

 * @author 范芳銘

 */

public classEasyExecPing {

         public static void main(String[] args){

                   EasyExecPing exec = newEasyExecPing();

                   exec.ping("127.0.0.1-t");

         }



         public void ping(String ip) {

                   String command = "ping" + ip;

                   try {

                            ByteArrayOutputStreamoutputStream = new ByteArrayOutputStream();

                            ByteArrayOutputStreamerrorStream = new ByteArrayOutputStream();



                            //命令行處理

                            CommandLinecommandline = CommandLine.parse(command);

                            //進行執行體

                            DefaultExecutor exec= new DefaultExecutor();



                            exec.setExitValues(null);

                            //利用監視狗來設置超時

                            ExecuteWatchdogwatchdog = new ExecuteWatchdog(60000);

                            exec.setWatchdog(watchdog);



                            PumpStreamHandlerstreamHandler = new PumpStreamHandler(

                                               outputStream,errorStream);



                            exec.setStreamHandler(streamHandler);

                            exec.execute(commandline);//執行



                            String out =outputStream.toString("gbk");

                            String error =errorStream.toString("gbk");



                            System.out.println(out);

                            System.err.println(error);

                   } catch (Exception e) {

                            e.printStackTrace();

                   }



         }

}


運行結果如下:

正在 Ping 127.0.0.1 具有 32 字節的數據:

來自 127.0.0.1 的回復: 字節=32 時間<1msTTL=64

來自 127.0.0.1 的回復: 字節=32 時間<1msTTL=64

來自 127.0.0.1 的回復: 字節=32 時間<1msTTL=64

來自 127.0.0.1 的回復: 字節=32 時間<1msTTL=64

……

 本文由用戶 pooi 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
 轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
 本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!