测试python调用

demo-client/byit-demo-client/src/main/java/com/byit/job/TestPy.java

@@ -5,29 +5,46 @@ import org.apache.commons.exec.DefaultExecutor;
 import org.apache.commons.exec.ExecuteWatchdog;
 import org.apache.commons.exec.PumpStreamHandler;
 
-import java.io.*;
-import java.nio.charset.Charset;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
 import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.List;
 
 public class TestPy {
 
     public static void main(String[] args) throws IOException, InterruptedException {
-        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
-        PumpStreamHandler pumpStreamHandler = new PumpStreamHandler(outputStream,outputStream,null);
-        ExecuteWatchdog watchdog = new ExecuteWatchdog(Integer.MAX_VALUE);
-        DefaultExecutor defaultExecutor = new DefaultExecutor();
-        defaultExecutor.setWatchdog(watchdog);
-        defaultExecutor.setExitValues(null);
-        defaultExecutor.setStreamHandler(pumpStreamHandler);
-        CommandLine commandline = new CommandLine("python");
-        commandline.addArgument("D:\\2020project\\byit-myth-job\\demo-client\\byit-demo-client\\test.py");
-        int execute = defaultExecutor.execute(commandline);
-        byte[] bytes = outputStream.toByteArray();
-        Thread.sleep(3000);
-        watchdog.destroyProcess();
-        System.out.println(execute);
-
-
-        System.out.println(new String(bytes,0,bytes.length, StandardCharsets.UTF_8));
+
+        List<ExecuteWatchdog> watchdogList = new ArrayList<>();
+
+        Thread thread = new Thread(() -> {
+            ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
+            PumpStreamHandler pumpStreamHandler = new PumpStreamHandler(outputStream,outputStream,null);
+            ExecuteWatchdog watchdog = new ExecuteWatchdog(Integer.MAX_VALUE);
+            watchdogList.add(watchdog);
+            DefaultExecutor defaultExecutor = new DefaultExecutor();
+            defaultExecutor.setWatchdog(watchdog);
+            defaultExecutor.setExitValues(null);
+            defaultExecutor.setStreamHandler(pumpStreamHandler);
+            CommandLine commandline = new CommandLine("python");
+            commandline.addArgument("D:\\workspace\\pycharmWorkSpace\\test\\com.test\\Test.py");
+            int execute = 0;
+            try {
+                execute = defaultExecutor.execute(commandline);
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+            byte[] bytes = outputStream.toByteArray();
+            System.out.println(execute);
+
+            System.out.println(new String(bytes,0,bytes.length, StandardCharsets.UTF_8));
+        });
+        thread.start();
+
+        Thread.sleep(10000);
+        watchdogList.forEach(watchdog ->{
+            watchdog.destroyProcess();
+        });
+
     }
 }