1

src/main/java/com/fdkankan/mqcontroller/task/TaskController.java

@@ -24,13 +24,21 @@ public class TaskController {
         }
     }
 
-
     @Scheduled(cron = "*/20 * * * * ?") // 每20秒执行一次（使用cron表达式）
-    public void checkEcs(){
+    public void openEcs(){
+        try {
+            taskService.openEcsList();
+        }catch (Exception e){
+            log.info("openEcs：",e);
+        }
+    }
+
+    @Scheduled(cron = "*/10 * * * * ?") // 每10秒执行一次（使用cron表达式）
+    public void delEcs(){
         try {
-            taskService.checkEcs();
+            taskService.delEcsList();
         }catch (Exception e){
-            log.info("checkEcs：",e);
+            log.info("delEcs：",e);
         }
     }
 

src/main/java/com/fdkankan/mqcontroller/task/TaskService.java

@@ -59,14 +59,19 @@ public class TaskService {
     public static HashMap<String,Integer> countMap = new HashMap<>();
 
     public void runTask() {
-        sendMq();
-        checkDelEcs();
-    }
+        try {
+            sendMq();
+        }catch (Exception e){
+            log.info("sendMq:error:",e);
+        }
+        try {
+            checkDelEcs();
+        }catch (Exception e){
+            log.info("checkDelEcs:error:",e);
+        }
 
-    public void checkEcs() {
-        openEcsList();
-        delEcsList();
     }
+
     /**
      * 将数据库中待计算的mq消息推送，rabbitmq
      */