{
+ private static final long serialVersionUID = -1185015143654744140L;
+ /**
+ * 此UUID的最高64有效位
+ */
+ private final long mostSigBits;
+ /**
+ * 此UUID的最低64有效位
+ */
+ private final long leastSigBits;
+
+ /**
+ * 私有构造
+ *
+ * @param data 数据
+ */
+ private UUID (byte[] data) {
+ long msb = 0;
+ long lsb = 0;
+ assert data.length == 16 : "data must be 16 bytes in length";
+ for (int i = 0 ; i < 8 ; i++) {
+ msb = (msb << 8) | (data[i] & 0xff);
+ }
+ for (int i = 8 ; i < 16 ; i++) {
+ lsb = (lsb << 8) | (data[i] & 0xff);
+ }
+ this.mostSigBits = msb;
+ this.leastSigBits = lsb;
+ }
+
+ /**
+ * 使用指定的数据构造新的 UUID。
+ *
+ * @param mostSigBits 用于 {@code UUID} 的最高有效 64 位
+ * @param leastSigBits 用于 {@code UUID} 的最低有效 64 位
+ */
+ public UUID (long mostSigBits, long leastSigBits) {
+ this.mostSigBits = mostSigBits;
+ this.leastSigBits = leastSigBits;
+ }
+
+ /**
+ * 获取类型 4（伪随机生成的）UUID 的静态工厂。
+ *
+ * @return 随机生成的 {@code UUID}
+ */
+ public static UUID fastUUID () {
+ return randomUUID(false);
+ }
+
+ /**
+ * 获取类型 4（伪随机生成的）UUID 的静态工厂。 使用加密的强伪随机数生成器生成该 UUID。
+ *
+ * @return 随机生成的 {@code UUID}
+ */
+ public static UUID randomUUID () {
+ return randomUUID(true);
+ }
+
+ /**
+ * 获取类型 4（伪随机生成的）UUID 的静态工厂。 使用加密的强伪随机数生成器生成该 UUID。
+ *
+ * @param isSecure 是否使用{@link SecureRandom}如果是可以获得更安全的随机码，否则可以得到更好的性能
+ *
+ * @return 随机生成的 {@code UUID}
+ */
+ public static UUID randomUUID (boolean isSecure) {
+ final Random ng = isSecure ? Holder.numberGenerator : getRandom();
+
+ byte[] randomBytes = new byte[16];
+ ng.nextBytes(randomBytes);
+ randomBytes[6] &= 0x0f; /* clear version */
+ randomBytes[6] |= 0x40; /* set to version 4 */
+ randomBytes[8] &= 0x3f; /* clear variant */
+ randomBytes[8] |= 0x80; /* set to IETF variant */
+ return new UUID(randomBytes);
+ }
+
+ /**
+ * 根据指定的字节数组获取类型 3（基于名称的）UUID 的静态工厂。
+ *
+ * @param name 用于构造 UUID 的字节数组。
+ *
+ * @return 根据指定数组生成的 {@code UUID}
+ */
+ public static UUID nameUUIDFromBytes (byte[] name) {
+ MessageDigest md;
+ try {
+ md = MessageDigest.getInstance("MD5");
+ } catch (NoSuchAlgorithmException nsae) {
+ throw new InternalError("MD5 not supported");
+ }
+ byte[] md5Bytes = md.digest(name);
+ md5Bytes[6] &= 0x0f; /* clear version */
+ md5Bytes[6] |= 0x30; /* set to version 3 */
+ md5Bytes[8] &= 0x3f; /* clear variant */
+ md5Bytes[8] |= 0x80; /* set to IETF variant */
+ return new UUID(md5Bytes);
+ }
+
+ /**
+ * 根据 {@link #toString()} 方法中描述的字符串标准表示形式创建{@code UUID}。
+ *
+ * @param name 指定 {@code UUID} 字符串
+ *
+ * @return 具有指定值的 {@code UUID}
+ *
+ * @throws IllegalArgumentException 如果 name 与 {@link #toString} 中描述的字符串表示形式不符抛出此异常
+ */
+ public static UUID fromString (String name) {
+ String[] components = name.split("-");
+ if (components.length != 5) {
+ throw new IllegalArgumentException("Invalid UUID string: " + name);
+ }
+ for (int i = 0 ; i < 5 ; i++) {
+ components[i] = "0x" + components[i];
+ }
+
+ long mostSigBits = Long.decode(components[0]).longValue();
+ mostSigBits <<= 16;
+ mostSigBits |= Long.decode(components[1]).longValue();
+ mostSigBits <<= 16;
+ mostSigBits |= Long.decode(components[2]).longValue();
+
+ long leastSigBits = Long.decode(components[3]).longValue();
+ leastSigBits <<= 48;
+ leastSigBits |= Long.decode(components[4]).longValue();
+
+ return new UUID(mostSigBits, leastSigBits);
+ }
+
+ /**
+ * 返回指定数字对应的hex值
+ *
+ * @param val 值
+ * @param digits 位
+ *
+ * @return 值
+ */
+ private static String digits (long val, int digits) {
+ long hi = 1L << (digits * 4);
+ return Long.toHexString(hi | (val & (hi - 1))).substring(1);
+ }
+
+ /**
+ * 获取{@link SecureRandom}，类提供加密的强随机数生成器 (RNG)
+ *
+ * @return {@link SecureRandom}
+ */
+ public static SecureRandom getSecureRandom () {
+ try {
+ return SecureRandom.getInstance("SHA1PRNG");
+ } catch (NoSuchAlgorithmException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ /**
+ * 获取随机数生成器对象
+ * ThreadLocalRandom是JDK 7之后提供并发产生随机数，能够解决多个线程发生的竞争争夺。
+ *
+ * @return {@link ThreadLocalRandom}
+ */
+ public static ThreadLocalRandom getRandom () {
+ return ThreadLocalRandom.current();
+ }
+
+ /**
+ * 返回此 UUID 的 128 位值中的最低有效 64 位。
+ *
+ * @return 此 UUID 的 128 位值中的最低有效 64 位。
+ */
+ public long getLeastSignificantBits () {
+ return leastSigBits;
+ }
+
+ /**
+ * 返回此 UUID 的 128 位值中的最高有效 64 位。
+ *
+ * @return 此 UUID 的 128 位值中最高有效 64 位。
+ */
+ public long getMostSignificantBits () {
+ return mostSigBits;
+ }
+
+ /**
+ * 与此 {@code UUID} 相关联的版本号. 版本号描述此 {@code UUID} 是如何生成的。
+ *
+ * 版本号具有以下含意:
+ *
+ * - 1 基于时间的 UUID
+ *
- 2 DCE 安全 UUID
+ *
- 3 基于名称的 UUID
+ *
- 4 随机生成的 UUID
+ *
+ *
+ * @return 此 {@code UUID} 的版本号
+ */
+ public int version () {
+ // Version is bits masked by 0x000000000000F000 in MS long
+ return (int) ((mostSigBits >> 12) & 0x0f);
+ }
+
+ /**
+ * 与此 {@code UUID} 相关联的变体号。变体号描述 {@code UUID} 的布局。
+ *
+ * 变体号具有以下含意：
+ *
+ * - 0 为 NCS 向后兼容保留
+ *
- 2 IETF RFC 4122(Leach-Salz), 用于此类
+ *
- 6 保留，微软向后兼容
+ *
- 7 保留供以后定义使用
+ *
+ *
+ * @return 此 {@code UUID} 相关联的变体号
+ */
+ public int variant () {
+ // This field is composed of a varying number of bits.
+ // 0 - - Reserved for NCS backward compatibility
+ // 1 0 - The IETF aka Leach-Salz variant (used by this class)
+ // 1 1 0 Reserved, Microsoft backward compatibility
+ // 1 1 1 Reserved for future definition.
+ return (int) ((leastSigBits >>> (64 - (leastSigBits >>> 62))) & (leastSigBits >> 63));
+ }
+
+ /**
+ * 与此 UUID 相关联的时间戳值。
+ *
+ *
+ * 60 位的时间戳值根据此 {@code UUID} 的 time_low、time_mid 和 time_hi 字段构造。
+ * 所得到的时间戳以 100 毫微秒为单位，从 UTC（通用协调时间） 1582 年 10 月 15 日零时开始。
+ *
+ *
+ * 时间戳值仅在在基于时间的 UUID（其 version 类型为 1）中才有意义。
+ * 如果此 {@code UUID} 不是基于时间的 UUID，则此方法抛出 UnsupportedOperationException。
+ *
+ * @throws UnsupportedOperationException 如果此 {@code UUID} 不是 version 为 1 的 UUID。
+ */
+ public long timestamp () throws UnsupportedOperationException {
+ checkTimeBase();
+ return (mostSigBits & 0x0FFFL) << 48//
+ | ((mostSigBits >> 16) & 0x0FFFFL) << 32//
+ | mostSigBits >>> 32;
+ }
+
+ /**
+ * 与此 UUID 相关联的时钟序列值。
+ *
+ *
+ * 14 位的时钟序列值根据此 UUID 的 clock_seq 字段构造。clock_seq 字段用于保证在基于时间的 UUID 中的时间唯一性。
+ *
+ * {@code clockSequence} 值仅在基于时间的 UUID（其 version 类型为 1）中才有意义。 如果此 UUID 不是基于时间的 UUID，则此方法抛出
+ * UnsupportedOperationException。
+ *
+ * @return 此 {@code UUID} 的时钟序列
+ *
+ * @throws UnsupportedOperationException 如果此 UUID 的 version 不为 1
+ */
+ public int clockSequence () throws UnsupportedOperationException {
+ checkTimeBase();
+ return (int) ((leastSigBits & 0x3FFF000000000000L) >>> 48);
+ }
+
+ /**
+ * 与此 UUID 相关的节点值。
+ *
+ *
+ * 48 位的节点值根据此 UUID 的 node 字段构造。此字段旨在用于保存机器的 IEEE 802 地址，该地址用于生成此 UUID 以保证空间唯一性。
+ *
+ * 节点值仅在基于时间的 UUID（其 version 类型为 1）中才有意义。
+ * 如果此 UUID 不是基于时间的 UUID，则此方法抛出 UnsupportedOperationException。
+ *
+ * @return 此 {@code UUID} 的节点值
+ *
+ * @throws UnsupportedOperationException 如果此 UUID 的 version 不为 1
+ */
+ public long node () throws UnsupportedOperationException {
+ checkTimeBase();
+ return leastSigBits & 0x0000FFFFFFFFFFFFL;
+ }
+
+ /**
+ * 返回此{@code UUID} 的字符串表现形式。
+ *
+ *
+ * UUID 的字符串表示形式由此 BNF 描述：
+ *
+ *
+ * {@code
+ * UUID = ----
+ * time_low = 4*
+ * time_mid = 2*
+ * time_high_and_version = 2*
+ * variant_and_sequence = 2*
+ * node = 6*
+ * hexOctet =
+ * hexDigit = [0-9a-fA-F]
+ * }
+ *
+ *
+ *
+ *
+ * @return 此{@code UUID} 的字符串表现形式
+ *
+ * @see #toString(boolean)
+ */
+ @Override
+ public String toString () {
+ return toString(false);
+ }
+
+ /**
+ * 返回此{@code UUID} 的字符串表现形式。
+ *
+ *
+ * UUID 的字符串表示形式由此 BNF 描述：
+ *
+ *
+ * {@code
+ * UUID = ----
+ * time_low = 4*
+ * time_mid = 2*
+ * time_high_and_version = 2*
+ * variant_and_sequence = 2*
+ * node = 6*
+ * hexOctet =
+ * hexDigit = [0-9a-fA-F]
+ * }
+ *
+ *
+ *
+ *
+ * @param isSimple 是否简单模式，简单模式为不带'-'的UUID字符串
+ *
+ * @return 此{@code UUID} 的字符串表现形式
+ */
+ public String toString (boolean isSimple) {
+ final StringBuilder builder = new StringBuilder(isSimple ? 32 : 36);
+ // time_low
+ builder.append(digits(mostSigBits >> 32, 8));
+ if (false == isSimple) {
+ builder.append('-');
+ }
+ // time_mid
+ builder.append(digits(mostSigBits >> 16, 4));
+ if (false == isSimple) {
+ builder.append('-');
+ }
+ // time_high_and_version
+ builder.append(digits(mostSigBits, 4));
+ if (false == isSimple) {
+ builder.append('-');
+ }
+ // variant_and_sequence
+ builder.append(digits(leastSigBits >> 48, 4));
+ if (false == isSimple) {
+ builder.append('-');
+ }
+ // node
+ builder.append(digits(leastSigBits, 12));
+
+ return builder.toString();
+ }
+
+ // Comparison Operations
+
+ /**
+ * 返回此 UUID 的哈希码。
+ *
+ * @return UUID 的哈希码值。
+ */
+ @Override
+ public int hashCode () {
+ long hilo = mostSigBits ^ leastSigBits;
+ return ((int) (hilo >> 32)) ^ (int) hilo;
+ }
+
+ // -------------------------------------------------------------------------------------------------------------------
+ // Private method start
+
+ /**
+ * 将此对象与指定对象比较。
+ *
+ * 当且仅当参数不为 {@code null}、而是一个 UUID 对象、具有与此 UUID 相同的 varriant、包含相同的值（每一位均相同）时，结果才为 {@code true}。
+ *
+ * @param obj 要与之比较的对象
+ *
+ * @return 如果对象相同，则返回 {@code true}；否则返回 {@code false}
+ */
+ @Override
+ public boolean equals (Object obj) {
+ if ((null == obj) || (obj.getClass() != UUID.class)) {
+ return false;
+ }
+ UUID id = (UUID) obj;
+ return (mostSigBits == id.mostSigBits && leastSigBits == id.leastSigBits);
+ }
+
+ /**
+ * 将此 UUID 与指定的 UUID 比较。
+ *
+ *
+ * 如果两个 UUID 不同，且第一个 UUID 的最高有效字段大于第二个 UUID 的对应字段，则第一个 UUID 大于第二个 UUID。
+ *
+ * @param val 与此 UUID 比较的 UUID
+ *
+ * @return 在此 UUID 小于、等于或大于 val 时，分别返回 -1、0 或 1。
+ */
+ @Override
+ public int compareTo (UUID val) {
+ // The ordering is intentionally set up so that the UUIDs
+ // can simply be numerically compared as two numbers
+ return (this.mostSigBits < val.mostSigBits ? -1 : //
+ (this.mostSigBits > val.mostSigBits ? 1 : //
+ (this.leastSigBits < val.leastSigBits ? -1 : //
+ (this.leastSigBits > val.leastSigBits ? 1 : //
+ 0))));
+ }
+
+ /**
+ * 检查是否为time-based版本UUID
+ */
+ private void checkTimeBase () {
+ if (version() != 1) {
+ throw new UnsupportedOperationException("Not a time-based UUID");
+ }
+ }
+
+ /**
+ * SecureRandom 的单例
+ */
+ private static class Holder {
+ static final SecureRandom numberGenerator = getSecureRandom();
+ }
+}
diff --git a/src/main/java/com/yyh/openAPI/WorkCenter/CreateAndRunInstance.java b/src/main/java/com/yyh/openAPI/WorkCenter/CreateAndRunInstance.java
new file mode 100644
index 0000000..3178f85
--- /dev/null
+++ b/src/main/java/com/yyh/openAPI/WorkCenter/CreateAndRunInstance.java
@@ -0,0 +1,110 @@
+// This file is auto-generated, don't edit it. Thanks.
+package com.yyh.openAPI.WorkCenter;
+
+import com.aliyun.ecs20140526.models.RunInstancesRequest;
+import com.aliyun.ecs20140526.models.RunInstancesResponse;
+import com.aliyun.tea.TeaException;
+import com.yyh.common.config.ClientService;
+import com.yyh.common.utils.UserUtil;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+
+/*
+ * 根据镜像创建并运行实例
+ * */
+@Component
+public class CreateAndRunInstance {
+
+
+ /*
+ * @Author: YY
+ * @Date: 2024/4/13 9:28
+ * @Description: 开始创建实例
+ * @Param: []
+ * @Return: java.lang.String
+ **/
+ /**
+ * @Description //
+ * @Date 2024/4/17
+ * @return java.lang.String
+ **/
+ public static String startCreate() throws Exception {
+ // 地域Id
+ String regionId = "cn-shanghai";
+ // 镜像 ID，启动实例时选择的镜像资源。
+ String imageId = "m-uf6ffzsvgwlvnvikzlnx";
+ // 实例规格
+ String instanceType = "ecs.u1-c1m1.large";
+ // 新创建实例所属于的安全组 ID。
+ String securityGroupId = "sg-uf63cq2cko5d8cr3gvln";
+ // 虚拟交换机 ID。
+ String vSwitchId = "vsw-uf64ypbxmk0qtl1apfyml";
+ // 公网出带宽最大值，单位为 Mbit/s。取值范围：0~100。 默认值：0。
+ Integer internetMaxBandwidthOut = com.aliyun.darabonbanumber.Client.parseInt("5");
+ // 网络计费类型。取值范围：
+ // PayByBandwidth: 按固定带宽计费。
+ // PayByTraffic: 按使用流量计费。
+ // 默认值：PayByTraffic。
+ String internetChargeType = "PayByTraffic";
+ // 系统盘大小
+ String size = "20";
+ // 系统盘的云盘种类
+ String category = "cloud_essd_entry";
+ // ECS实例的计费方式
+ // PrePaid：包年包月
+ // PostPaid：按量付费
+ String instanceChargeType = "PostPaid";
+
+
+ com.aliyun.ecs20140526.Client client = ClientService.createEcsClient(regionId);
+ // 批量创建实例
+ return CreateAndRunInstance.RunInstances(client, regionId, imageId, instanceType, securityGroupId, vSwitchId, internetMaxBandwidthOut, internetChargeType, size, category, instanceChargeType);
+ }
+
+ /**
+ * RunInstances 通过备选实例规格创建ECS实例最佳实践
+ * 该场景中，在调用RunInstances创建ECS实例时判断是否发生库存不足等错误，如果发生错误，将调用DescribeRecommendInstanceType查询备选实例，然后通过备选实例规格重新创建ECS实例。
+ */
+ public static String RunInstances(com.aliyun.ecs20140526.Client client, String regionId, String imageId, String instanceType, String securityGroupId, String vSwitchId, Integer internetMaxBandwidthOut, String internetChargeType, String size, String category, String instanceChargeType) throws Exception {
+ RunInstancesRequest request1 = new RunInstancesRequest()
+ .setRegionId(regionId)
+ .setImageId(imageId)
+ .setInstanceType(instanceType)
+ .setSecurityGroupId(securityGroupId)
+ .setVSwitchId(vSwitchId)
+ .setInstanceName("自动创建的实例节点")
+ .setDescription(new Date().toLocaleString() + " 创建的实例节点")
+ .setInternetMaxBandwidthOut(internetMaxBandwidthOut)
+ .setInternetChargeType(internetChargeType)
+ .setInstanceChargeType(instanceChargeType)
+ // 批量创建五台ECS实例，如果不设置该参数，默认创建一台ECS实例。
+ // amount = 5,
+ // 如果缺少库存可以接受的最低创建数量。
+ // minAmount = 2,
+ // 打开预检参数功能，不会实际创建ECS实例，只检查参数正确性、用户权限或者ECS库存等问题。
+ // 实际情况下，设置了DryRun参数后，Amount必须为1，MinAmount必须为空，您可以根据实际需求修改代码。
+// .setDryRun(true)
+ .setDryRun(false)
+ .setSystemDisk(new RunInstancesRequest.RunInstancesRequestSystemDisk()
+ .setSize(size)
+ .setCategory(category));
+
+
+ String result = "";
+ try {
+ com.aliyun.teaconsole.Client.log("--------------------批量创建实例开始--------------------");
+ RunInstancesResponse responces = client.runInstances(request1);
+ com.aliyun.teaconsole.Client.log("--------------------创建实例成功，实例ID:" + com.aliyun.teautil.Common.toJSONString(responces.body.instanceIdSets.instanceIdSet) + "--------------------");
+ //返回实例ID
+ result = responces.body.instanceIdSets.instanceIdSet + "";//前后带 []
+ result = UserUtil.removeBrackets(result);//前后不带[]
+ } catch (TeaException error) {
+ com.aliyun.teaconsole.Client.log("--------------------创建实例失败:" + com.aliyun.teautil.Common.toJSONString(error.code) + "--------------------" + error.message);
+ } catch (Exception _error) {
+ TeaException error = new TeaException(_error.getMessage(), _error);
+ com.aliyun.teaconsole.Client.log("--------------------创建实例失败:" + com.aliyun.teautil.Common.toJSONString(error.code) + "--------------------" + error.message);
+ }
+ return result;
+ }
+}
diff --git a/src/main/java/com/yyh/openAPI/WorkCenter/ReleaseInstance.java b/src/main/java/com/yyh/openAPI/WorkCenter/ReleaseInstance.java
new file mode 100644
index 0000000..65d29fc
--- /dev/null
+++ b/src/main/java/com/yyh/openAPI/WorkCenter/ReleaseInstance.java
@@ -0,0 +1,85 @@
+// This file is auto-generated, don't edit it. Thanks.
+package com.yyh.openAPI.WorkCenter;
+
+import com.aliyun.ecs20140526.models.*;
+import com.yyh.common.config.ClientService;
+import org.springframework.stereotype.Component;
+
+/**
+ * @ProjectName: five-groups-couplet
+ * @Author: YY
+ * @CreateTime: 2024/4/12
+ * @Description: 释放实例
+ */
+
+@Component
+public class ReleaseInstance {
+ public static DescribeInstancesResponse DescribeInstances(com.aliyun.ecs20140526.Client client, String regionId, String instanceIds, String instanceName) throws Exception {
+ DescribeInstancesRequest req = new DescribeInstancesRequest()
+ .setRegionId(regionId)
+ .setInstanceName(instanceName);
+ if (!com.aliyun.teautil.Common.empty(instanceIds)) {
+ req.instanceIds = com.aliyun.teautil.Common.toJSONString(com.aliyun.darabonbastring.Client.split(instanceIds, ",", 50));
+ }
+
+ DescribeInstancesResponse resp = client.describeInstances(req);
+ com.aliyun.teaconsole.Client.log("--------------------查询需要删除的实例--------------------");
+ return resp;
+ }
+
+ public static void ModifyInstanceAttribute(com.aliyun.ecs20140526.Client client, String instatnceId) throws Exception {
+ ModifyInstanceAttributeRequest req = new ModifyInstanceAttributeRequest()
+ .setInstanceId(instatnceId)
+ .setDeletionProtection(false);
+ client.modifyInstanceAttribute(req);
+ com.aliyun.teaconsole.Client.log("--------------------" + instatnceId + "释放保护取消成功--------------------");
+ }
+
+ public static void DeleteInstances(com.aliyun.ecs20140526.Client client, String regionId, String instanceIds, String force) throws Exception {
+ DeleteInstancesRequest req = new DeleteInstancesRequest()
+ .setRegionId(regionId)
+ .setInstanceId(com.aliyun.darabonbastring.Client.split(instanceIds, ",", 50))
+ .setForce(com.aliyun.teautil.Common.equalString(force, "true"));
+ DeleteInstancesResponse resp = client.deleteInstances(req);
+ com.aliyun.teaconsole.Client.log("--------------------实例释放成功--------------------");
+ com.aliyun.teaconsole.Client.log(com.aliyun.teautil.Common.toJSONString(com.aliyun.teautil.Common.toMap(resp)));
+ }
+
+ /*
+ * @Author: YY
+ * @Date: 2024/4/13 11:02
+ * @Description: 多个实例ID，用英文逗号分隔
+ * @Param: [instanceIds] i-uf6chlqotgoc9h173alu
+ * @Return: void
+ **/
+ public static void startRelease(String instanceIds) throws Exception {
+ // 区域ID
+ String regionId = "cn-shanghai";
+ // 实例名称，支持使用通配符*进行模糊搜索
+ String instanceName = "*";
+ // 强制删除有删除保护的机器
+ String deleteProtected = "true";
+ // 强制删除运行中的机器
+ String force = "true";
+ com.aliyun.ecs20140526.Client client = ClientService.createEcsClient(regionId);
+ if (com.aliyun.teautil.Common.equalString(deleteProtected, "true")) {
+ DescribeInstancesResponse describeInstancesResp = ReleaseInstance.DescribeInstances(client, regionId, instanceIds, instanceName);
+ instanceIds = "";
+ for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance instance : describeInstancesResp.body.instances.instance) {
+ instanceIds = "" + instance.instanceId + "," + instanceIds + "";
+ if (instance.deletionProtection) {
+ ReleaseInstance.ModifyInstanceAttribute(client, instance.instanceId);
+ }
+
+ }
+ instanceIds = com.aliyun.darabonbastring.Client.subString(instanceIds, 0, -1);
+ }
+
+ if (com.aliyun.teautil.Common.empty(instanceIds)) {
+ com.aliyun.teaconsole.Client.log("--------------------无有效实例可删除--------------------");
+ return;
+ }
+
+ ReleaseInstance.DeleteInstances(client, regionId, instanceIds, force);
+ }
+}
diff --git a/src/main/java/com/yyh/server/Server.java b/src/main/java/com/yyh/server/Server.java
new file mode 100644
index 0000000..86b6e08
--- /dev/null
+++ b/src/main/java/com/yyh/server/Server.java
@@ -0,0 +1,70 @@
+package com.yyh.server;
+
+import com.alibaba.fastjson2.JSONArray;
+import com.alibaba.fastjson2.JSONObject;
+import com.yyh.openAPI.WorkCenter.CreateAndRunInstance;
+import lombok.extern.slf4j.Slf4j;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+/**
+ * @ProjectName: LoadCenter
+ * @Author: YY
+ * @CreateTime: 2024/4/13
+ * @Description:
+ */
+@Component
+@Slf4j
+public class Server {
+ @Scheduled(cron = "0/20 * * * * ?")
+ public void test() {
+ String ip = "47.102.123.209";
+ //请求路径
+ String URL = "http://" + ip + ":8080/public/cluster";
+
+ OkHttpClient client = new OkHttpClient();
+
+ Request req = new Request.Builder()
+ .url(URL)
+ .get()
+ .addHeader("User-Agent", "Apifox/1.0.0 (https://apifox.com)")
+ .addHeader("Accesstoken", "")
+ .build();
+
+ try {
+ Response response = client.newCall(req).execute();
+
+ System.out.println(response);
+
+
+ JSONArray jsonArray = JSONArray.parseArray(response.body().string());
+ JSONObject jsonObject = jsonArray.getJSONObject(0);
+ //获取mqttInfo对象的值
+ JSONObject mqttInfo = jsonObject.getJSONObject("mqttInfo");
+ //获取连接数
+ int connectSize = mqttInfo.getIntValue("connectSize");
+
+ System.out.println(ip + " 的fluxmq连接数为：" + connectSize);
+
+ if (connectSize >= 6) {
+ //执行节点扩容
+
+ //返回实例的ID
+ String instanceId = CreateAndRunInstance.startCreate();
+
+ if (!instanceId.isEmpty()) {
+ System.out.println("扩容 成功！");
+ System.out.println("扩容的节点ip为：" + instanceId);
+ }
+ }
+
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+
+
+ }
+}
diff --git a/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports b/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
new file mode 100644
index 0000000..9989f9e
--- /dev/null
+++ b/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
@@ -0,0 +1,2 @@
+com.yyh.common.redis.configure.RedisConfig
+com.yyh.common.redis.service.RedisService
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
new file mode 100644
index 0000000..1a08502
--- /dev/null
+++ b/src/main/resources/application.yml
@@ -0,0 +1,18 @@
+server:
+ port: 9958
+
+
+spring:
+ redis:
+ host: 39.103.132.68
+ port: 6379
+ password: lyh172469
+
+
+config:
+ ali:
+ access-key-id: LTAI5tDyuACiTeRrsFZoDTaP
+ access-key-secret: j04qnolFV0JkmIH7lSyEM4QlOxjn7z
+ region-id: cn-shanghai
+ instance:
+ image-id:"m-uf6ii43j71vmvcc84cb9"
diff --git a/src/main/resources/banner.txt b/src/main/resources/banner.txt
new file mode 100644
index 0000000..2abd71b
--- /dev/null
+++ b/src/main/resources/banner.txt
@@ -0,0 +1,3 @@
+Spring Boot Version: ${spring-boot.version}
+Spring Application Name: ${spring.application.name}
+${AnsiBackground.BRIGHT_CYAN}
diff --git a/src/test/java/LoadTest.java b/src/test/java/LoadTest.java
new file mode 100644
index 0000000..8b6aa52
--- /dev/null
+++ b/src/test/java/LoadTest.java
@@ -0,0 +1,63 @@
+import com.aliyun.ecs20140526.models.DescribeInstancesResponseBody;
+import com.yyh.LoadCenterApplication;
+import com.yyh.common.redis.service.RedisService;
+import com.yyh.common.utils.UserUtil;
+import com.yyh.openAPI.WorkCenter.CreateAndRunInstance;
+import com.yyh.openAPI.WorkCenter.ReleaseInstance;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import java.util.List;
+
+/**
+ * @ProjectName: LoadCenter
+ * @Author: YY
+ * @CreateTime: 2024/4/13
+ * @Description: 负载测试
+ */
+
+@SpringBootTest(classes = LoadCenterApplication.class)
+@Slf4j
+public class LoadTest {
+ @Autowired
+ private RedisService redisService;
+
+
+ @Test
+ public void load() throws Exception {
+ //返回实例的ID
+ String instanceId = CreateAndRunInstance.startCreate();
+
+ Thread.sleep(2000);
+
+ //通过实例ID获取实例的详细属性
+ List describeInstancesResponseBodyInstancesInstances = GetInstanceProperties.startGet(instanceId);
+
+ //获取集合第一个的属性
+ DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance response = describeInstancesResponseBodyInstancesInstances.get(0);
+
+ //获取添加的实例的公网ip
+ String instanceIp = UserUtil.removeBrackets(response.getPublicIpAddress().getIpAddress().toString());
+ System.out.println("-----------------------");
+ System.out.println(instanceIp);
+ System.out.println("-----------------------");
+
+ }
+
+
+ //获取指定节点的负载数
+
+
+ /*
+ * 释放实例
+ * */
+ @Test
+ public void aaa() throws Exception {
+ ReleaseInstance.startRelease("i-uf6bu89eix8bwgiix0g1,i-uf64ycthw01iqb63wvmb,i-uf6gnczd1lzqp1yp8q8h");
+
+ }
+
+
+}