apache进程框架commons-exec，Java

r囧r小猫 2023-09-27 11:46 132阅读 0赞

## apache进程框架commons-exec，Java ##

pom.xml引用：

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

import org.apache.commons.exec.*;
    
    import java.io.ByteArrayOutputStream;
    import java.io.File;
    import java.io.IOException;
    import java.util.Map;
    
    public class Main {
        private static long processId = -1;
    
        public static void main(String[] args) {
            //无止境ping，但会再下面被ExecuteWatchdog设置的超时值终止进程而中断
            CommandLine commandLine = CommandLine.parse("ping 127.0.0.1 -t");
    
            DefaultExecutor executor = new DefaultExecutor() {
                @Override
                protected Process launch(CommandLine command, Map<String, String> env, File dir) throws IOException {
                    Process process = super.launch(command, env, dir);
                    processId = process.pid();
                    System.out.println("进程id=" + processId);
                    return process;
                }
            };
            executor.setExitValues(null);
    
            //如果进程运行时间超过timeOut毫秒，进程就自动结束（销毁）
            long timeOut = 5000;
            ExecuteWatchdog watchdog = new ExecuteWatchdog(timeOut);
            executor.setWatchdog(watchdog);
    
            final ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
            final ByteArrayOutputStream errorStream = new ByteArrayOutputStream();
    
            PumpStreamHandler streamHandler = new PumpStreamHandler(outputStream, errorStream);
            executor.setStreamHandler(streamHandler);
    
            ExecuteResultHandler erh = new ExecuteResultHandler() {
                @Override
                public void onProcessComplete(int exitValue) {
                    // exitValue 0 表示进程任务正常完成后结束退出。
                    // exitValue非0值表示异常结束进程。
                    System.out.println("exitValue:" + exitValue);
    
                    try {
                        String os = outputStream.toString("GBK");
                        System.out.println("onProcessComplete:" + os);
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
    
                @Override
                public void onProcessFailed(ExecuteException e) {
                    e.printStackTrace();
    
                    try {
                        String es = errorStream.toString("GBK");
                        System.out.println("onProcessFailed:" + es);
                    } catch (Exception ee) {
                        ee.printStackTrace();
                    }
                }
            };
    
            try {
                executor.execute(commandLine, erh);
            } catch (Exception e) {
                e.printStackTrace();
            }
    
            System.out.println("end");
        }
    }

输出：

> end  
> 进程id=27652  
> exitValue:1  
> onProcessComplete:  
> 正在 Ping 127.0.0.1 具有 32 字节的数据:  
> 来自 127.0.0.1 的回复: 字节=32 时间<1ms TTL=200  
> 来自 127.0.0.1 的回复: 字节=32 时间<1ms TTL=200  
> 来自 127.0.0.1 的回复: 字节=32 时间<1ms TTL=200  
> 来自 127.0.0.1 的回复: 字节=32 时间<1ms TTL=200  
> 来自 127.0.0.1 的回复: 字节=32 时间<1ms TTL=200