将运行日志放到fastdfs上

byit-myth-core/myth-executor-core/src/main/java/com/byit/executor/jobExecutor/process/MythJobProcess.java

 package com.byit.executor.jobExecutor.process;
 
+import com.byit.executor.conf.FileSystemContext;
 import com.byit.executor.util.JobContentUtil;
 import com.byit.executor.util.LogGobbler;
 import com.google.common.base.Joiner;
@@ -11,6 +12,7 @@ import java.io.IOException;
 import java.io.InputStreamReader;
 import java.lang.reflect.Field;
 import java.nio.charset.StandardCharsets;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
@@ -49,22 +51,26 @@ public class MythJobProcess implements Runnable{
     //本次任务对应的日志id
     private Integer logId;
     //执行日志内容
-    private String logContent;
+    private String logFilePath;
+    //上传日志工具类
+    private FileSystemContext fileSystemContext;
 
     public MythJobProcess(final List<String> cmd, final Map<String, String> env,
-                          final String workingDir, final Integer logId) {
+                          final String workingDir, final Integer logId, FileSystemContext fileSystemContext) {
         this.cmd = cmd;
         this.env = env;
         this.workingDir = workingDir;
         this.processId = -1;
         this.startupLatch = new CountDownLatch(1);
         this.completeLatch = new CountDownLatch(1);
+        this.logId = logId;
+        this.fileSystemContext = fileSystemContext;
     }
 
     public MythJobProcess(final List<String> cmd, final Map<String, String> env,
                           final String workingDir, final String executeAsUserBinary,
-                          final String effectiveUser, Integer logId) {
-        this(cmd, env, workingDir, logId);
+                          final String effectiveUser, Integer logId, FileSystemContext fileSystemContext) {
+        this(cmd, env, workingDir, logId, fileSystemContext);
         this.isExecuteAsUser = true;
         this.executeAsUserBinary = executeAsUserBinary;
         this.effectiveUser = effectiveUser;
@@ -141,8 +147,11 @@ public class MythJobProcess implements Runnable{
             if (this.process.isAlive()){
                 this.process.destroy();
             }
-            logContent = outputGobbler.getRecentLog() + "\n" + errorGobbler.getRecentLog();
+            String logContent = outputGobbler.getRecentLog() + "\n" + errorGobbler.getRecentLog();
             //TODO 将日志写到fastdfs上
+            Map<String,String> map = new HashMap<String,String>(10);
+            map.put("filename", logId + ".log");
+            logFilePath = fileSystemContext.uploadFile(logContent.getBytes(), "log", map);
         }
     }
 
@@ -299,6 +308,6 @@ public class MythJobProcess implements Runnable{
     }
 
     public String getLogContent(){
-        return logContent;
+        return logFilePath;
     }
 }