feat():修改ESC管理

cloud-modules/cloud-modules-vehiclegateway/pom.xml

@@ -102,6 +102,47 @@
             <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
             <version>1.2.5</version>
         </dependency>
+
+
+
+        <dependency>
+            <groupId>com.aliyun</groupId>
+            <artifactId>ecs20140526</artifactId>
+            <version>5.1.8</version>
+        </dependency>
+        <dependency>
+            <groupId>com.aliyun</groupId>
+            <artifactId>tea-openapi</artifactId>
+            <version>0.3.2</version>
+        </dependency>
+        <dependency>
+            <groupId>com.aliyun</groupId>
+            <artifactId>tea-console</artifactId>
+            <version>0.0.1</version>
+        </dependency>
+        <dependency>
+            <groupId>com.aliyun</groupId>
+            <artifactId>tea-util</artifactId>
+            <version>0.2.21</version>
+        </dependency>
+        <dependency>
+            <groupId>com.aliyun</groupId>
+            <artifactId>aliyun-java-sdk-ecs</artifactId>
+            <version>4.2.0</version><!-- 请根据实际情况使用最新的版本 -->
+        </dependency>
+
+        <dependency>
+            <groupId>com.muyu.server</groupId>
+            <artifactId>saas-server</artifactId>
+            <version>3.6.3</version>
+        </dependency>
+
+        <!-- Forest HTTP Client -->
+        <dependency>
+            <groupId>com.dtflys.forest</groupId>
+            <artifactId>forest-spring-boot-starter</artifactId>
+            <version>1.5.36</version>
+        </dependency>
     </dependencies>
 
     <build>

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/VehicleGatewayApplication.java

@@ -6,6 +6,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 
 @SpringBootApplication
 @EnableMyFeignClients
