couplet-auth/src/main/resources/bootstrap.yml

@@ -17,11 +17,9 @@ spring:
       discovery:
         # 服务注册地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
       config:
         # 配置中心地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
         # 配置文件格式
         file-extension: yml
         # 共享配置

couplet-common/couplet-common-business/src/main/java/com/couplet/common/domain/request/RealTimeDataRequest.java

@@ -6,7 +6,6 @@ import lombok.NoArgsConstructor;
 import lombok.ToString;
 
 import java.io.Serializable;
-import java.util.List;
 
 /**
  * @author fufanrui
@@ -21,7 +20,7 @@ import java.util.List;
 public class RealTimeDataRequest implements Serializable {
 
 
-    private List<Long> userId;
+    private Long userId;
 
     private String vin;
 

couplet-common/couplet-common-redis/src/main/java/com/couplet/common/redis/service/RedisService.java

@@ -1,10 +1,7 @@
 package com.couplet.common.redis.service;
 
-import ch.qos.logback.core.BasicStatusManager;
 import com.couplet.common.domain.CoupletVehicleData;
 import com.couplet.common.domain.request.RealTimeDataRequest;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import org.apache.poi.ss.formula.functions.T;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.*;
@@ -304,21 +301,8 @@ public class RedisService {
     }
 
     public void setVinAndUserId(RealTimeDataRequest realTimeDataRequest) {
-        String key = "vin"+realTimeDataRequest.getVin();
+        String key = "vin:" + realTimeDataRequest.getVin();
-        SetOperations setOperations = redisTemplate.opsForSet();
+        redisTemplate.opsForSet().add(key,realTimeDataRequest);
-        // 序列化RealTimeDataRequest对象为JSON字符串
-        ObjectMapper mapper = new ObjectMapper();
-        String jsonStr;
-        try {
-            jsonStr = mapper.writeValueAsString(realTimeDataRequest);
-        } catch (JsonProcessingException e) {
-            throw new RuntimeException(e.getMessage());
-        }
-
-        List<String> wrappedJson = Collections.singletonList(jsonStr);
-
-        // 将List作为Set的唯一元素添加到Redis中
-        setOperations.add(key, wrappedJson);
     }
 
     public void stopViewingData(String vin) {

couplet-gateway/src/main/resources/bootstrap.yml

@@ -15,11 +15,9 @@ spring:
       discovery:
         # 服务注册地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
       config:
         # 配置中心地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
         # 配置文件格式
         file-extension: yml
         # 共享配置

couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/CoupletMsgApplication.java

@@ -17,10 +17,12 @@ import org.springframework.scheduling.annotation.EnableScheduling;
 @EnableScheduling
 @EnableFeignClients(basePackages = "com.couplet")
 public class CoupletMsgApplication {
+
+
     public static void main(String[] args) {
         SpringApplication.run(CoupletMsgApplication.class);
         System.out.println("解析系统启动成功");
-        new ModelsKafkaMessage().initKafkaConsumer();
+//        new ModelsKafkaMessage().initKafkaConsumer();
     }
 
 

couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelsKafkaMessage.java

@@ -38,7 +38,7 @@ import static java.lang.Thread.sleep;
 @Component
 @Slf4j
 public class ModelsKafkaMessage {
-    private static final String TOPIC_NAME = "topic_lyh";
+    private static final String TOPIC_NAME = "online";
     private static final String BOOTSTRAP_SERVERS = "39.103.133.136:9092";
 
 
@@ -52,16 +52,13 @@ public class ModelsKafkaMessage {
     private AnalyzeEventCache analyzeEventCache;
 
 
-
-
-
     //kafka消费者初始化
     @PostConstruct
     public void initKafkaConsumer() {
         Properties props = new Properties();
         props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, BOOTSTRAP_SERVERS);
 //        props.put(ConsumerConfig.GROUP_ID_CONFIG, "my-consumer-group");
-        props.put(ConsumerConfig.GROUP_ID_CONFIG, "group");
+        props.put(ConsumerConfig.GROUP_ID_CONFIG, "ddd");
         props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");
         props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");
 
@@ -91,7 +88,7 @@ public class ModelsKafkaMessage {
             while (true) {
                 ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
                 records.forEach(record -> {
-                    log.info("接收到的数据：" + record.value());
+                    System.out.println("接收到的数据：" + record.value());
                     String str = hexToString(record.value());
                     List<CoupletMsgData> coupletMsgDataList = sendMsg(str);
                     for (CoupletMsgData msgData : coupletMsgDataList) {

couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/ElectronicFenceServiceImpl.java

@@ -5,7 +5,6 @@ import com.couplet.analyze.common.contents.AnalyzeEventContents;
 import com.couplet.analyze.msg.domain.CoupletMsgData;
 import com.couplet.analyze.msg.service.IncidentService;
 import com.couplet.common.core.text.Convert;
-import com.couplet.common.core.utils.StringUtils;
 import com.couplet.common.domain.Fence;
 import com.couplet.common.domain.request.FenceAndLogeRequest;
 import com.couplet.common.redis.service.RedisService;
@@ -47,11 +46,12 @@ public class ElectronicFenceServiceImpl implements IncidentService {
         if (redisService.hasKey(fenceKey)) {
             Set<Fence> cacheSet = redisService.getCacheSet(fenceKey);
             log.info("电子围栏事件redis存在.......");
+            //jingdu;
+            //longitude;
+            //weidu;
+            //latitude;
             for (Fence fence : cacheSet) {
                 String fenceLongitudeLatitude = fence.getFenceLongitudeLatitude();
-                if (!StringUtils.isEmpty(fenceLongitudeLatitude)){
-                    log.info("电子围栏没有数据鸭...");
-                }
                 /**
                  * 先通过；后切割
                  */

couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/RealTimeDataServiceImpl.java

@@ -5,7 +5,6 @@ import com.couplet.analyze.msg.domain.CoupletMsgData;
 import com.couplet.analyze.msg.mapper.IncidentMapper;
 import com.couplet.analyze.msg.service.IncidentService;
 import com.couplet.analyze.msg.service.impl.realTimeData.RealTimeJudge;
-import com.couplet.common.core.utils.StringUtils;
 import com.couplet.common.domain.request.RealTimeDataRequest;
 import com.couplet.common.redis.service.RedisService;
 import com.couplet.remote.RemoteRealTimeService;
@@ -13,8 +12,6 @@ import lombok.extern.log4j.Log4j2;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.HashSet;
-import java.util.Set;
 import java.util.concurrent.TimeUnit;
 
 /**
@@ -26,6 +23,12 @@ import java.util.concurrent.TimeUnit;
 @Log4j2
 public class RealTimeDataServiceImpl implements IncidentService {
 
+    /**
+     * 查询传入的数据是否存在
+     */
+    @Autowired
+    private IncidentMapper incidentMapper;
+
     @Autowired
     private RedisService redisService;
 
@@ -37,16 +40,28 @@ public class RealTimeDataServiceImpl implements IncidentService {
     @Override
     public void incident(CoupletMsgData coupletMsgData) {
         log.info("实时数据事件开始.....");
-
+        RealTimeDataRequest cacheObject = redisService.getCacheObject("vin:" + coupletMsgData.getVin());
-        if (redisService.hasKey("实时轨迹vin:"+ coupletMsgData.getVin())){
+//        //判断是否有缓存数据
-            boolean a= ("实时轨迹vin:" + coupletMsgData.getVin()).equals("实时轨迹vin:"+ coupletMsgData.getVin());
+//        if (redisService.hasKey("vin:query:" + coupletMsgData.getVin())){
-            if (a){
+//            redisService.deleteObject("vin:query:" + coupletMsgData.getVin());
-                log.info("[{}]有缓存数据，值为：[{}]，且缓存数据与实时数据一致，开始传输实时数据", coupletMsgData.getVin(), coupletMsgData);
+//        }
+//         if (RealTimeJudge.isJudge(coupletMsgData.getVin())) {
+        if (coupletMsgData.getVin().equals(cacheObject.getVin())){
+//            log.info("有实时数据，值为：[{}]开始传输实时数据", coupletMsgData.getVin());
+             //判断数据是否一致，
+//             if (RealTimeJudge.addRealTime(cacheObject)) {
+                 log.info("[{}]有缓存数据，值为：[{}]，且缓存数据与实时数据一致，开始传输实时数据", coupletMsgData.getVin(), cacheObject);
                  redisService.setCacheSet("vin:query:" + coupletMsgData.getVin(), coupletMsgData);
                  redisService.expire("vin:"+coupletMsgData.getVin(),10, TimeUnit.MINUTES);
+//             } else {
+//                 log.info("[{}]有缓存数据，值为：[{}]，且缓存数据与实时数据不一致，开始传输实时数据", coupletMsgData.getVin(), cacheObject);
+//             }
         }
-        }
+
+        log.info("[{}]开始传输实时数据", coupletMsgData.getVin());
+
         log.info("实时数据事件结束.....");
+
     }
 
     /**

couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/service/impl/realTimeData/RealTimeJudge.java

@@ -37,7 +37,7 @@ public class RealTimeJudge {
             userIds = new HashSet<>();
             setMap.put(realTimeDataRequest.getVin(),userIds);
         }
-//        userIds.add(realTimeDataRequest.getUserId());
+        userIds.add(realTimeDataRequest.getUserId());
         return true;
     }
 

couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/resources/bootstrap.yml

@@ -15,17 +15,14 @@ spring:
       discovery:
         # 服务注册地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
       config:
         # 配置中心地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
         # 配置文件格式
         file-extension: yml
         # 共享配置
         shared-configs:
           - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
-
   main:
     allow-bean-definition-overriding: true
   rabbitmq:
@@ -51,4 +48,3 @@ logging:
 mybatis-plus:
   configuration:
     map-underscore-to-camel-case: true
-

couplet-modules/couplet-business/pom.xml

@@ -114,6 +114,7 @@
             <groupId>com.couplet</groupId>
             <artifactId>couplet-analyze-msg</artifactId>
         </dependency>
+
     </dependencies>
 
     <build>

couplet-modules/couplet-business/src/main/java/com/couplet/business/server/CoupletBusinessApplication.java

@@ -17,7 +17,7 @@ import org.springframework.stereotype.Component;
 @EnableCustomConfig
 @EnableCustomSwagger2
 @EnableMyFeignClients(basePackages = ("com.couplet"))
-@SpringBootApplication(scanBasePackages = {"com.couplet"})
+@SpringBootApplication(scanBasePackages = {"com.couplet", "com.couplet.mq.remote"})
 @EnableScheduling
 public class CoupletBusinessApplication {
     public static void main(String[] args) {

couplet-modules/couplet-business/src/main/java/com/couplet/business/server/controller/VehicleDetectionController.java

@@ -16,7 +16,6 @@ import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
 import java.util.Objects;
-import java.util.Set;
 
 /**
  * @author fufanrui
@@ -68,9 +67,9 @@ public class VehicleDetectionController {
      * @date
      */
     @PostMapping("/monitorinDataList/{vin}")
-    public Result<Set<CoupletMsgData>> monitorinDataList(@PathVariable String vin){
+    public Result<List<CoupletMsgData>> monitorinDataList(@PathVariable String vin){
-        Set<CoupletMsgData> monitorinDataList  =  vehicleDetectionService.monitorinDataList(vin);
+        List<CoupletMsgData> monitorinDataList  =  vehicleDetectionService.monitorinDataList(vin);
-        Result<Set<CoupletMsgData>> success = Result.success(monitorinDataList);
+        Result<List<CoupletMsgData>> success = Result.success(monitorinDataList);
         return success;
     }
 

couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/VehicleDetectionService.java

@@ -6,7 +6,6 @@ import com.couplet.common.domain.CoupletVehicleData;
 import com.couplet.common.domain.Vehicle;
 
 import java.util.List;
-import java.util.Set;
 
 public interface VehicleDetectionService {
 
@@ -14,9 +13,7 @@ public interface VehicleDetectionService {
 
     void stopViewingData(String vin);
 
-
+    List<CoupletMsgData> monitorinDataList(String vin);
 
     void monitorinData(String vin);
-
-    Set<CoupletMsgData> monitorinDataList(String vin);
 }

couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/impl/FenceServiceImpl.java

@@ -44,12 +44,12 @@ public class FenceServiceImpl extends ServiceImpl<FenceMapper, Fence> implements
      */
     @Autowired
     private StringRedisTemplate redisTemplate;
-
     /**
      * 远程调用队列服务
      */
 //    @Autowired
 //    private RemoteFenceService remoteFenceService;
+
     @Override
     public List<Fence> pageQuery(FenceConfig fenceConfig) {
         List<Fence> list = fenceMapper.pageQuery(fenceConfig);
@@ -70,26 +70,36 @@ public class FenceServiceImpl extends ServiceImpl<FenceMapper, Fence> implements
 //        remoteFenceService.fenceQueue(fenceUpdateRequest);
     }
 
+    @Override
+    public void fenceInsert(FenceRequest fenceRequest) {
+
+    }
+
     /**
      * 业务实现:添加围栏
      *
-     * @param
+     * @param request
      * @param fenceRequest
      */
-    @Override
+//    @Override
-    public void fenceInsert(FenceRequest fenceRequest) {
+//    public void fenceInsert(HttpServletRequest request, FenceRequest fenceRequest) {
-        String username = SecurityUtils.getUsername();
+//        String username = SecurityUtils.getUsername();
-        fenceRequest.setCrateName(username);
+//        fenceRequest.setCrateName(username);
-        fenceRequest.setMaintainerName(username);
+//        //先添加围栏
-        //先添加围栏
+//        fenceMapper.insertFence(fenceRequest);
-        fenceMapper.insertFence(fenceRequest);
+//        String[] logoIds = fenceRequest.getLogoIds();
-
+//        String[] parts = new String[0];
-        fenAndLogoService.addBach(fenceRequest.getFenceId(), fenceRequest.getLogoIds());
+//        for (String logoId : logoIds) {
-        /**
+//            //把前台传入的字符串分割成数组
-         * 电子围栏发送改变
+//            parts = logoId.split(",");
-         */
+//            //再添加围栏和标识中间表
-        redisTemplate.opsForValue().set("fenceInsert", JSON.toJSONString(fenceRequest), 10, TimeUnit.MINUTES);
+//            fenAndLogoService.addBach(fenceRequest.getFenceId(), parts);
-    }
+//        }
+//        /**
+//        * 电子围栏发送改变
+//        */
+//        redisTemplate.opsForValue().set("fenceInsert", JSON.toJSONString(fenceRequest), 10, TimeUnit.MINUTES);
+//    }
 
     @Override
     public void removeByFenceId(Long fenceId) {

couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/impl/VehicleDetectionServiceImpl.java

@@ -22,7 +22,10 @@ import org.springframework.stereotype.Service;
 import springfox.documentation.spring.web.json.Json;
 
 import java.lang.reflect.Array;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Set;
 import java.util.concurrent.TimeUnit;
 
 /**
@@ -50,29 +53,23 @@ public class VehicleDetectionServiceImpl implements VehicleDetectionService{
     }
 
     @Override
-    public Set<CoupletMsgData> monitorinDataList(String vin) {
+    public List<CoupletMsgData> monitorinDataList(String vin) {
         String key = "vin:query:" + vin;
         log.info("key为:"+key);
         Set<CoupletMsgData> cacheSet = redisService.getCacheSet(key);
-
+        ArrayList<CoupletMsgData> coupletMsgData = new ArrayList<>(cacheSet);
-        return cacheSet;
+        return coupletMsgData;
     }
 
     @Override
     public void monitorinData(String vin) {
-        //创建对象
         RealTimeDataRequest realTimeDataRequest = new RealTimeDataRequest();
-        //获取用户id
         Long userId = SecurityUtils.getUserId();
-        //设置车辆vin
         realTimeDataRequest.setVin(vin);
-        //创建hashSet集合
+        realTimeDataRequest.setUserId(userId);
-        HashSet<Long> objects = new HashSet<>();
+//        analyzeEventCache.queryEvent("查询实时数据"+vin,realTimeDataRequest);
-        //添加车辆id
+//        redisService.expire("查询实时数据"+vin,4,TimeUnit.MINUTES);
-        objects.add(userId);
+        redisService.setVinAndUserId(realTimeDataRequest);
-        //把对象放入hashSet集合中
-        //存储的对象是:key:业务+vin  value: hashSet集合类型的对象
-        redisService.setCacheSet("实时轨迹vin:"+ vin,objects);
     }
 
     @Override

couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/impl/VehicleServiceImpl.java

@@ -423,12 +423,11 @@ public class VehicleServiceImpl extends ServiceImpl<VehicleMapper, Vehicle> impl
             bindLogoById.forEach(logoId -> {
 
                 //存标识id 的set
-//                HashSet<Long> logos = new HashSet<>();
+                HashSet<Long> logos = new HashSet<>();
-//                logos.add(logoId);
+                logos.add(logoId);
-//                //存入redis
+                //存入redis
-//                redis.setCacheSet("车辆vin和标识:" + vehicle.getVin(), logos);
+                redis.setCacheSet("车辆vin和标识:" + vehicle.getVin(), logos);
-
+                redis.expire("车辆vin和标识:" + vehicle.getVin(), 2, TimeUnit.MINUTES);
-//                redis.expire("车辆vin和标识:" + vehicle.getVin(), 5, TimeUnit.MINUTES);
 
 
                 //通过标识id获取标识绑定的电子围栏集合
@@ -439,7 +438,7 @@ public class VehicleServiceImpl extends ServiceImpl<VehicleMapper, Vehicle> impl
                     fanceSet.add(fence);
                     //存入redis
                     redis.setCacheSet("车辆vin和电子围栏:" + vehicle.getVin(), fanceSet);
-//                    redis.expire("车辆vin和电子围栏:" + vehicle.getVin(), 5, TimeUnit.MINUTES);
+                    redis.expire("车辆vin和电子围栏:" + vehicle.getVin(), 2, TimeUnit.MINUTES);
                 });
             });
         });

couplet-modules/couplet-business/src/main/resources/bootstrap.yml

@@ -16,11 +16,11 @@ spring:
       discovery:
         # 服务注册地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
+        namespace: 968741d4-299d-483c-8d30-ede2aff8cfd4
       config:
         # 配置中心地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
+        namespace: 968741d4-299d-483c-8d30-ede2aff8cfd4
         # 配置文件格式
         file-extension: yml
         # 共享配置

couplet-modules/couplet-business/src/main/resources/mapper/business/FenceMapper.xml

@@ -60,7 +60,8 @@
         INSERT INTO `couplet-cloud`.`couplet_fence_info`
             (`fence_name`, `fence_longitude_latitude`, `fence_description`, `is_delete`, `fence_state`, `create_time`,
              `update_time`, `create_name`, `maintainer_name`, `alarm_status`,`fence_condition`)
-            VALUES (#{fenceName}, NULL, #{fenceDescription} , 0, 0, now(), NULL, #{crateName}, #{maintainerName}, 0, 1)
+        VALUES
+            (#{fenceName}, null, #{fenceDescription}, 0, 0, now(), null, null, #{maintainerName}, 0 ,0)
 
 
     </insert>

couplet-modules/couplet-file/src/main/resources/bootstrap.yml

@@ -15,11 +15,9 @@ spring:
       discovery:
         # 服务注册地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
       config:
         # 配置中心地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
         # 配置文件格式
         file-extension: yml
         # 共享配置

couplet-modules/couplet-gen/src/main/resources/bootstrap.yml

@@ -17,11 +17,9 @@ spring:
       discovery:
         # 服务注册地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
       config:
         # 配置中心地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
         # 配置文件格式
         file-extension: yml
         # 共享配置

couplet-modules/couplet-job/src/main/resources/bootstrap.yml

@@ -15,11 +15,11 @@ spring:
       discovery:
         # 服务注册地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
+        namespace: 968741d4-299d-483c-8d30-ede2aff8cfd4
       config:
         # 配置中心地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
+        namespace: 968741d4-299d-483c-8d30-ede2aff8cfd4
         # 配置文件格式
         file-extension: yml
         # 共享配置

couplet-modules/couplet-modules-mq/src/main/java/com/couplet/mq/controller/MqController.java

@@ -74,7 +74,7 @@ public class MqController {
         RealTimeDataRequest realTimeDataRequest = new RealTimeDataRequest();
         realTimeDataRequest.setVin(vin);
         Long userId = SecurityUtils.getUserId();
-
+        realTimeDataRequest.setUserId(userId);
         rabbitTemplate.convertAndSend(RabbitMQConfig.VinExchangeName, RabbitMQConfig.VinRoutingKey, realTimeDataRequest,
                 message -> {
                     message.getMessageProperties().setMessageId(IdUtils.randomUUID());

couplet-modules/couplet-modules-mq/src/main/resources/bootstrap.yml

@@ -15,11 +15,9 @@ spring:
       discovery:
         # 服务注册地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
       config:
         # 配置中心地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
         # 配置文件格式
         file-extension: yml
         # 共享配置

couplet-modules/couplet-modules-onLine/src/main/java/com/couplet/online/utils/MqttMonitor.java

@@ -76,7 +76,7 @@ public class MqttMonitor {
 
 
     //Kafka生产者配置
-    private static final String TOPIC_NAME = "topic_lhy";
+    private static final String TOPIC_NAME = "fufanrui";
     private static final String BOOTSTRAP_SERVERS = "39.103.133.136:9092";
 
     //线程池，用于异步处理消息到来时的业务逻辑

couplet-modules/couplet-modules-onLine/src/main/resources/bootstrap.yml

@@ -36,7 +36,7 @@ mqtt:
     #    broker: mqtt://115.159.47.13:1883
     username:
     password:
-    clientId: aaaaaad
+    clientId: fufanrui44
     qos: 0
-    topic: xiaoYao
+    topic: test898
 

couplet-modules/couplet-system/src/main/resources/bootstrap.yml

@@ -15,11 +15,11 @@ spring:
       discovery:
         # 服务注册地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
+        namespace: 968741d4-299d-483c-8d30-ede2aff8cfd4
       config:
         # 配置中心地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
+        namespace: 968741d4-299d-483c-8d30-ede2aff8cfd4
         # 配置文件格式
         file-extension: yml
         # 共享配置

couplet-visual/couplet-monitor/src/main/resources/bootstrap.yml

@@ -15,11 +15,11 @@ spring:
       discovery:
         # 服务注册地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
+        namespace: 968741d4-299d-483c-8d30-ede2aff8cfd4
       config:
         # 配置中心地址
         server-addr: 121.89.211.230:8848
-        namespace: 172469
+        namespace: 968741d4-299d-483c-8d30-ede2aff8cfd4
         # 配置文件格式
         file-extension: yml
         # 共享配置