cloud-modules/cloud-modules-vehicle-gateway/pom.xml

@@ -107,12 +107,6 @@
             <groupId>com.aliyun</groupId>
             <artifactId>cloudapi20160714</artifactId>
         </dependency>
-
-        <!-- rabbitmq模块 -->
-        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>cloud-common-rabbit</artifactId>
-        </dependency>
     </dependencies>
 
     <repositories>

cloud-modules/cloud-modules-vehicle-gateway/src/main/java/com/muyu/vehiclegateway/controller/ConnectController.java

@@ -1,51 +0,0 @@
-package com.muyu.vehiclegateway.controller;
-
-import com.muyu.common.core.domain.Result;
-import com.muyu.vehiclegateway.domain.req.VehicleConnectionReq;
-import com.muyu.vehiclegateway.service.ConnectService;
-import io.swagger.v3.oas.annotations.tags.Tag;
-import lombok.extern.log4j.Log4j2;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
-
-import java.security.MessageDigest;
-import java.security.NoSuchAlgorithmException;
-
-/**
- * @ClassName ConnectController
- * @Description 连接车辆
- * @Author YiBo.Liu
- * @Date 2024/10/2 16:25
- */
-@RequestMapping("/vehicleGateway")
-@RestController
-@Log4j2
-@Tag(name = "连接车辆控制层")
-public class ConnectController {
-
-    @Autowired
-    private ConnectService connectService;
-
-    /**
-     * 获取车辆信息
-     * @param vehicleConnectionReq
-     * @return
-     */
-    @PostMapping("/receiveMsg/connect")
-    private Result receiveMsg(@RequestBody VehicleConnectionReq vehicleConnectionReq){
-        log.info("=======>" + vehicleConnectionReq);
-        connectService.receiveMsg(vehicleConnectionReq);
-        return Result.success();
-    }
-
-    /**
-     * 创建ECS实例
-     * @throws Exception
-     */
-    @GetMapping("/createConnect")
-    private void createConnect() throws Exception {
-        connectService.createConnect();
-        log.info("创建实例成功");
-    }
-
-}

cloud-modules/cloud-modules-vehicle-gateway/src/main/java/com/muyu/vehiclegateway/domain/ConnectMemory.java

@@ -1,37 +0,0 @@
-package com.muyu.vehiclegateway.domain;
-
-import io.swagger.v3.oas.annotations.tags.Tag;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-/**
- * @ClassName ConnectMemory
- * @Description 内存使用情况
- * @Author YiBo.Liu
- * @Date 2024/10/4 11:02
- */
-@Data
-@Builder
-@AllArgsConstructor
-@NoArgsConstructor
-@Tag(name = "服务器内存使用情况")
-public class ConnectMemory {
-
-    /**
-     * 节点ID
-     */
-    private String clusterId;
-
-    /**
-     * 所属IP
-     */
-    private String ipAddress;
-
-    /**
-     * 剩余连接数
-     */
-    private String remainingNum;
-
-}

cloud-modules/cloud-modules-vehicle-gateway/src/main/java/com/muyu/vehiclegateway/domain/Instance.java

@@ -1,37 +0,0 @@
-package com.muyu.vehiclegateway.domain;
-
-import io.swagger.v3.oas.annotations.tags.Tag;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-/**
- * @ClassName Instance
- * @Description 服务器数据
- * @Author YiBo.Liu
- * @Date 2024/9/30 20:42
- */
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-@Builder
-@Tag(name = "服务器数据")
-public class Instance {
-
-    /**
-     * 服务器ID
-     */
-    private String instanceId;
-
-    /**
-     * 服务器IP
-     */
-    private String ipAddress;
-
-    /**
-     * 服务器状态
-     */
-    private String status;
-
-}

cloud-modules/cloud-modules-vehicle-gateway/src/main/java/com/muyu/vehiclegateway/domain/MqttServerModel.java

@@ -1,32 +0,0 @@
-package com.muyu.vehiclegateway.domain;
-
-import io.swagger.v3.oas.annotations.tags.Tag;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-/**
- * @ClassName MqttServerModel
- * @Description 描述
- * @Author YiBo.Liu
- * @Date 2024/10/4 14:49
- */
-@Data
-@Builder
-@AllArgsConstructor
-@NoArgsConstructor
-@Tag(name = "mqtt服务器模型")
-public class MqttServerModel {
-
-    /**
-     * MQTT服务节点
-     */
-    private String broker;
-
-    /**
-     * MQTT订阅主题
-     */
-    private String topic;
-
-}

