Parcourir la source

增加启动弹性伸缩工具

dsx il y a 2 ans
Parent
commit
4a87c6a77c
1 fichiers modifiés avec 10 ajouts et 1 suppressions
  1. 10 1
      src/main/java/com/fdkankan/job/job/CreateScalingHandler.java

+ 10 - 1
src/main/java/com/fdkankan/job/job/CreateScalingHandler.java

@@ -1,5 +1,6 @@
 package com.fdkankan.job.job;
 
+import cn.hutool.core.util.StrUtil;
 import com.fdkankan.rubbersheeting.ScalingService;
 import com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
@@ -26,7 +27,15 @@ public class CreateScalingHandler {
     public void createScalingHandler(){
         XxlJobHelper.log("createScalingHandler start.....");
 
-        scalingService.createEcs();
+        int count = 1;
+        String param = XxlJobHelper.getJobParam();
+        if(StrUtil.isNotEmpty(param)){
+            count = Integer.valueOf(param);
+        }
+
+        for(int i = 0; i < count; i++){
+            scalingService.createEcs();
+        }
 
         XxlJobHelper.log("createScalingHandler end.....");
     }