commit 43295537c99a8bb77433e02beb24e594ba26d622
Author: Yan Nan <255809923@qq.com>
Date: Wed Apr 17 11:51:17 2024 +0800
yn
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..0f996d3
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,231 @@
+
+
+ 4.0.0
+ com.muyu
+ mqtt
+ 0.0.1-SNAPSHOT
+ mqtt
+ Demo project for Spring Boot
+
+ 1.8
+ UTF-8
+ UTF-8
+ 2.6.13
+
+
+
+
+
+
+
+ com.aliyun
+ darabonba-string
+ 0.0.3
+
+
+ com.aliyun
+ tea
+ [1.0.3, 2.0.0)
+
+
+
+ com.aliyun
+ ecs20140526
+ 3.1.2
+
+
+ com.aliyun
+ tea-openapi
+ 0.3.2
+
+
+ com.aliyun
+ tea-util
+ 0.2.21
+
+
+ com.aliyun
+ tea-console
+ 0.0.1
+
+
+ com.aliyun
+ darabonba-env
+ 0.1.1
+
+
+ com.aliyun
+ tea
+ 1.1.14
+
+
+
+
+ com.aliyun
+ credentials-java
+ LATEST
+
+
+ com.aliyun
+ tea-openapi
+ 0.2.8
+
+
+ com.aliyun
+ dysmsapi20170525
+ 2.0.24
+
+
+
+ com.aliyun
+ ecs20140526
+ 3.1.12
+
+
+
+ com.aliyun
+ aliyun-java-sdk-core
+ 4.6.3
+
+
+ com.aliyun
+ aliyun-java-sdk-ecs
+ 4.24.59
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+ org.projectlombok
+ lombok
+
+
+ org.springframework.boot
+ spring-boot-starter-data-redis
+
+
+
+ org.eclipse.paho
+ org.eclipse.paho.client.mqttv3
+ 1.2.5
+
+
+
+ com.alibaba.fastjson2
+ fastjson2
+ 2.0.47
+
+
+
+ org.springframework.boot
+ spring-boot-starter-test
+ test
+
+
+ org.springframework
+ spring-tx
+ 5.3.31
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-dependencies
+ ${spring-boot.version}
+ pom
+ import
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.6.1
+
+ 16
+ 16
+
+
+
+ org.sonatype.plugins
+ nexus-staging-maven-plugin
+ 1.6.3
+ true
+
+ sonatype-nexus-staging
+ https://s01.oss.sonatype.org/
+ true
+
+
+
+ org.apache.maven.plugins
+ maven-javadoc-plugin
+ 3.1.1
+
+ UTF-8
+ none
+
+
+
+ org.apache.maven.plugins
+ maven-surefire-plugin
+ 2.22.1
+
+
+ org.apache.maven.plugins
+ maven-assembly-plugin
+ 2.4.1
+
+
+ jar-with-dependencies
+
+
+
+ true
+ com.aliyun.sample.Sample
+
+
+
+
+
+ make-assembly
+ package
+
+ single
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/src/main/java/com/muyu/Ynpplication.java b/src/main/java/com/muyu/Ynpplication.java
new file mode 100644
index 0000000..fe6860d
--- /dev/null
+++ b/src/main/java/com/muyu/Ynpplication.java
@@ -0,0 +1,15 @@
+package com.muyu;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+@EnableScheduling
+@SpringBootApplication
+public class Ynpplication {
+
+ public static void main(String[] args) {
+ SpringApplication.run(Ynpplication.class, args);
+ }
+
+}
diff --git a/src/main/java/com/muyu/common/aly/AliYunRcsService.java b/src/main/java/com/muyu/common/aly/AliYunRcsService.java
new file mode 100644
index 0000000..cd074e6
--- /dev/null
+++ b/src/main/java/com/muyu/common/aly/AliYunRcsService.java
@@ -0,0 +1,88 @@
+package com.muyu.common.aly;
+
+import com.aliyun.ecs20140526.Client;
+import com.aliyun.ecs20140526.models.DescribeInstancesRequest;
+import com.aliyun.ecs20140526.models.DescribeInstancesResponse;
+import com.aliyun.ecs20140526.models.DescribeInstancesResponseBody;
+import com.aliyun.tea.TeaException;
+import com.muyu.common.config.AliConfig;
+import com.muyu.common.domain.InstanceInfo;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @ClassName AliYunRcsService //类名称
+ * @Author: yannan //作者
+ * @CreateDate: 2024/4/16 20:49 //创建时间
+ * 阿里云ECS服务器OpenAPI调出
+ */
+@Service
+public class AliYunRcsService {
+
+
+ private final AliConfig aliConfig;
+
+ private final Client client;
+
+
+
+ public AliYunRcsService(AliConfig aliConfig, Client client){
+ this.aliConfig = aliConfig;
+ this.client=client;
+ }
+
+
+
+ public List selectECS(String instanceName) throws Exception {
+ DescribeInstancesRequest describeInstancesRequest = new DescribeInstancesRequest()
+ .setRegionId(aliConfig.getRegionId())
+ .setInstanceName(instanceName)
+ .setPageSize(10);
+
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+
+ List instanceInfos = new ArrayList<>(); // 用于存储查询到的实例信息
+
+ try {
+ DescribeInstancesResponse describeInstancesResponse = client.describeInstancesWithOptions(describeInstancesRequest, runtime);
+ DescribeInstancesResponseBody body = describeInstancesResponse.getBody();
+ DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstances instances = body.getInstances();
+ List instanceList = instances.getInstance();
+
+ // 修改 selectECS 方法中 IP 地址的处理部分
+ for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance item : instanceList) {
+ InstanceInfo instanceInfo = new InstanceInfo();
+ instanceInfo.setInstanceId(item.getInstanceId());
+ instanceInfo.setInstanceName(item.getInstanceName());
+ // 将 IP 地址对象转换为字符串，并存储到 InstanceInfo 对象中
+ // 在您的代码中将 IP 地址转换为字符串的部分可以改为以下方式
+
+
+
+ String publicIpAddress = item.getPublicIpAddress().getIpAddress().toString();
+// 去掉方括号
+ publicIpAddress = publicIpAddress.substring(1, publicIpAddress.length() - 1);
+ instanceInfo.setPublicIpAddress(publicIpAddress);
+
+ String privateIpAddress = item.getVpcAttributes().getPrivateIpAddress().ipAddress.toString();
+// 去掉方括号
+ privateIpAddress = privateIpAddress.substring(1, privateIpAddress.length() - 1);
+ instanceInfo.setPrivateIpAddress(privateIpAddress);
+ instanceInfos.add(instanceInfo);
+ }
+ } catch (TeaException error) {
+ error.printStackTrace();
+ // 异常处理
+ } catch (Exception _error) {
+ _error.printStackTrace();
+ // 异常处理
+ }
+
+ return instanceInfos;
+ }
+
+
+
+}
diff --git a/src/main/java/com/muyu/common/config/AliConfig.java b/src/main/java/com/muyu/common/config/AliConfig.java
new file mode 100644
index 0000000..6802ae3
--- /dev/null
+++ b/src/main/java/com/muyu/common/config/AliConfig.java
@@ -0,0 +1,55 @@
+package com.muyu.common.config;
+
+import com.aliyun.ecs20140526.Client;
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @ClassName AliConfig //类名称
+ * @Author: yn //作者
+ * @CreateDate: 2024-4-16 20:41 //创建时间
+ */
+@Configuration
+@ConfigurationProperties(prefix = "config.aly")
+@Data
+public class AliConfig {
+
+
+ /**
+ * access-key-id
+ */
+ private String accessKeyId;
+
+ /**
+ *access-key-secret
+ */
+ private String accessKeySecret;
+
+
+ /**
+ * 地域ID
+ */
+ private String regionId;
+
+
+
+ @Bean
+ public static Client createClient(AliConfig aliConfig) throws Exception {
+ // 工程代码泄露可能会导致 AccessKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考。
+ // 建议使用更安全的 STS 方式，更多鉴权访问方式请参见：https://help.aliyun.com/document_detail/378657.html。
+ com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
+ // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
+ .setAccessKeyId(aliConfig.accessKeyId)
+ // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
+ .setAccessKeySecret(aliConfig.getAccessKeySecret());
+ // Endpoint 请参考 https://api.aliyun.com/product/Ecs
+ config.endpoint = "ecs.cn-shanghai.aliyuncs.com";
+ return new Client(config);
+ }
+
+
+
+
+}
diff --git a/src/main/java/com/muyu/common/config/ClientConfig.java b/src/main/java/com/muyu/common/config/ClientConfig.java
new file mode 100644
index 0000000..724bf0e
--- /dev/null
+++ b/src/main/java/com/muyu/common/config/ClientConfig.java
@@ -0,0 +1,27 @@
+package com.muyu.common.config;
+
+import com.aliyun.ecs20140526.Client;
+
+/**
+ * @author yn
+ * @description TODO
+ * @date 2024-04-13 12:40
+ */
+public class ClientConfig {
+
+
+
+ public static Client createClient() throws Exception {
+ // 工程代码泄露可能会导致 AccessKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考。
+ // 建议使用更安全的 STS 方式，更多鉴权访问方式请参见：https://help.aliyun.com/document_detail/378657.html。
+ com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
+ // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
+ .setAccessKeyId("LTAI5tPDLpTbAX9bUSrTSrPH")
+ // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
+ .setAccessKeySecret("rbLG6bh8ZSttUPMxUspk9j8XLzvLU0");
+ // Endpoint 请参考 https://api.aliyun.com/product/Ecs
+ config.endpoint = "ecs.cn-shanghai.aliyuncs.com";
+ return new Client(config);
+ }
+
+}
diff --git a/src/main/java/com/muyu/common/config/CreateAnConfig.java b/src/main/java/com/muyu/common/config/CreateAnConfig.java
new file mode 100644
index 0000000..f811fa6
--- /dev/null
+++ b/src/main/java/com/muyu/common/config/CreateAnConfig.java
@@ -0,0 +1,329 @@
+package com.muyu.common.config;
+
+import com.aliyun.ecs20140526.Client;
+import com.aliyun.ecs20140526.models.*;
+import com.aliyun.tea.TeaException;
+import com.aliyun.tea.TeaModel;
+import com.aliyun.teaopenapi.models.Config;
+
+import com.muyu.common.contents.CreateContents;
+import com.muyu.common.domain.CreateVo;
+import com.muyu.common.domain.DeleteServer;
+import com.muyu.common.domain.Icreate;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @author yn
+ * @description 实例创建-查询-删除
+ * @date 2024-04-12 15:10
+ */
+@Component
+public class CreateAnConfig {
+
+
+ /**
+ * Initialization 初始化公共请求参数
+ */
+ public static Client Initialization(String regionId) throws Exception {
+ Config config = new Config();
+ // 您的AccessKey ID
+ config.accessKeyId = CreateContents.ACCESSKEYIDDATA;
+ // 您的AccessKey Secret
+ config.accessKeySecret = CreateContents.ACCESSKEYSECRETDATA;
+ // 您的可用区ID
+ config.regionId = regionId;
+ return new Client(config);
+ }
+
+
+
+ static int i = 1;
+
+ public static void main(String[] args_) throws Exception {
+ System.setOut(new java.io.PrintStream(System.out, true, "UTF-8"));
+ List args = java.util.Arrays.asList(args_);
+ Client client = ClientConfig.createClient();
+ DescribeInstancesRequest describeInstancesRequest = new DescribeInstancesRequest()
+ .setRegionId("cn-shanghai")
+ .setInstanceName("Test-server")
+ .setPageSize(10);
+
+ com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
+
+ try {
+ // 复制代码运行请自行打印 API 的返回值
+ DescribeInstancesResponse describeInstancesResponse = client.describeInstancesWithOptions(describeInstancesRequest, runtime);
+ DescribeInstancesResponseBody body = describeInstancesResponse.getBody();
+ DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstances instances = body.getInstances();
+ List instance = instances.getInstance();
+ instance.stream().forEach(item->{
+ System.out.println("实例{" + i + "}的ID:" + item.getInstanceId());
+ System.out.println("名称:" + item.getInstanceName());
+ System.out.println("地域ID:" + item.getRegionId());
+ System.out.println("状态:" + item.getStatus());
+ System.out.println("类型:" + item.getInstanceType());
+ System.out.println("CPU核心数:" + item.getCpu());
+ System.out.println("内存大小:" + item.getMemory() + "MB");
+ System.out.println("磁盘大小:" + item.getLocalStorageCapacity() + "G");
+ System.out.println("操作系统:" + item.getOSName());
+ System.out.println("网络类型:" + item.getInstanceNetworkType());
+ System.out.println("公网出带宽值:" + item.getInternetMaxBandwidthOut() + "Mbit/s");
+ System.out.println("公网入带宽值:" + item.getInternetMaxBandwidthIn() + "Mbit/s");
+ System.out.println("公网IP:" + item.getPublicIpAddress().getIpAddress());
+ System.out.println("私网IP:" + item.getVpcAttributes().getPrivateIpAddress().ipAddress);
+ System.out.println("专有网络VPCID:" + item.getVpcAttributes().getVpcId());
+ System.out.println("安全组ID:" + item.getSecurityGroupIds().getSecurityGroupId());
+ System.out.println("创建时间:" + item.getCreationTime());
+ System.out.println("到期时间:" + item.getExpiredTime());
+ System.out.println("是否可以回收:" + (item.getRecyclable()?"是":"否") + "\n\n");
+ i++;
+
+ });
+ } catch (TeaException error) {
+ // 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
+ // 错误 message
+ System.out.println(error.getMessage());
+ // 诊断地址
+ System.out.println(error.getData().get("Recommend"));
+ com.aliyun.teautil.Common.assertAsString(error.message);
+ } catch (Exception _error) {
+ TeaException error = new TeaException(_error.getMessage(), _error);
+ // 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
+ // 错误 message
+ System.out.println(error.getMessage());
+ // 诊断地址
+ System.out.println(error.getData().get("Recommend"));
+ com.aliyun.teautil.Common.assertAsString(error.message);
+ }
+ }
+
+
+
+ /**
+ * 查询实例方法
+ * @throws Exception
+ */
+ public static void findByCreate(CreateVo createVo) throws Exception {
+ //java.util.List args = java.util.Arrays.asList(args_);
+ // 地域Id
+ //String regionId = "cn-shanghai";
+ String regionId = createVo.getRedionId();
+ // 要查询的资源类型。取值范围：
+ // Zone：可用区。
+ // IoOptimized：I/O 优化。
+ // InstanceType：实例规格。
+ // SystemDisk：系统盘。
+ // DataDisk：数据盘。
+ // Network：网络类型。
+ // ddh：专有宿主机。
+ //String destinationResource = "InstanceType";
+ String destinationResource = createVo.getDestinationResource();
+ // 是否为I/O优化实例
+ // optimized：I/O优化
+ // none：非IO优化
+ //String ioOptimized = "optimized";
+ String ioOptimized = createVo.getIoOptimized();
+ // 实例规格
+ //说明: 如果您指定了InstanceType，则无法指定Cores或者Memory。
+ //String instanceType = "ecs.u1-c1m1.large";
+ String instanceType = createVo.getInstanceType();
+ Client client = CreateAnConfig.Initialization(regionId);
+ // 查询指定地域下所有可用区的库存供应情况
+ CreateAnConfig.DescribeAvailableResource(client, regionId, destinationResource, ioOptimized, instanceType);
+ }
+
+
+ /**
+ * DescribeAvailableResource 查询指定地域下所有可用区的库存供应情况
+ */
+ public static void DescribeAvailableResource(Client client, String regionId, String destinationResource, String ioOptimized, String instanceType) throws Exception {
+ System.setOut(new java.io.PrintStream(System.out, true, "UTF-8"));
+ DescribeAvailableResourceRequest request = new DescribeAvailableResourceRequest()
+ .setRegionId(regionId)
+ .setDestinationResource(destinationResource)
+ .setIoOptimized(ioOptimized)
+ .setInstanceType(instanceType);
+ try {
+ com.aliyun.teaconsole.Client.log("--------------------查询" + regionId + "地域下所有可用区的" + instanceType + "库存供应情况：--------------------");
+ DescribeAvailableResourceResponse responces = client.describeAvailableResource(request);
+ com.aliyun.teaconsole.Client.log("--------------------查询结果:" + com.aliyun.teautil.Common.toJSONString(TeaModel.buildMap(responces.body.availableZones)) + "--------------------");
+ } catch (TeaException error) {
+ com.aliyun.teaconsole.Client.log("--------------------查询失败:" + com.aliyun.teautil.Common.toJSONString(error.code) + "--------------------");
+
+ } catch (Exception _error) {
+ TeaException error = new TeaException(_error.getMessage(), _error);
+ com.aliyun.teaconsole.Client.log("--------------------查询失败:" + com.aliyun.teautil.Common.toJSONString(error.code) + "--------------------");
+
+ }
+ }
+
+
+ /**
+ * 创建实例方法
+ * @param icreate
+ * @throws Exception
+ */
+ public static String createAnServer(Icreate icreate) throws Exception {
+// java.util.List args = java.util.Arrays.asList(args_);
+ // 地域Id
+ //String regionId = "cn-shanghai";
+ String regionId = icreate.getRehionId();
+ // 镜像 ID，启动实例时选择的镜像资源。
+ // String imageId = "m-uf6elrscl3c9wk6o762l";
+ String imageId = icreate.getImageId();
+ // 实例规格
+ //String instanceType = "ecs.u1-c1m1.large";
+ String instanceType = icreate.getInstanceType();
+ // 新创建实例所属于的安全组 ID。
+ //String securityGroupId = "sg-uf6bj6vxp8ruhvffdsau";
+ String securityGroupId = icreate.getSecurityGroupId();
+ // 虚拟交换机 ID。
+ //String vSwitchId = "vsw-uf66jtgij0ptqxf1ix6l7 ";
+ String vSwitchId = icreate.getVSwitchId();
+ // 公网出带宽最大值，单位为 Mbit/s。取值范围：0~100。 默认值：0。
+ //Integer internetMaxBandwidthOut = Integer.parseInt("2");
+ Integer internetMaxBandwidthOut = Integer.parseInt(icreate.getInternetMaxBandwidthOut());
+ // 网络计费类型。取值范围：
+ // PayByBandwidth: 按固定带宽计费。
+ // PayByTraffic: 按使用流量计费。
+ // 默认值：PayByTraffic。
+ //String internetChargeType = "PayByTraffic";
+ String internetChargeType = icreate.getInternetChargeType();
+ // 系统盘大小
+ //String size = "20";
+ String size = icreate.getSize();
+ // 系统盘的云盘种类
+ //String category = "cloud_essd";
+ String category = icreate.getCategory();
+ // ECS实例的计费方式
+ // PrePaid：包年包月
+ // PostPaid：按量付费
+ //String instanceChargeType = "PostPaid";
+ String instanceChargeType = icreate.getInstanceChargeType();
+ Client client = CreateAnConfig.Initialization(regionId);
+ // 批量创建实例
+ String instances = CreateAnConfig.RunInstances(client, regionId, imageId, instanceType, securityGroupId, vSwitchId, internetMaxBandwidthOut, internetChargeType, size, category, instanceChargeType);
+
+ return instances;
+
+ }
+
+ /**
+ * RunInstances 通过备选实例规格创建ECS实例最佳实践
+ * 该场景中，在调用RunInstances创建ECS实例时判断是否发生库存不足等错误，如果发生错误，将调用DescribeRecommendInstanceType查询备选实例，然后通过备选实例规格重新创建ECS实例。
+ */
+ public static String RunInstances(Client client, String regionId, String imageId, String instanceType, String securityGroupId, String vSwitchId, Integer internetMaxBandwidthOut, String internetChargeType, String size, String category, String instanceChargeType) throws Exception {
+ System.setOut(new java.io.PrintStream(System.out, true, "UTF-8"));
+ RunInstancesRequest request1 = new RunInstancesRequest()
+ .setRegionId(regionId)
+ .setImageId(imageId)
+ .setInstanceType(instanceType)
+ .setSecurityGroupId(securityGroupId)
+ .setVSwitchId(vSwitchId)
+ .setInstanceName("Myname")
+ .setDescription("Myprocure")
+ .setInternetMaxBandwidthOut(internetMaxBandwidthOut)
+ .setInternetChargeType(internetChargeType)
+ .setInstanceChargeType(instanceChargeType)
+ // 批量创建五台ECS实例，如果不设置该参数，默认创建一台ECS实例。
+ // amount = 5,
+ // 如果缺少库存可以接受的最低创建数量。
+ // minAmount = 2,
+ // 打开预检参数功能，不会实际创建ECS实例，只检查参数正确性、用户权限或者ECS库存等问题。
+ // 实际情况下，设置了DryRun参数后，Amount必须为1，MinAmount必须为空，您可以根据实际需求修改代码。
+ .setDryRun(false)
+ .setSystemDisk(new RunInstancesRequest.RunInstancesRequestSystemDisk()
+ .setSize(size)
+ .setCategory(category));
+ RunInstancesResponse responces = client.runInstances(request1);
+ try {
+ com.aliyun.teaconsole.Client.log("--------------------批量创建实例开始--------------------");
+
+ com.aliyun.teaconsole.Client.log("--------------------创建实例成功，实例ID:" + com.aliyun.teautil.Common.toJSONString(responces.body.instanceIdSets.instanceIdSet) + "--------------------");
+ } catch (TeaException error) {
+ com.aliyun.teaconsole.Client.log("--------------------创建实例失败:" + error+ "--------------------");
+ } catch (Exception _error) {
+ TeaException error = new TeaException(_error.getMessage(), _error);
+ com.aliyun.teaconsole.Client.log("--------------------创建实例失败:" +error + "--------------------");
+
+
+ }
+ return com.aliyun.teautil.Common.toJSONString(responces.body.instanceIdSets.instanceIdSet);
+ }
+
+ public static DescribeInstancesResponse DescribeInstances(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(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(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)));
+ }
+
+ /**
+ * 批量删除实力
+ * @param deleteServer
+ * @throws Exception
+ */
+ public static void DeleServerCreateAn(DeleteServer deleteServer) throws Exception {
+ // 区域ID
+ //String regionId = "cn-shanghai";
+ String regionId = deleteServer.getRegionId();
+ // 多个实例ID，用英文逗号分隔
+ //String instanceIds = "i-uf6h4s0jtpvobykd7vzc";
+ String instanceIds = deleteServer.getInstanceIds();
+ // 实例名称，支持使用通配符*进行模糊搜索
+ //String instanceName = "MyFirstEcsInstance";
+ String instanceName = deleteServer.getInstanceName();
+ // 强制删除有删除保护的机器
+ //String deleteProtected = "true";
+ String deleteProtected = deleteServer.getDeleteProtected();
+ // 强制删除运行中的机器
+ //String force = "true";
+ String force = deleteServer.getForce();
+ Client client = CreateAnConfig.Initialization(regionId);
+ if (com.aliyun.teautil.Common.equalString(deleteProtected, force)) {
+ DescribeInstancesResponse describeInstancesResp = CreateAnConfig.DescribeInstances(client, regionId, instanceIds, instanceName);
+ instanceIds = "";
+ for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance instance : describeInstancesResp.body.instances.instance) {
+ instanceIds = "" + instance.instanceId + "," + instanceIds + "";
+ if (instance.deletionProtection) {
+ CreateAnConfig.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 ;
+ }
+
+ CreateAnConfig.DeleteInstances(client, regionId, instanceIds, force);
+ }
+}
diff --git a/src/main/java/com/muyu/common/config/FastJson2JsonRedisSerializer.java b/src/main/java/com/muyu/common/config/FastJson2JsonRedisSerializer.java
new file mode 100644
index 0000000..fb621d8
--- /dev/null
+++ b/src/main/java/com/muyu/common/config/FastJson2JsonRedisSerializer.java
@@ -0,0 +1,50 @@
+package com.muyu.common.config;
+
+import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONReader;
+import com.alibaba.fastjson2.JSONWriter;
+import com.alibaba.fastjson2.filter.Filter;
+import org.springframework.data.redis.serializer.RedisSerializer;
+import org.springframework.data.redis.serializer.SerializationException;
+
+import java.nio.charset.Charset;
+import java.nio.charset.StandardCharsets;
+
+/**
+ * Redis使用FastJson序列化
+ *
+ * @author muyu
+ */
+public class FastJson2JsonRedisSerializer implements RedisSerializer {
+
+ public static final String[] JSON_WHITELIST_STR = {"org.springframework", "com.muyu"};
+ public static final Charset DEFAULT_CHARSET = StandardCharsets.UTF_8;
+
+
+ static final Filter AUTO_TYPE_FILTER = JSONReader.autoTypeFilter(JSON_WHITELIST_STR);
+
+ private Class clazz;
+
+ public FastJson2JsonRedisSerializer (Class clazz) {
+ super();
+ this.clazz = clazz;
+ }
+
+ @Override
+ public byte[] serialize (T t) throws SerializationException {
+ if (t == null) {
+ return new byte[0];
+ }
+ return JSON.toJSONString(t, JSONWriter.Feature.WriteClassName).getBytes(DEFAULT_CHARSET);
+ }
+
+ @Override
+ public T deserialize (byte[] bytes) throws SerializationException {
+ if (bytes == null || bytes.length <= 0) {
+ return null;
+ }
+ String str = new String(bytes, DEFAULT_CHARSET);
+
+ return JSON.parseObject(str, clazz, AUTO_TYPE_FILTER);
+ }
+}
diff --git a/src/main/java/com/muyu/common/config/RedisConfig.java b/src/main/java/com/muyu/common/config/RedisConfig.java
new file mode 100644
index 0000000..2509d30
--- /dev/null
+++ b/src/main/java/com/muyu/common/config/RedisConfig.java
@@ -0,0 +1,43 @@
+package com.muyu.common.config;
+
+import org.springframework.boot.autoconfigure.AutoConfigureBefore;
+import org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration;
+import org.springframework.cache.annotation.CachingConfigurerSupport;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+/**
+ * redis配置
+ *
+ * @author muyu
+ */
+@Configuration
+@EnableCaching
+@AutoConfigureBefore(RedisAutoConfiguration.class)
+public class RedisConfig extends CachingConfigurerSupport {
+
+
+ @Bean
+ @SuppressWarnings(value = {"unchecked", "rawtypes"})
+ public RedisTemplate redisTemplate (RedisConnectionFactory connectionFactory) {
+ RedisTemplate template = new RedisTemplate<>();
+ template.setConnectionFactory(connectionFactory);
+
+ FastJson2JsonRedisSerializer serializer = new FastJson2JsonRedisSerializer(Object.class);
+
+ // 使用StringRedisSerializer来序列化和反序列化redis的key值
+ template.setKeySerializer(new StringRedisSerializer());
+ template.setValueSerializer(serializer);
+
+ // Hash的key也采用StringRedisSerializer的序列化方式
+ template.setHashKeySerializer(new StringRedisSerializer());
+ template.setHashValueSerializer(serializer);
+
+ template.afterPropertiesSet();
+ return template;
+ }
+}
diff --git a/src/main/java/com/muyu/common/contents/CreateContents.java b/src/main/java/com/muyu/common/contents/CreateContents.java
new file mode 100644
index 0000000..0fe28d3
--- /dev/null
+++ b/src/main/java/com/muyu/common/contents/CreateContents.java
@@ -0,0 +1,14 @@
+package com.muyu.common.contents;
+
+/**
+ * @author yn
+ * @description TODO
+ * @date 2024-04-12 16:22
+ */
+public class CreateContents {
+
+ //AccessKey ID值
+ public static final String ACCESSKEYIDDATA = "LTAI5tPDLpTbAX9bUSrTSrPH";
+ //您的AccessKey Secret
+ public static final String ACCESSKEYSECRETDATA = "rbLG6bh8ZSttUPMxUspk9j8XLzvLU0";
+}
diff --git a/src/main/java/com/muyu/common/domain/ApifoxModel.java b/src/main/java/com/muyu/common/domain/ApifoxModel.java
new file mode 100644
index 0000000..d8d23ec
--- /dev/null
+++ b/src/main/java/com/muyu/common/domain/ApifoxModel.java
@@ -0,0 +1,55 @@
+package com.muyu.common.domain;
+
+import lombok.Data;
+
+@Data
+public class ApifoxModel {
+ /**
+ * 节点ID
+ */
+ private String clusterId;
+ /**
+ * CPU使用信息
+ */
+ private CPUInfo cpuInfo;
+ /**
+ * 节点状态
+ */
+ private FlowInfo flowInfo;
+ /**
+ * HTTP请求地址
+ */
+ private String httpUrl;
+ /**
+ * JVM使用信息
+ */
+ private JVMInfo jvmInfo;
+ /**
+ * MQTT事件信息
+ */
+ private MqttInfo mqttInfo;
+ /**
+ * MQTTS请求地址
+ */
+ private String mqttsUrl;
+ /**
+ * MQTT请求地址
+ */
+ private String mqttUrl;
+ /**
+ * 节点名称
+ */
+ private String nodeName;
+ /**
+ * 启动时间
+ */
+ private String startJvmTime;
+ /**
+ * 节点版本
+ */
+ private String version;
+ /**
+ * websocket请求地址
+ */
+ private String websocketUrl;
+}
diff --git a/src/main/java/com/muyu/common/domain/CPUInfo.java b/src/main/java/com/muyu/common/domain/CPUInfo.java
new file mode 100644
index 0000000..10d27f3
--- /dev/null
+++ b/src/main/java/com/muyu/common/domain/CPUInfo.java
@@ -0,0 +1,30 @@
+package com.muyu.common.domain;
+
+import lombok.Data;
+
+/**
+ * CPU使用信息
+ */
+@Data
+public class CPUInfo {
+ /**
+ * CPU核数
+ */
+ private long cpuNum;
+ /**
+ * 内核态使用率
+ */
+ private String cSys;
+ /**
+ * 空闲率
+ */
+ private String idle;
+ /**
+ * I/O等待
+ */
+ private String iowait;
+ /**
+ * 用户态使用率
+ */
+ private String user;
+}
diff --git a/src/main/java/com/muyu/common/domain/CreateVo.java b/src/main/java/com/muyu/common/domain/CreateVo.java
new file mode 100644
index 0000000..2679147
--- /dev/null
+++ b/src/main/java/com/muyu/common/domain/CreateVo.java
@@ -0,0 +1,32 @@
+package com.muyu.common.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+/**
+ * @author yn
+ * @description TODO
+ * @date 2024-04-12 16:17
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@SuperBuilder
+public class CreateVo {
+
+ //地域ID
+ private String redionId = "cn-shanghai";
+
+ //查询资源类型,取值范围
+ private String destinationResource = "InstanceType";
+
+ //是否为I/O优化实例
+ private String ioOptimized = "optimized";
+
+ //实例规格
+ private String instanceType = "ecs.u1-c1m1.large";
+
+ private String instanceId;
+}
diff --git a/src/main/java/com/muyu/common/domain/DeleteServer.java b/src/main/java/com/muyu/common/domain/DeleteServer.java
new file mode 100644
index 0000000..2556390
--- /dev/null
+++ b/src/main/java/com/muyu/common/domain/DeleteServer.java
@@ -0,0 +1,32 @@
+package com.muyu.common.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+/**
+ * @author yn
+ * @description TODO
+ * @date 2024-04-12 19:14
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@SuperBuilder
+public class DeleteServer {
+ //区域ID
+ private String regionId = "cn-shanghai";
+
+ //多个实例ID，英文逗号隔开
+ private String instanceIds;
+
+ //实例名称，支持模糊查
+ private String instanceName;
+
+ //是否强制删除有删除保护的机器 默认 true
+ private String deleteProtected="true";
+
+ //是否强制删除运行中的机器 默认 true
+ private String force = "true";
+}
diff --git a/src/main/java/com/muyu/common/domain/FlowInfo.java b/src/main/java/com/muyu/common/domain/FlowInfo.java
new file mode 100644
index 0000000..ada9422
--- /dev/null
+++ b/src/main/java/com/muyu/common/domain/FlowInfo.java
@@ -0,0 +1,28 @@
+package com.muyu.common.domain;
+
+import lombok.Data; /**
+ * 节点状态
+ */
+@Data
+public class FlowInfo {
+ /**
+ * 上次读取吞吐量
+ */
+ private String lastReadThroughput;
+ /**
+ * 上次写入吞吐量
+ */
+ private String lastWriteThroughput;
+ /**
+ * 读取总吞吐量
+ */
+ private String readBytesHistory;
+ /**
+ * 实写字节
+ */
+ private String realWriteBytes;
+ /**
+ * 写入总吞吐量
+ */
+ private String writeBytesHistory;
+}
diff --git a/src/main/java/com/muyu/common/domain/Icreate.java b/src/main/java/com/muyu/common/domain/Icreate.java
new file mode 100644
index 0000000..59d83fa
--- /dev/null
+++ b/src/main/java/com/muyu/common/domain/Icreate.java
@@ -0,0 +1,48 @@
+package com.muyu.common.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+/**
+ * @author yn
+ * @description TODO
+ * @date 2024-04-12 16:25
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@SuperBuilder
+public class Icreate {
+
+ //地域ID
+ private String rehionId = "cn-shanghai";
+
+ //镜像ID
+ private String imageId = "m-uf6hu0jwys1efmiemfxl";
+
+ //实例规格
+ private String instanceType = "ecs.e-c1m1.large";
+
+ //安全组ID
+ private String securityGroupId = "sg-uf6bj6vxp8ruhvffdsau";
+
+ //虚拟交换机ID
+ private String vSwitchId = "vsw-uf6sfq669js64lwke0isv";
+
+ //公网出带宽最大值，单位为 Mbit/s。取值范围：0~100。 默认值：0。
+ private String internetMaxBandwidthOut = "2";
+
+ //网络计费类型，取值范围
+ private String internetChargeType = "PayByTraffic";
+
+ //系统盘大小
+ private String size = "20";
+
+ //系统盘的云盘种类
+ private String category = "cloud_essd";
+
+ //ECS实例的计费方式
+ private String instanceChargeType = "PostPaid";
+}
diff --git a/src/main/java/com/muyu/common/domain/InstanceInfo.java b/src/main/java/com/muyu/common/domain/InstanceInfo.java
new file mode 100644
index 0000000..e858d5e
--- /dev/null
+++ b/src/main/java/com/muyu/common/domain/InstanceInfo.java
@@ -0,0 +1,33 @@
+package com.muyu.common.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+import lombok.experimental.SuperBuilder;
+
+/**
+ * @author yn
+ * @description TODO
+ * @date 2024-04-13 18:41
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@SuperBuilder
+@ToString
+public class InstanceInfo{
+ private String instanceId;
+ private String instanceName;
+ private String publicIpAddress; // 将数据类型修改为字符串
+ private String privateIpAddress; // 将数据类型修改为字符串
+
+
+ public void setPublicIpAddress(String ipAddress) {
+ this.publicIpAddress = ipAddress;
+ }
+
+ public void setPrivateIpAddress(String ipAddress) {
+ this.privateIpAddress = ipAddress;
+ }
+}
diff --git a/src/main/java/com/muyu/common/domain/IsanJoin.java b/src/main/java/com/muyu/common/domain/IsanJoin.java
new file mode 100644
index 0000000..97e7a48
--- /dev/null
+++ b/src/main/java/com/muyu/common/domain/IsanJoin.java
@@ -0,0 +1,22 @@
+package com.muyu.common.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+/**
+ * @author yn
+ * @description TODO
+ * @date 2024-04-15 10:57
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@SuperBuilder
+public class IsanJoin {
+ //节点ID
+ private String insanId;
+ //连接数
+ private Integer countConntion;
+}
diff --git a/src/main/java/com/muyu/common/domain/JVMInfo.java b/src/main/java/com/muyu/common/domain/JVMInfo.java
new file mode 100644
index 0000000..76dc8bf
--- /dev/null
+++ b/src/main/java/com/muyu/common/domain/JVMInfo.java
@@ -0,0 +1,58 @@
+package com.muyu.common.domain;
+
+import lombok.Data;
+
+/**
+ * JVM使用信息
+ */
+@Data
+public class JVMInfo {
+ /**
+ * 文件描述(句柄)
+ */
+ private String fileDescriptors;
+ /**
+ * 堆内存
+ */
+ private String heapCommit;
+ /**
+ * 堆初始化空间
+ */
+ private String heapInit;
+ /**
+ * 堆最大内存
+ */
+ private String heapMax;
+ /**
+ * 堆使用空间
+ */
+ private String heapUsed;
+ /**
+ * JAVA目录
+ */
+ private String jdkHome;
+ /**
+ * JDK版本
+ */
+ private String jdkVersion;
+ /**
+ * 非堆空间
+ */
+ private String noHeapCommit;
+ /**
+ * 非堆初始化空间
+ */
+ private String noHeapInit;
+ /**
+ * 非堆最大空间
+ */
+ private String noHeapMax;
+ /**
+ * 非堆使用空间
+ */
+ private String noHeapUsed;
+ /**
+ * 线程数量
+ */
+ private long threadCount;
+}
diff --git a/src/main/java/com/muyu/common/domain/MqttInfo.java b/src/main/java/com/muyu/common/domain/MqttInfo.java
new file mode 100644
index 0000000..073413f
--- /dev/null
+++ b/src/main/java/com/muyu/common/domain/MqttInfo.java
@@ -0,0 +1,63 @@
+package com.muyu.common.domain;// ApifoxModel.java
+
+
+import lombok.Data;
+
+
+// JVMInfo.java
+
+
+// MqttInfo.java
+
+
+
+/**
+ * MQTT事件信息
+ */
+@Data
+public class MqttInfo {
+ /**
+ * 关闭事件数量
+ */
+ private long closeEventSize;
+ /**
+ * 连接事件数量
+ */
+ private long connectEventSize;
+ /**
+ * 链接总数
+ */
+ private long connectSize;
+ /**
+ * 断开链接数量
+ */
+ private long disconnectEventSize;
+ /**
+ * 推送数量
+ */
+ private long publishEventSize;
+ /**
+ * 发布重试事件数量
+ */
+ private long publishRetryEventSize;
+ /**
+ * 保留消息数量
+ */
+ private long retainSize;
+ /**
+ * 订阅事件数量
+ */
+ private long subscribeEventSize;
+ /**
+ * 订阅数量
+ */
+ private long subscribeSize;
+ /**
+ * 主题数量
+ */
+ private long topicSize;
+ /**
+ * 取消订阅数量
+ */
+ private long unSubscribeEventSize;
+}
diff --git a/src/main/java/com/muyu/common/domain/NodeRegReq.java b/src/main/java/com/muyu/common/domain/NodeRegReq.java
new file mode 100644
index 0000000..11599ce
--- /dev/null
+++ b/src/main/java/com/muyu/common/domain/NodeRegReq.java
@@ -0,0 +1,28 @@
+package com.muyu.common.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @author yn
+ * @description TODO
+ * @date 2024-04-13 8:33
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class NodeRegReq {
+
+ /**
+ * 客户端ID
+ */
+ private String clientId;
+
+ /**
+ * token
+ */
+ private String token;
+}
diff --git a/src/main/java/com/muyu/common/redis/RedisService.java b/src/main/java/com/muyu/common/redis/RedisService.java
new file mode 100644
index 0000000..115578c
--- /dev/null
+++ b/src/main/java/com/muyu/common/redis/RedisService.java
@@ -0,0 +1,336 @@
+package com.muyu.common.redis;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.*;
+import org.springframework.stereotype.Component;
+
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
+
+/**
+ * spring redis 工具类
+ *
+ * @author muyu
+ **/
+@SuppressWarnings(value = {"unchecked", "rawtypes"})
+@Component
+public class RedisService {
+ @Autowired
+ public RedisTemplate redisTemplate;
+
+ /**
+ * 缓存基本的对象，Integer、String、实体类等
+ *
+ * @param key 缓存的键值
+ * @param value 缓存的值
+ */
+ public void setCacheObject (final String key, final T value) {
+ redisTemplate.opsForValue().set(key, value);
+ }
+
+ public SetOperations opsForSet() {
+ return redisTemplate.opsForSet();
+ }
+ public HashOperations opsForHash() {
+ return (HashOperations) redisTemplate.opsForHash();
+ }
+
+ // 获取缓存集合的方法，返回 List
+ public List getCacheSets(String key) {
+ // 获取绑定的 Set 操作对象
+ BoundSetOperations setOperation = redisTemplate.boundSetOps(key);
+
+ // 获取 Redis 集合中的所有元素，并转换为 List
+ Set members = setOperation.members();
+ return members.stream()
+ .map(Object::toString)
+ .collect(Collectors.toList());
+ }
+
+ /**
+ * 减少序列值
+ * @param key
+ * @param number
+ * @return
+ */
+ public Long increment(final String key , Long number){
+ return redisTemplate.opsForValue().increment(key,number);
+ }
+ /**
+ * 向 Redis 集合中添加元素
+ * @param key Redis 集合的 key
+ * @param value 要添加的元素
+ * @return 如果元素不存在并成功添加返回 true，如果元素已经存在则返回 false
+ */
+ public boolean addToSet(String key, String value) {
+ Long added = redisTemplate.opsForSet().add(key, value);
+ return added == 1?true:false;
+ }
+ public ZSetOperations opsForZSet() {
+ return redisTemplate.opsForZSet();
+ }
+ /**
+ * 缓存基本的对象，Integer、String、实体类等
+ *
+ * @param key 缓存的键值
+ * @param value 缓存的值
+ * @param timeout 时间
+ * @param timeUnit 时间颗粒度
+ */
+ public void setCacheObject (final String key, final T value, final Long timeout, final TimeUnit timeUnit) {
+ redisTemplate.opsForValue().set(key, value, timeout, timeUnit);
+ }
+
+ /**
+ * 设置有效时间
+ *
+ * @param key Redis键
+ * @param timeout 超时时间
+ *
+ * @return true=设置成功；false=设置失败
+ */
+ public boolean expire (final String key, final long timeout) {
+ return expire(key, timeout, TimeUnit.SECONDS);
+ }
+
+ public ValueOperations opsForValue() {
+ return redisTemplate.opsForValue();
+ }
+ /**
+ * 设置有效时间
+ *
+ * @param key Redis键
+ * @param timeout 超时时间
+ * @param unit 时间单位
+ *
+ * @return true=设置成功；false=设置失败
+ */
+ public boolean expire (final String key, final long timeout, final TimeUnit unit) {
+ return redisTemplate.expire(key, timeout, unit);
+ }
+
+ /**
+ * 获取有效时间
+ *
+ * @param key Redis键
+ *
+ * @return 有效时间
+ */
+ public long getExpire (final String key) {
+ return redisTemplate.getExpire(key);
+ }
+
+ /**
+ * 判断 key是否存在
+ *
+ * @param key 键
+ *
+ * @return true 存在 false不存在
+ */
+ public Boolean hasKey (String key) {
+ return redisTemplate.hasKey(key);
+ }
+
+
+
+ /**
+ * 获得缓存的基本对象。
+ *
+ * @param key 缓存键值
+ *
+ * @return 缓存键值对应的数据
+ */
+ public T getCacheObject (final String key) {
+ ValueOperations operation = redisTemplate.opsForValue();
+ return operation.get(key);
+ }
+
+ /**
+ * 删除单个对象
+ *
+ * @param key
+ */
+ public boolean deleteObject (final String key) {
+ return redisTemplate.delete(key);
+ }
+
+ /**
+ * 删除集合对象
+ *
+ * @param collection 多个对象
+ *
+ * @return
+ */
+ public boolean deleteObject (final Collection collection) {
+ return redisTemplate.delete(collection) > 0;
+ }
+
+ /**
+ * 缓存List数据
+ *
+ * @param key 缓存的键值
+ * @param dataList 待缓存的List数据
+ *
+ * @return 缓存的对象
+ */
+ public long setCacheList (final String key, final List dataList) {
+ Long count = redisTemplate.opsForList().rightPushAll(key, dataList);
+ return count == null ? 0 : count;
+ }
+
+ /**
+ * 获得缓存的list对象
+ *
+ * @param key 缓存的键值
+ *
+ * @return 缓存键值对应的数据
+ */
+ public T getCacheList (final String key,Long index) {
+ return (T) redisTemplate.opsForList().index(key, index);
+ }
+ /**
+ * 缓存Set
+ *
+ * @param key 缓存键值
+ * @param dataSet 缓存的数据
+ *
+ * @return 缓存数据的对象
+ */
+ public BoundSetOperations setCacheSet (final String key, final Set dataSet) {
+ BoundSetOperations setOperation = redisTemplate.boundSetOps(key);
+ Iterator it = dataSet.iterator();
+ while (it.hasNext()) {
+ setOperation.add(it.next());
+ }
+ return setOperation;
+ }
+
+ /**
+ * 缓存Set
+ *
+ * @param key 缓存键值
+ * @param setValue 缓存的数据
+ *
+ * @return 缓存数据的对象
+ */
+ public BoundSetOperations setCacheSets (final String key, final T setValue) {
+ BoundSetOperations setOperation = redisTemplate.boundSetOps(key);
+ setOperation.add(setValue);
+ return setOperation;
+ }
+ /**
+ * 删除set值
+ *
+ * @param key 缓存键值
+ * @param setValue 缓存的数据
+ *
+ * @return 缓存数据的对象
+ */
+ public void deleteCachSet(String key, String setValue) {
+ BoundSetOperations setOperation = redisTemplate.boundSetOps(key);
+ setOperation.remove(setValue);
+ }
+ /**
+ * 获得缓存的set
+ *
+ * @param key
+ *
+ * @return
+ */
+ public Set getCacheSet (final String key) {
+ return redisTemplate.opsForSet().members(key);
+ }
+
+ /**
+ * 缓存Map
+ *
+ * @param key
+ * @param dataMap
+ */
+ public void setCacheMap (final String key, final Map dataMap) {
+ if (dataMap != null) {
+ redisTemplate.opsForHash().putAll(key, dataMap);
+ }
+ }
+
+ /**
+ * 获得缓存的Map
+ *
+ * @param key
+ *
+ * @return
+ */
+ public Map getCacheMap (final String key) {
+ return redisTemplate.opsForHash().entries(key);
+ }
+
+ /**
+ * 往Hash中存入数据
+ *
+ * @param key Redis键
+ * @param hKey Hash键
+ * @param value 值
+ */
+ public void setCacheMapValue (final String key, final String hKey, final T value) {
+ redisTemplate.opsForHash().put(key, hKey, value);
+ }
+
+ /**
+ * 获取Hash中的数据
+ *
+ * @param key Redis键
+ * @param hKey Hash键
+ *
+ * @return Hash中的对象
+ */
+ public T getCacheMapValue (final String key, final String hKey) {
+ HashOperations opsForHash = redisTemplate.opsForHash();
+ return opsForHash.get(key, hKey);
+ }
+
+ /**
+ * 获取多个Hash中的数据
+ *
+ * @param key Redis键
+ * @param hKeys Hash键集合
+ *
+ * @return Hash对象集合
+ */
+ public List getMultiCacheMapValue (final String key, final Collection