执行节点监控

byit-myth-admin/src/main/java/com/byit/service/impl/ApiNodeServiceImpl.java

@@ -27,6 +27,7 @@ import com.byit.service.JobTaskRunLogService;
 import com.byit.task.JavaNodeExecutorTask;
 import com.byit.task.JavaTaskJobTask;
 import com.byit.task.ScriptExecutorJobTask;
+import com.byit.util.IDGenerationStrategy;
 import com.byit.utils.ValidationUtil;
 import io.netty.util.TimerTask;
 import lombok.extern.slf4j.Slf4j;
@@ -122,7 +123,7 @@ public class ApiNodeServiceImpl implements ApiNodeService {
         schedule.setLogId(logId);
 
         RunLog runLog = RunLog.builder().isEnd(false).runLog("等待服务器分配资源").build();
-        String runKey = "REAL:EXEC:" + logId;
+        String runKey = IDGenerationStrategy.keyGenerationStrategy(logId);
         stringRedisTemplate.opsForList().rightPush(runKey, JSON.toJSONString(runLog, WriteClassName));
         TimerTask timerTask;
         if (NodeTypeEnum.JAVA.getCode().equals(runNode.getJobType())) {

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/helper/UnfinishedNodeMonitoringRunHelper.java

@@ -6,6 +6,7 @@ import com.byit.dto.plugin.RunLog;
 import com.byit.model.JobTaskRunLog;
 import com.byit.service.JobTaskRunLogService;
 import com.byit.thread.BaseThreadRunHelper;
+import com.byit.util.IDGenerationStrategy;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
@@ -40,10 +41,10 @@ public class UnfinishedNodeMonitoringRunHelper extends BaseThreadRunHelper {
         List<JobTaskRunLog> tempRunNodeList = jobTaskRunLogService.findTempRunNodeList();
         if (CollectionUtil.isNotEmpty(tempRunNodeList)) {
             tempRunNodeList.forEach(nodeLog -> {
-                log.debug("-----节点{}未执行完毕-----",nodeLog);
-                String runId = nodeLog.getRunId();
+                log.debug("-----节点{}未执行完毕-----", nodeLog);
+                String keyGenerationStrategy = IDGenerationStrategy.keyGenerationStrategy(nodeLog.getLogId());
                 RunLog runLog = RunLog.builder().isEnd(false).runLog(PENG).build();
-                stringRedisTemplate.opsForList().rightPush(runId, JSON.toJSONString(runLog, WriteClassName));
+                stringRedisTemplate.opsForList().rightPush(keyGenerationStrategy, JSON.toJSONString(runLog, WriteClassName));
             });
         }
         return 5000L;

byit-myth-core/myth-admin-core/src/main/java/com/byit/util/IDGenerationStrategy.java

@@ -22,8 +22,7 @@ public class IDGenerationStrategy {
         return runIdPre;
     }
 
-    public static void main(String[] args) {
-        System.out.println(runIdGenerationStrategy(88));
-
+    public static String keyGenerationStrategy(Integer logId){
+        return  "REAL:EXEC:" + logId;
     }
 }