调整时间

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

@@ -15,7 +15,7 @@ public class TaskController {
     TaskService taskService;
 
 
-    @Scheduled(cron = "*/30 * * * * ?") // 每30秒执行一次（使用cron表达式）
+    @Scheduled(cron = "*/10 * * * * ?") // 每10秒执行一次（使用cron表达式）
     public void runTask(){
         try {
             taskService.runTask();
@@ -33,7 +33,7 @@ public class TaskController {
         }
     }
 
-    @Scheduled(cron = "*/10 * * * * ?") // 每10秒执行一次（使用cron表达式）
+    @Scheduled(cron = "*/30 * * * * ?") // 每30秒执行一次（使用cron表达式）
     public void delEcs(){
         try {
             taskService.delEcsList();

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

@@ -253,7 +253,7 @@ public class TaskService {
 
         Integer ecsCount = countMap.get(mqQueueConfig.getQueueName());
         MqMsg mqMsg = mqMsgMap.get(mqQueueConfig.getQueueName());
-        Boolean flag = mqQueueConfig.getOpenScalingTime() == 0 || checkOpenCount  % (mqQueueConfig.getOpenScalingTime() * 2) == 0;
+        Boolean flag = mqQueueConfig.getOpenScalingTime() == 0 || checkOpenCount  % (mqQueueConfig.getOpenScalingTime() * 6) == 0;
         //未在计算的服务器数量
         Integer noModelingCount = mqMsg.getConsumers() - mqMsg.getMessages_unacknowledged();
         //未启动的服务器数量