apache进程框架commons-exec，Java

Posted 2023-01-06 zhangphil

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