Выполнение исполняемой командной строки из Java

В этом посте мы рассмотрим общую потребность разработчиков Java. Выполнять и управлять внешним процессом изнутри Java. Поскольку эта задача довольно распространена, мы решили найти библиотеку Java, которая поможет нам в этом.

Требования от такой библиотеки:

Выполните процесс асинхронно.
Возможность прервать выполнение процесса.
Возможность дождаться завершения процесса.
На выходе процесса уведомления.
Возможность убить процесс в случае зависания.
Получить код завершения процесса.

Родной JDK мало чем помогает. К счастью, у нас есть Apache Commons Exec . На самом деле все гораздо проще, но все же не так просто, как мы надеялись. Мы написали небольшую обертку сверху.

Вот подпись метода, которую мы выставляем:

1: public static Future<Long> runProcess(final CommandLine commandline, final ProcessExecutorHandler handler, final long watchdogTimeout) throws IOException;

Возвращает будущее <Long>. Это охватывает раздел 1,2,3,6.
Экземпляр ProcessExecutorHandler передается в функцию. Этот экземпляр на самом деле является слушателем любого вывода процесса. Это покрывает раздел 4 в нашем требовании.
Последнее, но не менее важное, вы предоставляете тайм-аут. Если выполнение процесса занимает больше времени, чем указано, вы предполагаете, что процесс завис, и завершите его. В этом случае код ошибки, возвращаемый процессом, будет -999.

Это оно! Вот метод имплантации. Наслаждаться.

import org.apache.commons.exec.*;
 
 import org.apache.commons.exec.Executor;
 
 import java.io.IOException;
 
 import java.util.concurrent.*;
 
 public class ProcessExecutor {
 
     public static final Long  WATCHDOG_EXIST_VALUE = -999L;
 
     public static Future<Long> runProcess(final CommandLine commandline, final ProcessExecutorHandler handler, final long watchdogTimeout) throws IOException{
 
      ExecutorService executor = Executors.newSingleThreadExecutor();
 
      return executor.submit(new ProcessCallable(watchdogTimeout, handler, commandline));
 
    }
 
    private static class ProcessCallable implements Callable<Long>{
 
        private long watchdogTimeout;
 
        private ProcessExecutorHandler handler;
 
        private CommandLine commandline;
 
        private ProcessCallable(long watchdogTimeout, ProcessExecutorHandler handler, CommandLine commandline) {
 
       this.watchdogTimeout = watchdogTimeout;
 
       this.handler = handler;
 
       this.commandline = commandline;
 
   }
 
   @Override
 
   public Long call() throws Exception {
 
       Executor executor = new DefaultExecutor();
 
       executor.setProcessDestroyer(new ShutdownHookProcessDestroyer());
 
       ExecuteWatchdog watchDog = new ExecuteWatchdog(watchdogTimeout);
 
             executor.setWatchdog(watchDog);
 
             executor.setStreamHandler(new PumpStreamHandler(new MyLogOutputStream(handler, true),new MyLogOutputStream(handler, false)));
 
          Long exitValue;
 
          try {
 
              exitValue =  new Long(executor.execute(commandline));
 
          } catch (ExecuteException e) {
 
              exitValue =  new Long(e.getExitValue());
 
          }
 
          if(watchDog.killedProcess()){
 
              exitValue =WATCHDOG_EXIST_VALUE;
 
          }
 
           return exitValue;
 
       }
 
  }
 
  private static class MyLogOutputStream extends  LogOutputStream{
 
      private ProcessExecutorHandler handler;
 
      private boolean forewordToStandardOutput;
 
      private MyLogOutputStream(ProcessExecutorHandler handler, boolean forewordToStandardOutput) {
 
              this.handler = handler;
 
              this.forewordToStandardOutput = forewordToStandardOutput;
 
          }
 
          @Override
 
          protected void processLine(String line, int level) {
 
              if (forewordToStandardOutput){
 
                  handler.onStandardOutput(line);
 
            }
 
            else{
 
                handler.onStandardError(line);
 
            }
 
        }
 
    }
 
    public static void main(String[] args) throws IOException {
 
        CommandLine cl = CommandLine.parse("test.bat");
 
        Future<Long> exitValue = runProcess(cl, new ProcessExecutorHandler() {
 
            @Override
 
            public void onStandardOutput(String msg) {
 
                System.out.println("output msg = " + msg);
 
            }
 
            @Override
 
            public void onStandardError(String msg) {
 
                System.out.println("error msg = " + msg);
 
            }
 
        }, 1);
 
        try {
 
            Long aVoid = exitValue.get();
 
            System.out.println("Finished with  " + aVoid);
 
        } catch (InterruptedException e) {
 
            e.printStackTrace();  //To change body of catch statement use File | ngs | File Templates.
 
        } catch (ExecutionException e) {
 
            e.printStackTrace();  //To change body of catch statement use File | ngs | File Templates.
 
        }
 
    }
 
}

Ссылка: Выполнение исполняемой командной строки из Java от нашего партнера по JCG Надава Азарии в блоге DeveloperLife .

Выполнение исполняемой командной строки из Java

Категории

Последние статьи

Рефакторинг Hudson God Class

Альтернативы синтаксиса Java лямбда

Morphia и MongoDB: развивающиеся структуры документов

OpenShift Express: развертывание приложения Java EE (с поддержкой AS7)

Интеграция jqGrid, REST, AJAX и Spring MVC