cloud-modules/cloud-modules-vehicle-gateway/src/main/java/com/muyu/vehiclegateway/domain/req/VehicleConnectionReq.java

@@ -1,44 +0,0 @@
-package com.muyu.vehiclegateway.domain.req;
-
-import com.alibaba.fastjson.annotation.JSONField;
-import com.baomidou.mybatisplus.annotation.TableField;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-/**
- * @ClassName VehicleConnectionReq
- * @Description 描述
- * @Author YiBo.Liu
- * @Date 2024/10/2 16:10
- */
-@Data
-@AllArgsConstructor
-@NoArgsConstructor
-@Builder
-public class VehicleConnectionReq {
-
-    /**
-     * id
-     */
-
-    private Integer id;
-
-    /**
-     * 车辆vin码
-     */
-    @JSONField(name = "vehicleVin")
-    private String vehicleVin;
-
-    /**
-     *时间戳
-     */
-    private String timestamp;
-
-    /**
-     * 随机字符串
-     */
-    private String nonce;
-
-}

cloud-modules/cloud-modules-vehicle-gateway/src/main/java/com/muyu/vehiclegateway/instance/GenerateInstance.java

@@ -9,12 +9,13 @@ import com.aliyun.tea.TeaException;
 import com.aliyun.teautil.Common;
 import com.aliyun.teautil.models.RuntimeOptions;
 import com.muyu.common.redis.service.RedisService;
-import com.muyu.vehiclegateway.domain.Instance;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
 
 import java.util.ArrayList;
@@ -22,7 +23,7 @@ import java.util.List;
 
 /**
  * @ClassName GenerateInstance
- * @Description 程序启动创建ECS服务器实例
+ * @Description 描述
  * @Author YiBo.Liu
  * @Date 2024/9/28 19:39
  */