+
 public class VehicleGatewayApplication {
     public static void main(String[] args) {
         SpringApplication.run(VehicleGatewayApplication.class,args);

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/ManageInstance.java

@@ -0,0 +1,132 @@
+package com.muyu.vehicle;
+
+import com.aliyun.ecs20140526.Client;
+import com.aliyun.ecs20140526.models.*;
+import com.aliyun.tea.TeaException;
+import com.aliyun.teaopenapi.models.Config;
+import com.aliyun.teautil.Common;
+import com.aliyun.teautil.models.RuntimeOptions;
+import com.muyu.common.redis.service.RedisService;
+import com.muyu.vehicle.config.SelectInstance;
+import com.muyu.vehicle.domain.InstanceInfo;
+import com.muyu.vehicle.utils.CreateClient;
+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.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+
+
+@Component
+@Log4j2
+/**
+ * 项目启动创建实例
+ */
+public class ManageInstance implements ApplicationRunner {
+    @Autowired
+    private RedisService redisService;
+
+        /**
+         * 镜像ID
+         */
+        public static final String IMAGE_ID = "m-uf6ffgkry85fwu4znr6s";
+
+        /**
+         * 实例类型
+         */
+        public static final String INSTANCE_TYPE = "ecs.e-c1m1.large";
+
+        /**
+         * 安全组ID
+         */
+        public static final String SECURITY_GROUP_ID = "sg-uf6glo8c4k17szhxu7sk";
+
+        /**
+         *交换机ID
+         */
+        public static final String V_SWITCH_ID = "vsw-uf6xy4rbt9ggcz93t6oib";
+
+
+        /**
+         * 实例付费类型
+         */
+        public static final String INSTANCE_CHARGE_TY = "PostPaid";
+
+        public static List<String> generateInstance() throws Exception {
+            // 创建阿里云ECS客户端
+            // 创建ECS客户端对象，用于后续调用ECS相关API
+            Client client = CreateClient.createClient();
+            // 配置系统盘参数
+            RunInstancesRequest.RunInstancesRequestSystemDisk systemDisk =
+                    new RunInstancesRequest.RunInstancesRequestSystemDisk()
+                            .setSize("40")
+                            .setCategory("cloud_essd");
+
+            // 创建创建实例请求对象并设置参数
+
+            RunInstancesRequest runInstancesRequest = new RunInstancesRequest()
+                    .setRegionId("cn-shanghai") // 设置地域ID
+                    .setImageId(IMAGE_ID) // 设置镜像ID
+                    .setInstanceType(INSTANCE_TYPE) // 设置实例类型
+                    .setSecurityGroupId(SECURITY_GROUP_ID) // 设置安全组ID
+                    .setVSwitchId(V_SWITCH_ID) // 设置虚拟交换机ID
+                    .setInstanceName("cloud-MQTT") // 设置实例名称
+                    .setInstanceChargeType(INSTANCE_CHARGE_TY) // 设置实例付费类型为后付费按量付费
+                    .setSystemDisk(systemDisk) // 设置系统盘配置
+                    .setHostName("root") // 设置主机名
+                    .setPassword("2112A-four") // 设置实例密码
+                    .setAmount(2) // 设置创建实例的数量
+                    .setInternetChargeType("PayByTraffic")
+                    .setInternetMaxBandwidthOut(1);
+
+
+            //创建运行时选择对象
+            RuntimeOptions runTime =
+                    new RuntimeOptions();
+            // 尝试执行创建实例请求
+            try {
+                ArrayList<String> list = new ArrayList<>();
+                // 复制代码运行请自行打印 API 的返回值
+                RunInstancesResponse runInstancesResponse = client.runInstancesWithOptions(runInstancesRequest, runTime);
+                RunInstancesResponseBody body = runInstancesResponse.getBody();
+                for (String instance : body.getInstanceIdSets().getInstanceIdSet()) {
+                    list.add(instance);
+                }
+                log.info("ESC创建成功,实例ID为:" + list);
+                return list;
+            } catch (TeaException error) {
+                // 错误 message
+                log.info(error.getMessage());
+                // 诊断地址
+                log.info(error.getData().get("Recommend"));
+                Common.assertAsString(error.message);
+            } catch (Exception _error) {
+                TeaException error = new TeaException(_error.getMessage(), _error);
+                // 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
+                // 错误 message
+                log.info("实例创建失败:" + error.getMessage());
+            }
+            return null;
+        }
+
+
+        @Override
+        public void run(ApplicationArguments args) throws Exception {
+            List<String> list = generateInstance();
+            log.info("创建实例成功");
+            log.info("正在加载实例");
+            Thread.sleep(30000);
+            List<InstanceInfo> instanceInfos = SelectInstance.selectInstance(list);
+            log.info("实例信息加载成功");
+            for (InstanceInfo instanceInfo : instanceInfos) {
+                redisService.getCacheObject(instanceInfo.getInstanceId());
+            } log.info("实例信息:{}",instanceInfos);
+
+        }
+    }
+
+

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/VehicleInstance.java

@@ -1,132 +0,0 @@
-package com.muyu.vehicle;
-
-import com.alibaba.fastjson.JSONObject;
-import com.muyu.web.common.ScheduledThreadPool;
-import com.muyu.web.domain.MqttProperties;
-import com.muyu.web.domain.VehicleInfo;
-import com.muyu.web.domain.model.PositionModel;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-import lombok.extern.log4j.Log4j2;
-import org.eclipse.paho.client.mqttv3.MqttClient;
-import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
-import org.eclipse.paho.client.mqttv3.MqttException;
-import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
-
-import java.util.Objects;
-import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.ScheduledFuture;
-
-@Data
-@Builder
-@Log4j2
-@NoArgsConstructor
-@AllArgsConstructor
-public class VehicleInstance {
-    /**
-     * 路线轨迹编码
-     */
-    private String positionCode;
-
-    /**
-     * 路径队列
-     */
-    private LinkedBlockingQueue<PositionModel> positionQueue=new LinkedBlockingQueue<>();
-
-    /**
-     * 车辆
-     */
-    private VehicleInfo vehicleInfo;
-
-    /**
-     * 车辆工作线程
-     */
-    private VehicleThread vehicleThread;
-
-    /**
-     * MQTT配置
-     */
-    private MqttProperties mqttProperties;
-
-    /**
-     * 线程提交回调
-     */
-    private ScheduledFuture<?>scheduledFuture;
-
-    /**
-     * 连接上报
-     */
-    private MqttClient client;
-
-
-    /**
-     * 获取当前车辆VIN
-     */
-    public String getVin(){
-        return this.vehicleInfo.getVin();
-    }
-    /**
-     * 获取车辆租户信息
-     */
-    public String getTenantId(){
-        return this.vehicleInfo.getTenantId();
-    }
-
-    /**
-     * 发送消息
-     */
-    public void sengMsg(String msg){
-
-    }
-
-
-    /**
-     * 初始化客户端
-     */
-    public void initClient(){
-        try {
-            client = new MqttClient(mqttProperties.getBroker(), mqttProperties.getClientId(), new MemoryPersistence());
-            MqttConnectOptions options = new MqttConnectOptions();
-            //设置用户名和密码
-            if (Objects.nonNull(mqttProperties.getUserName())&&Objects.nonNull(mqttProperties.getPassword())){
-             options.setUserName(mqttProperties.getUserName());
-             options.setPassword(mqttProperties.getPassword().toCharArray());
-            }
-            options.setConnectionTimeout(1);
-            options.setKeepAliveInterval(20);
-            //连接
-            client.connect(options);
-            log.debug("车辆:[{}]客户端初始化成功连接配置:{}",getVin(),
-                    JSONObject.toJSONString(this.mqttProperties)
-            );
-            VehicleThread vehicleThread = new VehicleThread();
-            vehicleThread.setVehicleInstance(this);
-            this.setVehicleThread(vehicleThread);
-            ScheduledFuture<?> submit = ScheduledThreadPool.submit(vehicleThread);
-            this.setScheduledFuture(submit);
-            log.info("初始化车辆上报模拟线程开始：[{}]", this.getVin());
-        } catch (MqttException e) {
-            log.error("车辆：[{}] 客户端初始化异常", getVin(), e);
-            throw new RuntimeException(e);
-        }
-    }
-
-    /**
-     * 是否连接在线
-     */
-    public boolean isOnline(){
-        if (this.client==null){
-            return false;
-        }
-        return this.client.isConnected();
-    }
-
-    /**
-     * 是否建立车辆模拟线程
-     */
-    public boolean isSend(){
-        return this.vehicleThread!=null;
-    }
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/VehicleThread.java

@@ -1,24 +0,0 @@
-package com.muyu.vehicle;
-
-import lombok.Data;
-import lombok.extern.log4j.Log4j2;
-
-@Data
-@Log4j2
-public class VehicleThread implements Runnable{
-    /**
-     * 是否停止线程
-     */
-    private volatile boolean isStop;
-
-    /**
-     * 车辆实例对象
-     */
-    private VehicleInstance vehicleInstance;
-    @Override
-    public void run() {
-        if (!isStop){
-            log.info("{}-上报数据",this.vehicleInstance.getVin());
-        }
-    }
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/api/ClientAdmin.java

@@ -1,12 +0,0 @@
-package com.muyu.vehicle.api;
-
-/**
- * 客户端管理
- */
-public interface ClientAdmin {
-    /**
-     * 获取车辆负载地址
-     */
-
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/config/CloseInstance.java

@@ -0,0 +1,99 @@
+package com.muyu.vehicle.config;
+import com.aliyun.ecs20140526.Client;
+import com.aliyun.ecs20140526.models.DeleteInstancesRequest;
+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.aliyun.teaopenapi.models.Config;
+import com.aliyun.teautil.Common;
+import com.aliyun.teautil.models.RuntimeOptions;
+import com.muyu.vehicle.utils.CreateClient;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.beans.factory.DisposableBean;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+
+/**
+ * 删除实例信息
+ */
+@Component
+@Log4j2
+public class CloseInstance implements DisposableBean{
+
+    /**
+     * <b>description</b> :
+     * <p>使用AK&amp;SK初始化账号Client</p>
+     * @return Client
+     *
+     * @throws Exception
+     */
+    public static void delInstance() throws Exception {
+
+        // 创建ECS客户端对象，用于后续调用ECS相关API
+        Client client = CreateClient.createClient();
+
+        DescribeInstancesRequest describeInstancesRequest = new DescribeInstancesRequest()
+                .setRegionId("cn-shanghai");
+
+        //创建运行时选择对象,用于配置运行时的选项参数
+        RuntimeOptions runtimeOptions = new RuntimeOptions();
+
+        //获取实例列表
+        DescribeInstancesResponse describeInstancesResponse = client.describeInstancesWithOptions(describeInstancesRequest, runtimeOptions);
+
+        //提取实例ID集合
+        ArrayList<String> list = new ArrayList<>();
+        DescribeInstancesResponseBody body = describeInstancesResponse.getBody();
+
+        for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance instance : body.getInstances().getInstance()) {
+            if (!instance.getInstanceId().equals("i-uf68jwsbbqq4b4xc893s")) {
+                list.add(instance.getInstanceId());
+            }
+        }
+        log.info("搜索到实例Instance IDs: " + list);
+        // 创建删除实例请求对象，并设置请求参数
+        DeleteInstancesRequest deleteInstancesRequest = new DeleteInstancesRequest()
+                // 设置地域ID，指定删除实例的地域
+                .setRegionId("cn-shanghai")
+                // 设置DryRun为true，用于验证请求是否可以成功，但不实际执行删除操作
+                .setDryRun(false)
+                // 设置Force为true，表示即使实例有正在运行的任务，也强制删除实例
+                .setForce(true)
+                // 设置TerminateSubscription为true，表示删除按订阅付费的实例时终止订阅
+                .setTerminateSubscription(true)
+                .setInstanceId(list);
+
+        // 创建运行时选项对象，用于配置运行时的选项参数
+        RuntimeOptions runtime = new RuntimeOptions();
+        try {
+            // 复制代码运行请自行打印 API 的返回值
+            client.deleteInstancesWithOptions(deleteInstancesRequest, runtime);
+        } catch (TeaException error) {
+            // 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
+            // 错误 message
+            log.info(error.getMessage());
+            // 诊断地址
+            log.info(error.getData().get("Recommend"));
+            Common.assertAsString(error.message);
+        } catch (Exception _error) {
+            TeaException error = new TeaException(_error.getMessage(), _error);
+            // 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
+            // 错误 message
+            System.out.println(error.getMessage());
+            // 诊断地址
+            log.info(error.getData().get("Recommend"));
+            Common.assertAsString(error.message);
+        }
+    }
+
+
+    @Override
+    public void destroy() throws Exception {
+        log.info("开始删除实例");
+        delInstance();
+    }
+}
+
+

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/config/RestTemplateConfig.java

@@ -0,0 +1,29 @@
+package com.muyu.vehicle.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.http.client.ClientHttpRequestFactory;
+import org.springframework.http.client.SimpleClientHttpRequestFactory;
+import org.springframework.web.client.RestTemplate;
+
+@Configuration
+public class RestTemplateConfig {
+
+
+
+    @Bean
+    public RestTemplate restTemplate(ClientHttpRequestFactory factory){
+        return new RestTemplate(factory);
+    }
+
+
+
+    @Bean
+    public ClientHttpRequestFactory simpleClientHttpRequestFactory() {
+        SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
+        //超时设置
+        factory.setReadTimeout(5000);//ms
+        factory.setConnectTimeout(15000);//ms
+        return factory;
+    }
+}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/config/SelectInstance.java

@@ -0,0 +1,53 @@
+package com.muyu.vehicle.config;
+
+import com.alibaba.fastjson.JSON;
+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.teautil.Common;
+import com.aliyun.teautil.models.RuntimeOptions;
+import com.muyu.vehicle.domain.InstanceInfo;
+import com.muyu.vehicle.utils.CreateClient;
+import lombok.extern.log4j.Log4j2;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 查询实例信息
+ */
+
+@Log4j2
+public class SelectInstance {
+    public static List<InstanceInfo> selectInstance(List<String> instanceIds) throws Exception {
+        // 创建ECS客户端对象，用于后续调用ECS相关API
+        Client client = CreateClient.createClient();
+        ArrayList<InstanceInfo> instanceInfos = new ArrayList<>();// 实例基础信息
+        com.aliyun.ecs20140526.models.DescribeInstancesRequest describeInstancesRequest = new com.aliyun.ecs20140526.models.DescribeInstancesRequest()
+                .setInstanceIds(JSON.toJSONString(instanceIds))
+                .setRegionId("cn-shanghai");
+        // 创建运行时选项对象
+        RuntimeOptions runtime = new RuntimeOptions();
+        //实例ID Instances.Instance.InstanceId
+        //实例IP Instances.Instance.PublicIpAddress.IpAddress
+        //状态 Instances.Instance.Status
+        DescribeInstancesResponse resp = client.describeInstancesWithOptions(describeInstancesRequest, runtime);
+        DescribeInstancesResponseBody body = resp.getBody();
+
+        ArrayList<InstanceInfo> exampleInformations = new ArrayList<>();
+        for (DescribeInstancesResponseBody.DescribeInstancesResponseBodyInstancesInstance instance : body.getInstances().getInstance()){
+            InstanceInfo instanceInfo = new InstanceInfo();
+            instanceInfo.setInstanceId(instance.getInstanceId());
+            log.info("实例ID:{}",instanceInfo.getInstanceId());
+            instanceInfo.setStatus(instance.getStatus());
+            log.info("实例状态:{}",instanceInfo.getStatus());
+            instanceInfo.setIpAddress(String.valueOf(instance.getPublicIpAddress().getIpAddress()));
+            log.info("实例IP:{}",instanceInfo.getIpAddress());
+            exampleInformations.add(instanceInfo);
+        }
+        log.info("实例信息:{}",instanceInfos);
+        return instanceInfos;
+    }
+
+}

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

@@ -0,0 +1,19 @@
+package com.muyu.vehicle.controller;
+import com.muyu.common.core.domain.Result;
+import com.muyu.vehicle.domain.req.VehicleConnectionReq;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@Log4j2
+public class CarInstanceController {
+
+
+
+    @PostMapping("/receiveMsg/connect")
+    public Result receiveMsg(@RequestBody VehicleConnectionReq vehicleConnectionReq){
+        log.info("=======>"+vehicleConnectionReq);
+        return Result.success();
+    }
+
+}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/core/LocalContainer.java

@@ -1,24 +0,0 @@
-package com.muyu.vehicle.core;
-
-import com.muyu.vehicle.VehicleInstance;
-
-import java.util.Map;
-import java.util.concurrent.ConcurrentHashMap;
-
-public class LocalContainer {
-    private static final Map<String,Map<String, VehicleInstance>> tenantVehicleDataMap
-            =new ConcurrentHashMap<>();
-
-    /**
-     * 获取租户ID下车辆
-     */
-    public static Map<String,VehicleInstance>getVehicleDataMap(String tenantId){
-        return tenantVehicleDataMap.computeIfAbsent(tenantId,k->new ConcurrentHashMap<>());
-    }
-
-    /**
-     *
-     */
-
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/core/VehicleConfiguration.java

@@ -1,13 +0,0 @@
-package com.muyu.vehicle.core;
-
-import lombok.AllArgsConstructor;
-import lombok.extern.log4j.Log4j2;
-import org.springframework.boot.ApplicationArguments;
-import org.springframework.boot.ApplicationRunner;
-import org.springframework.context.annotation.Configuration;
-
-@Log4j2
-@Configuration
-@AllArgsConstructor
-public class VehicleConfiguration {
-}

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

@@ -1,16 +1,20 @@
-package com.muyu.web.domain;
+package com.muyu.vehicle.domain;
 
 import lombok.AllArgsConstructor;
+import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
 /**
- * mqtt配置类
+ * fluxMq配置
  */
 @Data
-@AllArgsConstructor
+@Builder
 @NoArgsConstructor
-public class MqttProperties {
+@AllArgsConstructor
+public class FluxMqProperties {
+
+
     /**
      * 节点
      */
@@ -20,11 +24,6 @@ public class MqttProperties {
      * 主题
      */
     private String topic;
-    /**
-     * 用户名
-     */
-    private String userName;
-
     /**
      * 密码
      */
@@ -34,9 +33,8 @@ public class MqttProperties {
      * 节点ID
      */
     private String clientId;
-    /**
-     * 上报级别
-     */
-    private int qos=0;
+
+
+
 
 }

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

@@ -0,0 +1,21 @@
+package com.muyu.vehicle.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * 网关实例信息
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class InstanceInfo {
+
+ //实例ID
+    private String InstanceId;
+
+    private String IpAddress;
+
+    private String status;
+}

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

@@ -0,0 +1,28 @@
+package com.muyu.vehicle.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ *  Mqtt服务器模型
+ * @author YunFei.Du
+ * @date  22:08 2024/5/29
+ */
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class MqttServerModel {
+
+    /**
+     * MQTT服务节点
+     */
+    private String broker;
+
+    /**
+     * MQTT订阅主题
+     */
+    private String topic;
+}

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

@@ -1,34 +1,36 @@
-package com.muyu.web.domain.req;
+package com.muyu.vehicle.domain.req;
 
-import com.alibaba.fastjson.annotation.JSONField;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
+/**
+ * 车辆连接信息
+ */
 @Data
 @Builder
-@NoArgsConstructor
 @AllArgsConstructor
+@NoArgsConstructor
 public class VehicleConnectionReq {
 
-    @JSONField(name = "vin")
-    private String vin;
+    private String vehicleVin;
 
     /**
      * 时间戳
      */
-    private String timestamp;
 
+    private String timestamp;
 
     /**
      * 用户名
      */
-    @JSONField(name = "username")
-    private String userName;
+
+    private String username;
 
     /**
      * 随机字符串
      */
     private String nonce;
+
 }

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

@@ -0,0 +1,19 @@
+package com.muyu.vehicle.service;
+
+import com.muyu.common.core.domain.Result;
+import com.muyu.vehicle.domain.MqttServerModel;
+import com.muyu.vehicle.domain.req.VehicleConnectionReq;
+
+/**
+ * 车辆业务层
+ */
+public interface CarInstanceService {
+
+    Result<MqttServerModel> getConnect(VehicleConnectionReq carConnectionReq);
+
+    /**
+     * 车辆初始化
+     */
+    void carClientStart(String vin);
+
+}

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

@@ -0,0 +1,39 @@
+package com.muyu.vehicle.service.impl;
+
+import com.muyu.common.core.domain.Result;
+import com.muyu.common.core.utils.uuid.UUID;
+import com.muyu.vehicle.config.RestTemplateConfig;
+import com.muyu.vehicle.domain.MqttServerModel;
+import com.muyu.vehicle.domain.req.VehicleConnectionReq;
+import com.muyu.vehicle.service.CarInstanceService;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * 车辆业务实现层
+ */
+@Service
+@Log4j2
+public class CarInstanceServiceImpl implements CarInstanceService {
+
+
+
+    @Override
+    public Result<MqttServerModel> getConnect(VehicleConnectionReq carConnectionReq) {
+        return null;
+    }
+
+    @Override
+    public void carClientStart(String vin) {
+        String timestamp = String.valueOf(System.currentTimeMillis());
+        VehicleConnectionReq carConnectionReq = VehicleConnectionReq.builder()
+                .vehicleVin(vin)
+                .timestamp(timestamp)
+                .username(vin + timestamp)
+                .nonce(UUID.fastUUID().toString().replaceAll("-", ""))
+                .build();
+
+        //获取网关节点信息
+    }
+}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/vehicle/utils/CreateClient.java

@@ -0,0 +1,32 @@
+package com.muyu.vehicle.utils;
+
+import com.aliyun.ecs20140526.Client;
+import com.aliyun.teaopenapi.models.Config;
+
+/**
+ *  创建ECS客户端对象
+ */
+public class CreateClient {
+    /**
+     * ACCESS_KEY_ID
+     */
+    public static final String ALIBABA_CLOUD_ACCESS_KEY_ID = "LTAI5tGabdxedjfCh2uXHNrw";
+
+    /**
+     *ACCESS_KEY_SECRET
+     */
+    public static final String ACCESS_KEY_SECRET = "NHb7wHVpesLW6Axc0bFBs6ThhuNR10";
+
+    public static Client createClient() throws Exception {
+        // 工程代码泄露可能会导致 AccessKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考。
+        // 建议使用更安全的 STS 方式，更多鉴权访问方式请参见：https://help.aliyun.com/document_detail/378657.html。
+        Config config = new Config()
+                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
+                .setAccessKeyId(ALIBABA_CLOUD_ACCESS_KEY_ID)
+                // 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
+                .setAccessKeySecret(ACCESS_KEY_SECRET);
+        // Endpoint 请参考 https://api.aliyun.com/product/Ecs
+        config.endpoint = "ecs.cn-shanghai.aliyuncs.com";
+        return new Client(config);
+    }
+}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/web/common/ScheduledThreadPool.java

@@ -1,33 +0,0 @@
-package com.muyu.web.common;
-
-import net.sf.jsqlparser.statement.select.KSQLWindow;
-
-import java.util.concurrent.Executors;
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.ScheduledFuture;
-import java.util.concurrent.TimeUnit;
-
-public class ScheduledThreadPool {
-    /**
-     * 周期线程数 CPU*2+1
-     */
-    private static final ScheduledExecutorService scheduledThreadPool= Executors.newScheduledThreadPool(
-            Runtime.getRuntime().availableProcessors()*2+1
-    );
-
-    public static ScheduledFuture<?>submit(Runnable thread){
-        // 参数分别是： 任务， 多久后开始执行， 每隔多久执行一次（周期），时间单位
-        return submit(thread, 1);
-    }
-
-    public static ScheduledFuture<?>submit(Runnable thread,long period){
-        return scheduledThreadPool.scheduleAtFixedRate(thread,0,period, TimeUnit.SECONDS);
-    }
-
-    /**
-     * 关闭线程池
-     */
-    public static void shutdown(){
-        scheduledThreadPool.shutdown();
-    }
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/web/controller/testController.java

@@ -1,40 +0,0 @@
-package com.muyu.web.controller;
-
-import com.muyu.common.core.utils.uuid.UUID;
-import org.eclipse.paho.client.mqttv3.*;
-
-public class testController {
-    public static void main(String[] args) {
-        String broker       = "tcp://47.101.53.251:1883";
-        String clientId     = "SX-"+ UUID.randomUUID().toString();
-        MqttClient client;
-
-        try {
-            client = new MqttClient(broker, clientId);
-            MqttConnectOptions connectOptions = new MqttConnectOptions();
-            connectOptions.setCleanSession(true);
-            System.out.println("Connect to broker:"+broker);
-            client.connect(connectOptions);
-            System.out.println("Connected");
-            client.setCallback(new MqttCallback() {
-                @Override
-                public void connectionLost(Throwable throwable) {
-                    System.out.println("连接丢失");
-                }
-
-                @Override
-                public void messageArrived(String topic, MqttMessage mqttMessage) throws Exception {
-                    System.out.println("消息到达:"+new String(mqttMessage.getPayload())+topic);
-                }
-
-                @Override
-                public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
-
-                }
-            });
-        } catch (MqttException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/web/domain/ServerConfig.java

@@ -1,76 +0,0 @@
-package com.muyu.web.domain;
-
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
-import com.muyu.web.domain.model.ServerConfigModel;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import java.util.function.Supplier;
-
-/**
- * 服务器配置类
- */
-@Data
-@Builder
-@NoArgsConstructor
-@AllArgsConstructor
-@TableName(value = "server_config")
-public class ServerConfig {
-
-    /**
-     * 主键
-     */
-    @TableId(value = "id",type = IdType.AUTO)
-    private Long id;
-
-
-    /**
-     * 主机地址
-     */
-    private String host;
-
-    /**
-     * 端口号
-     */
-    private String port;
-
-    /**
-     * 负载地址
-     */
-    private String url;
-
-    /**
-     * 默认MOTT地址
-     */
-    private String defaultMqttAddr;
-
-    /**
-     * 默认MQTT主题
-     */
-    private String defaultMqttTopic;
-
-    /**
-     * 默认MOTT交付级别
-     */
-    private Integer defaultMqttQos;
-
-
-    public static  ServerConfig modeBuild(ServerConfigModel serverConfigModel, Supplier<Long> idKey){
-        return builder()
-                .id(idKey.get())
-                .host(serverConfigModel.getHost())
-                .port(serverConfigModel.getPort())
-                .url(serverConfigModel.getUrl())
-                .defaultMqttAddr(serverConfigModel.getDefaultMqttAddr())
-                .defaultMqttTopic(serverConfigModel.getDefaultMqttTopic())
-                .defaultMqttQos(serverConfigModel.getDefaultMqttQos())
-                .build();
-
-
-
-    }
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/web/domain/VehicleInfo.java

@@ -1,92 +0,0 @@
-package com.muyu.web.domain;
-
-import com.baomidou.mybatisplus.annotation.*;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-import java.math.BigDecimal;
-import java.util.Date;
-import java.util.function.Supplier;
-
-@Data
-@NoArgsConstructor
-@AllArgsConstructor
-@Builder
-@TableName("vehicle_info")
-public class VehicleInfo {
-
-    /**
-     * 主键
-     */
-    @TableId(
-            value = "id",
-            type = IdType.AUTO
-    )
-    private Long id;
-    /**
-     * VIN
-     */
-    private String vin;
-    /**
-     * VIN
-     */
-    @TableField(value = "tenant_id", fill = FieldFill.INSERT)
-    private String tenantId;
-
-    /**
-     * 报文模板
-     */
-    @TableField("message_template_id")
-    private Long messageTemplateId;
-
-    /**
-     * 电池剩余电量
-     */
-    @TableField("remaining_battery")
-    private BigDecimal remainingBattery;
-
-    /**
-     * 电池电量
-     */
-    @TableField("battery_level")
-    private BigDecimal batteryLevel;
-
-    /**
-     * 上一次经度
-     */
-    @TableField("last_longitude")
-    private String lastLongitude;
-
-    /**
-     * 上一次维度
-     */
-    @TableField("last_latitude")
-    private String lastLatitude;
-
-    /**
-     * 总里程
-     */
-    @TableField("total_mileage")
-    private BigDecimal totalMileage;
-
-    /**
-     * 创建时间
-     */
-    @TableField(value = "create_time", fill = FieldFill.INSERT)
-    private Date createTime;
-
-
-    public static  VehicleInfo create(String vin, Supplier<Long>messageTemplateId){
-     return    VehicleInfo.builder()
-                .vin(vin)
-                .messageTemplateId(messageTemplateId.get())
-                .createTime(new Date())
-                .totalMileage(BigDecimal.ZERO)
-                .build();
-    }
-
-
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/web/domain/model/MqttServerModel.java

@@ -1,37 +0,0 @@
-package com.muyu.web.domain.model;
-
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
-    Mqtt服务器模型
- */
-
-@Data
-@NoArgsConstructor
-@AllArgsConstructor
-public class MqttServerModel {
-    private static final Logger log=LoggerFactory.getLogger(MqttServerModel.class);
-
-    /**
-     * MQTT服务节点
-     */
-    private String broker;
-
-    /**
-     * MQTT订阅主题
-     */
-    private String topic;
-
-    public String getBroker(){
-        log.info("broker:{}",broker);
-        return broker.contains("tcp://")?broker:"tcp://"+broker+":1883";
-    }
-
-
-}
-

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/web/domain/model/PositionModel.java

@@ -1,33 +0,0 @@
-package com.muyu.web.domain.model;
-
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-/**
- * @description: 位置模型
- */
-@Data
-@Builder
-@NoArgsConstructor
-@AllArgsConstructor
-public class PositionModel {
-    /**
-     * 经度
-     */
-    private String longitude;
-
-    /**
-     * 维度
-     */
-    private String latitude;
-
-    public static PositionModel strBuild (String positionStr) {
-        String[] split = positionStr.split(",");
-        return PositionModel.builder()
-                .longitude(split[0])
-                .latitude(split[1])
-                .build();
-    }
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/web/domain/model/ServerConfigModel.java

@@ -1,53 +0,0 @@
-package com.muyu.web.domain.model;
-
-import com.muyu.web.domain.ServerConfig;
-import lombok.AllArgsConstructor;
-import lombok.Builder;
-import lombok.Data;
-import lombok.NoArgsConstructor;
-
-@Data
-@Builder
-@AllArgsConstructor
-@NoArgsConstructor
-public class ServerConfigModel {
-    /**
-     * 主机地址
-     */
-    private String host;
-
-    /**
-     * 端口号
-     */
-    private String port;
-    /**
-     * 负载地址
-     */
-    private String url;
-
-    /**
-     * 默认MOTT地址
-     */
-    private String defaultMqttAddr;
-
-    /**
-     * 默认MQTT主题
-     */
-    private String defaultMqttTopic;
-
-    /**
-     * 默认MOTT交付级别
-     */
-    private Integer defaultMqttQos;
-
-    public static  ServerConfigModel serverConfigModelBuild(ServerConfig serverConfig){
-        return builder()
-                .host(serverConfig.getHost().trim())
-                .port(serverConfig.getPort())
-                .url(serverConfig.getUrl().trim())
-                .defaultMqttAddr(serverConfig.getDefaultMqttAddr().trim())
-                .defaultMqttTopic(serverConfig.getDefaultMqttTopic().trim())
-                .defaultMqttQos(serverConfig.getDefaultMqttQos())
-                .build();
-    }
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/web/service/VehicleInstanceService.java

@@ -1,12 +0,0 @@
-package com.muyu.web.service;
-
-public interface VehicleInstanceService {
-
-
-    /**
-     * 车辆客户端初始化
-     */
-    void vehicleClientStart(String vin);
-
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/web/service/impl/VehicleInstanceServiceImpl.java

@@ -1,25 +0,0 @@
-package com.muyu.web.service.impl;
-
-import com.muyu.common.core.utils.uuid.UUID;
-import com.muyu.web.domain.req.VehicleConnectionReq;
-import com.muyu.web.service.VehicleInstanceService;
-import com.muyu.web.utils.MD5Util;
-import lombok.extern.log4j.Log4j2;
-import org.springframework.stereotype.Service;
-
-@Log4j2
-@Service
-public class VehicleInstanceServiceImpl implements VehicleInstanceService {
-    @Override
-    public void vehicleClientStart(String vin) {
-        log.info("车辆{},开始上线",vin);
-        String timestamp = String.valueOf(System.currentTimeMillis());
-        VehicleConnectionReq.builder()
-                .vin(vin)
-                .timestamp(timestamp)
-                .userName(MD5Util.encrypted(vin+timestamp))
-                .nonce(MD5Util.encrypted(UUID.randomUUID().toString().replace("-","")))
-                .build();
-        //
-    }
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/java/com/muyu/web/utils/MD5Util.java

@@ -1,52 +0,0 @@
-package com.muyu.web.utils;
-
-import lombok.extern.log4j.Log4j2;
-
-import java.nio.charset.StandardCharsets;
-import java.security.MessageDigest;
-import java.security.NoSuchAlgorithmException;
-import java.security.SecureRandom;
-
-@Log4j2
-public class MD5Util {
-    private static final Integer SALT_LENGTH = 12;
-
-    /**
-     * 指定数组转化为16进制字符串
-     */
-    public static String byteToHexString(byte[]b){
-        StringBuilder stringBuilder = new StringBuilder();
-        for (byte value : b) {
-            String hex = Integer.toHexString(value & 0xFF);
-            if (hex.length()==1){
-                hex='0'+hex;
-            }
-            stringBuilder.append(hex.toUpperCase());
-        }
-        return stringBuilder.toString();
-    }
-
-    /**
-     * 获得加密后的口令
-     */
-    public static String encrypted(String str){
-        try {
-        byte[]pwd=null;
-        SecureRandom random = new SecureRandom();
-        byte[] salt = new byte[SALT_LENGTH];
-        random.nextBytes(salt);
-        MessageDigest md=null;
-        md = MessageDigest.getInstance("MD5");
-        md.update(salt);
-        md.update(str.getBytes(StandardCharsets.UTF_8));
-        byte[] digest = md.digest();
-        pwd=new byte[digest.length+SALT_LENGTH];
-        System.arraycopy(salt,0,pwd,0,SALT_LENGTH);
-        System.arraycopy(digest,0,pwd,SALT_LENGTH,digest.length);
-        return byteToHexString(pwd);
-        } catch (NoSuchAlgorithmException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-}

cloud-modules/cloud-modules-vehiclegateway/src/main/resources/bootstrap.yml

@@ -7,10 +7,12 @@ nacos:
   addr: 47.101.53.251:8848
   user-name: nacos
   password: nacos
-  namespace: four
+  namespace: sx
 
 # Spring
 spring:
+  main:
+    allow-bean-definition-overriding: true
   application:
     # 应用名称
     name: cloud-vehicleGateway
@@ -54,3 +56,5 @@ logging:
   level:
     com.muyu.system.mapper: DEBUG
 
+
+