执行节点监控

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

@@ -20,6 +20,10 @@ public class UnfinishedNodeMonitoringRunHelper extends BaseThreadRunHelper {
      * 心跳
      */
     private static final String PENG = "PENG";
+    /**
+     * 心跳前缀
+     */
+    private static final String HEARTBEAT = "HEARTBEAT_";
     private final StringRedisTemplate stringRedisTemplate;
     private final JobTaskRunLogService jobTaskRunLogService;
 
@@ -32,7 +36,11 @@ public class UnfinishedNodeMonitoringRunHelper extends BaseThreadRunHelper {
     public Long start() {
         List<JobTaskRunLog> tempRunNodeList = jobTaskRunLogService.findTempRunNodeList();
         if (CollectionUtil.isNotEmpty(tempRunNodeList)) {
-            tempRunNodeList.forEach(nodeLog -> stringRedisTemplate.opsForList().rightPush(nodeLog.getRunId(), PENG));
+            tempRunNodeList.forEach(nodeLog -> {
+                String runId = nodeLog.getRunId();
+                String key = HEARTBEAT + runId;
+                stringRedisTemplate.opsForList().rightPush(key, PENG);
+            });
         }
         return 5000L;
     }