浏览代码

添加定制化启动弹性伸缩接口

tianboguang 2 年之前
父节点
当前提交
1600d0df24

+ 8 - 17
4dkankan-utils-rubber-sheeting/src/main/java/com/fdkankan/rubbersheeting/AliYunScalingService.java

@@ -78,24 +78,16 @@ public class AliYunScalingService implements ScalingService{
         return value != null ? URLEncoder.encode(value, ENCODING).replace("+", "%20").replace("*", "%2A").replace("%7E", "~") : null;
     }
 
-    public static void main(String[] args) {
-
-        String text = "";
-        for(int i = 0, len = 100; i < len; i ++){
-//            createEcs();
-        }
-//        System.out.println(deleteEcs("i-wz95huv20p8v6csu6q1q"));
-
-//        try{
-//            System.out.println(FileUtils.readFile("C:\\Users\\hisun\\Downloads\\hosts.txt"));
-//            System.out.println(1);
-//        }catch (Exception e){
-//            e.printStackTrace();
-//        }
+    @Override
+    public String createEcs(){
+        Map<String,String> configs = new HashMap<>(2);
+        configs.put("ruleAri",ScalingRuleAri);
+        return createEcsByConfig(configs);
     }
 
     @Override
-    public String createEcs(){
+    public String createEcsByConfig(Map<String, String> configs) {
+        String ruleAri = configs.get("ruleAri");
         try {
 
             boolean tag = true;
@@ -104,7 +96,7 @@ public class AliYunScalingService implements ScalingService{
                 parameters = new HashMap<String, String>();
                 // 加入请求参数
                 parameters.put("Action", "ExecuteScalingRule");
-                parameters.put("ScalingRuleAri", ScalingRuleAri);
+                parameters.put("ScalingRuleAri", ruleAri);
                 parameters.put("Version", "2014-08-28");
                 parameters.put("AccessKeyId", AccessKeyId);
                 parameters.put("Timestamp", formatIso8601Date(new Date()));
@@ -141,7 +133,6 @@ public class AliYunScalingService implements ScalingService{
                     }
                 }
             }
-//            System.out.println("POST parameter : " + parameterBuffer.toString());
             return OkHttpUtils.httpGet("http://ess.aliyuncs.com?" + parameterBuffer.toString());
         }catch (Exception e){
             e.printStackTrace();

+ 7 - 0
4dkankan-utils-rubber-sheeting/src/main/java/com/fdkankan/rubbersheeting/AwsScalingService.java

@@ -3,6 +3,8 @@ package com.fdkankan.rubbersheeting;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.stereotype.Component;
 
+import java.util.Map;
+
 /**
  * Created by Hb_zzZ on 2020/8/25.
  */
@@ -29,6 +31,11 @@ public class AwsScalingService implements ScalingService{
         return null;
     }
 
+    @Override
+    public String createEcsByConfig(Map<String, String> configs) {
+        return null;
+    }
+
 
     @Override
     public String deleteEcs(String id){

+ 4 - 0
4dkankan-utils-rubber-sheeting/src/main/java/com/fdkankan/rubbersheeting/ScalingService.java

@@ -2,9 +2,13 @@ package com.fdkankan.rubbersheeting;
 
 import org.springframework.stereotype.Component;
 
+import java.util.Map;
+
 @Component
 public interface ScalingService {
     String createEcs();
 
+    String createEcsByConfig(Map<String,String> configs);
+
     String deleteEcs(String id);
 }