@@ -39,7 +40,7 @@ public class GenerateInstance implements ApplicationRunner {
      * 启动自动创建实例
      * @throws Exception
      */
-    public List<Instance> generateInstance() throws Exception {
+    public List<String> generateInstance() throws Exception {
 
         // 创建ECS客户端对象，用于后续调用ECS相关API
         Client client = CreateClient.createClient();
@@ -51,7 +52,7 @@ public class GenerateInstance implements ApplicationRunner {
                 // 设置地域ID
                 .setRegionId("cn-shanghai")
                 // 设置镜像ID
-                .setImageId("m-uf6f7atj16s3cjn9q5l8")
+                .setImageId("m-uf63thq7h50ng72jpoq2")
                 // 设置实例类型
                 .setInstanceType("ecs.t6-c1m1.large")
                 // 设置安全组ID
@@ -104,29 +105,27 @@ public class GenerateInstance implements ApplicationRunner {
         DescribeInstancesResponse describeInstancesResponse = client.describeInstancesWithOptions(describeInstancesRequest, runtimeOptions);
 
         //提取实例ID集合
-        List<Instance> list = new ArrayList<>();
+        ArrayList<String> list = new ArrayList<>();
 
         DescribeInstancesResponseBody body = describeInstancesResponse.getBody();
 
         for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance instance : body.getInstances().getInstance()) {
+            list.add(instance.getInstanceId());
+            list.add(instance.getPublicIpAddress().ipAddress.get(0));
+            list.add(instance.getStatus());
 
             log.info("实例id为:"+instance.getInstanceId());
             log.info("实例ip为:"+instance.getPublicIpAddress().ipAddress.get(0));
             log.info("实例状态为:"+instance.getStatus());
 
-            Instance instance1 = new Instance(instance.getInstanceId(), instance.getPublicIpAddress().ipAddress.get(0), instance.getStatus());
-
-            list.add(instance1);
         }
 
-//        Thread.sleep(20000);
+        redisService.setCacheList("shili",list);
-//        redisService.setCacheList("aaa",list);
 
         return list;
 
     }
 
-
     @Override
     public void run(ApplicationArguments args) throws Exception {
         generateInstance();

cloud-modules/cloud-modules-vehicle-gateway/src/main/java/com/muyu/vehiclegateway/mapper/ConnectMapper.java

@@ -1,10 +0,0 @@
-package com.muyu.vehiclegateway.mapper;
-
-import com.muyu.vehiclegateway.domain.req.VehicleConnectionReq;
-import org.apache.ibatis.annotations.Mapper;
-
-@Mapper
-public interface ConnectMapper {
-    void addVehicle(VehicleConnectionReq vehicleConnectionReq);
-
-}

cloud-modules/cloud-modules-vehicle-gateway/src/main/java/com/muyu/vehiclegateway/service/ConnectService.java

@@ -1,21 +0,0 @@
-package com.muyu.vehiclegateway.service;
-
-import com.muyu.vehiclegateway.domain.req.VehicleConnectionReq;
-
-public interface ConnectService {
-
-    /**
-     * 创建实例
-     * @throws Exception
-     */
-    void createConnect() throws Exception;
-
-    /**
-     * 获取车辆信息
-     * @param vehicleConnectionReq
-     * @return
-     */
-    void receiveMsg(VehicleConnectionReq vehicleConnectionReq);
-
-
-}

cloud-modules/cloud-modules-vehicle-gateway/src/main/java/com/muyu/vehiclegateway/service/impl/ConnectServiceImpl.java

@@ -1,57 +0,0 @@
-package com.muyu.vehiclegateway.service.impl;
-
-import cn.hutool.json.JSON;
-import com.alibaba.fastjson2.JSONObject;
-import com.muyu.common.core.constant.GenConstants;
-import com.muyu.common.core.utils.uuid.UUID;
-import com.muyu.vehiclegateway.domain.req.VehicleConnectionReq;
-import com.muyu.vehiclegateway.instance.GenerateInstance;
-import com.muyu.vehiclegateway.mapper.ConnectMapper;
-import com.muyu.vehiclegateway.service.ConnectService;
-import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.core.RabbitTemplate;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
-import static io.lettuce.core.pubsub.PubSubOutput.Type.message;
-
-/**
- * @ClassName ConnectServiceImpl
- * @Description 描述
- * @Author YiBo.Liu
- * @Date 2024/10/2 16:25
- */
-@Service
-public class ConnectServiceImpl implements ConnectService {
-
-    @Autowired
-    private RabbitTemplate rabbitTemplate;
-
-
-    @Autowired
-    private ConnectMapper connectMapper;
-
-    /**
-     * 创建实例
-     * @throws Exception
-     */
-    @Override
-    public void createConnect() throws Exception {
-        GenerateInstance generateInstance = new GenerateInstance();
-        generateInstance.generateInstance();
-    }
-
-    /**
-     * 获取车辆信息
-     * @param vehicleConnectionReq
-     * @return
-     */
-    @Override
-    public void receiveMsg(VehicleConnectionReq vehicleConnectionReq) {
-        rabbitTemplate.convertAndSend("GO_OFFLINE", vehicleConnectionReq.getVehicleVin(),message1 -> {
-            message1.getMessageProperties().setMessageId(UUID.fastUUID().toString());
-            return message1;
-        });
-        connectMapper.addVehicle(vehicleConnectionReq);
-    }
-}

cloud-modules/cloud-modules-vehicle-gateway/src/main/resources/bootstrap.yml

@@ -40,8 +40,6 @@ spring:
         file-extension: yml
         # 共享配置
         shared-configs:
-          # rabbitmq配置
-          - application-rabbit-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
           # 系统共享配置
           - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
           # 系统环境Config共享配置

cloud-modules/cloud-modules-vehicle-gateway/src/main/resources/mapper/ConnectMapper.xml

@@ -1,10 +0,0 @@
-<?xml version="1.0" encoding="UTF-8" ?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-
-<mapper namespace="com.muyu.vehiclegateway.mapper.ConnectMapper">
-
-    <insert id="addVehicle">
-        insert into connect(id,vehicle_vin,timestamp,nonce)
-        values (#{id},#{vehicleVin},#{timestamp},#{nonce})
-    </insert>
-</mapper>