diff --git a/cloud-auth/src/main/resources/bootstrap.yml b/cloud-auth/src/main/resources/bootstrap.yml index eeaceee..4a68ffe 100644 --- a/cloud-auth/src/main/resources/bootstrap.yml +++ b/cloud-auth/src/main/resources/bootstrap.yml @@ -7,7 +7,7 @@ nacos: addr: 106.15.136.7:8848 user-name: nacos password: nacos - namespace: dev + namespace: prod # Spring spring: application: diff --git a/cloud-gateway/src/main/resources/bootstrap.yml b/cloud-gateway/src/main/resources/bootstrap.yml index d315c84..84dcd7f 100644 --- a/cloud-gateway/src/main/resources/bootstrap.yml +++ b/cloud-gateway/src/main/resources/bootstrap.yml @@ -7,7 +7,7 @@ nacos: addr: 106.15.136.7:8848 user-name: nacos password: nacos - namespace: dev + namespace: prod # Spring spring: diff --git a/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/resources/bootstrap.yml b/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/resources/bootstrap.yml index 2ab3074..5ae36be 100644 --- a/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/resources/bootstrap.yml +++ b/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/resources/bootstrap.yml @@ -7,7 +7,7 @@ nacos: addr: 106.15.136.7:8848 user-name: nacos password: nacos - namespace: dev + namespace: prod spring: application: diff --git a/cloud-modules/cloud-modules-event-process/src/main/resources/bootstrap.yml b/cloud-modules/cloud-modules-event-process/src/main/resources/bootstrap.yml index 6a9e09e..99c6a11 100644 --- a/cloud-modules/cloud-modules-event-process/src/main/resources/bootstrap.yml +++ b/cloud-modules/cloud-modules-event-process/src/main/resources/bootstrap.yml @@ -7,7 +7,7 @@ nacos: addr: 106.15.136.7:8848 user-name: nacos password: nacos - namespace: dev + namespace: prod spring: application: @@ -47,4 +47,4 @@ spring: # kafka共享配置 - application-kafka-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} # rabbit共享配置 - - application-rabbit-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} \ No newline at end of file + - application-rabbit-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} diff --git a/cloud-modules/cloud-modules-file/src/main/resources/bootstrap.yml b/cloud-modules/cloud-modules-file/src/main/resources/bootstrap.yml index b471a18..c604d55 100644 --- a/cloud-modules/cloud-modules-file/src/main/resources/bootstrap.yml +++ b/cloud-modules/cloud-modules-file/src/main/resources/bootstrap.yml @@ -7,7 +7,7 @@ nacos: addr: 106.15.136.7:8848 user-name: nacos password: nacos - namespace: dev + namespace: prod # Spring spring: diff --git a/cloud-modules/cloud-modules-gen/src/main/resources/bootstrap.yml b/cloud-modules/cloud-modules-gen/src/main/resources/bootstrap.yml index 7e3624f..c96e06b 100644 --- a/cloud-modules/cloud-modules-gen/src/main/resources/bootstrap.yml +++ b/cloud-modules/cloud-modules-gen/src/main/resources/bootstrap.yml @@ -7,7 +7,7 @@ nacos: addr: 106.15.136.7:8848 user-name: nacos password: nacos - namespace: dev + namespace: prod # Spring spring: diff --git a/cloud-modules/cloud-modules-protocol-analysis/pom.xml b/cloud-modules/cloud-modules-protocol-analysis/pom.xml index d9a3bde..8a2dc0c 100644 --- a/cloud-modules/cloud-modules-protocol-analysis/pom.xml +++ b/cloud-modules/cloud-modules-protocol-analysis/pom.xml @@ -136,11 +136,11 @@ cloud-modules-enterprise-cache - - - com.muyu - cloud-common-rabbit - + + + + + diff --git a/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/ParsingMQTT.java b/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/ParsingMQTT.java index b5d0638..9ec6244 100644 --- a/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/ParsingMQTT.java +++ b/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/ParsingMQTT.java @@ -1,6 +1,6 @@ package com.muyu.analysis.parsing.mqtt; -import com.muyu.analysis.parsing.mqtt.service.MqttClientService; +//import com.muyu.analysis.parsing.mqtt.service.MqttClientService; import com.muyu.common.core.constant.KafkaConstants; import com.muyu.common.core.constant.RedisConstants; import com.muyu.common.core.domain.Result; @@ -67,19 +67,21 @@ public class ParsingMQTT { @Resource private CarMessageValueCacheService allMessageValueCacheService; - @Autowired - private MqttClientService mqttClientService; - /** - * 协议解析 - */ - @PostConstruct - public JSONObject mqttClient(MqttMessage mqttMessage,String messageStr) { -// String topic = "vehicle"; -//// String MQTTConnect.BROKER = "tcp://106.15.136.7:1883"; -//// String clientId = "JavaSample"; +// @Autowired +// private MqttClientService mqttClientService; - String payload = new String(mqttMessage.getPayload()); - log.info("====:{}", payload); + +// /** +// * 协议解析 +// */ +// @PostConstruct +// public JSONObject mqttClient(MqttMessage mqttMessage,String messageStr) { +//// String topic = "vehicle"; +////// String MQTTConnect.BROKER = "tcp://106.15.136.7:1883"; +////// String clientId = "JavaSample"; +// +// String payload = new String(mqttMessage.getPayload()); +// log.info("====:{}", payload); // try { // // 第三个参数为空，默认持久化策略 @@ -134,48 +136,149 @@ public class ParsingMQTT { - /** - * 协议解析 - * @param messageStr - * @return - */ +// /** +// * 协议解析 +// * @param messageStr +// * @return +// */ // public JSONObject protocolParsing() { //根据空格切割数据 - String[] hexArray = messageStr.split(" "); - StringBuilder result = new StringBuilder(); - //遍历十六进制数据转换为字符 - for (String hex : hexArray) { - int decimal = Integer.parseInt(hex, 16); - result.append((char) decimal); - } - //取出车辆VIN码 - String vehicleVin = result.substring(1, 18); - log.info("车辆VIN码: " + vehicleVin); - //根据车辆VIN码查询报文模板ID - // 根据车辆VIN码查询车辆信息 - Vehicle vehicle = vehicleCacheService.get(vehicleVin); - VehicleType vehicleType = vehicleTypeCacheService.get(String.valueOf(vehicle.getVehicleTypeId())); - Long templateId = vehicleType.getMessageTemplateId(); - List templateList = allMessageValueCacheService.get(String.valueOf(templateId)); - //判断报文模板列表不为空 - if (templateList.isEmpty()) { - log.info("报文模版为空"); - throw new RuntimeException("报文模版为空"); - } - //存储报文模版解析后的数据 - JSONObject jsonObject = new JSONObject(); - for (MessageValueListResp messageValue : templateList) { - //起始位下标 - Integer startIndex = messageValue.getMessageStartIndex() - 1; - //结束位下标 - Integer endIndex = messageValue.getMessageEndIndex(); - //根据报文模版截取数据 - String value = result.substring(startIndex, endIndex); - //存入数据 - jsonObject.put(messageValue.getMessageLabel(), value); - } - return jsonObject; -// } +// String[] hexArray = messageStr.split(" "); +// StringBuilder result = new StringBuilder(); +// //遍历十六进制数据转换为字符 +// for (String hex : hexArray) { +// int decimal = Integer.parseInt(hex, 16); +// result.append((char) decimal); +// } +// //取出车辆VIN码 +// String vehicleVin = result.substring(1, 18); +// log.info("车辆VIN码: " + vehicleVin); +// //根据车辆VIN码查询报文模板ID +// // 根据车辆VIN码查询车辆信息 +// Vehicle vehicle = vehicleCacheService.get(vehicleVin); +// VehicleType vehicleType = vehicleTypeCacheService.get(String.valueOf(vehicle.getVehicleTypeId())); +// Long templateId = vehicleType.getMessageTemplateId(); +// List templateList = allMessageValueCacheService.get(String.valueOf(templateId)); +// //判断报文模板列表不为空 +// if (templateList.isEmpty()) { +// log.info("报文模版为空"); +// throw new RuntimeException("报文模版为空"); +// } +// //存储报文模版解析后的数据 +// JSONObject jsonObject = new JSONObject(); +// for (MessageValueListResp messageValue : templateList) { +// //起始位下标 +// Integer startIndex = messageValue.getMessageStartIndex() - 1; +// //结束位下标 +// Integer endIndex = messageValue.getMessageEndIndex(); +// //根据报文模版截取数据 +// String value = result.substring(startIndex, endIndex); +// //存入数据 +// jsonObject.put(messageValue.getMessageLabel(), value); +// } +// return jsonObject; +//// } +// } + + /** + * 协议解析 + */ + @PostConstruct + public void mqttClient() { +// String topic = "vehicle"; +//// String MQTTConnect.BROKER = "tcp://106.15.136.7:1883"; +//// String clientId = "JavaSample"; + + try { + // 第三个参数为空，默认持久化策略 + MqttClient sampleClient = new MqttClient(MQTTConnect.BROKER, MQTTConnect.CLIENT_ID); + MqttConnectOptions connOpts = new MqttConnectOptions(); + connOpts.setCleanSession(true); + log.info("连接中MQTTConnect.BROKER: {}", MQTTConnect.BROKER); + sampleClient.connect(connOpts); + sampleClient.subscribe(MQTTConnect.TOPIC, 0); + sampleClient.setCallback(new MqttCallback() { + // 连接丢失 + @Override + public void connectionLost(Throwable throwable) { + + } + + // 连接成功 + @Override + public void messageArrived(String s, MqttMessage mqttMessage) throws Exception { + System.out.println(new String(mqttMessage.getPayload())); + JSONObject entries = this.protocolParsing(new String(mqttMessage.getPayload())); + + ProducerRecord producerRecord = new ProducerRecord<>(KafkaConstants.MESSAGE_PARSING, + entries.toString() ); + kafkaProducer.send(producerRecord); + log.info("解析之后的数据："+entries); + + } + + /** + * 协议解析 + * @param messageStr + * @return + */ + public JSONObject protocolParsing(String messageStr) { + //根据空格切割数据 + String[] hexArray = messageStr.split(" "); + StringBuilder result = new StringBuilder(); + //遍历十六进制数据转换为字符 + for (String hex : hexArray) { + int decimal = Integer.parseInt(hex, 16); + result.append((char) decimal); + } + //取出车辆VIN码 + String vehicleVin = result.substring(1, 18); + log.info("车辆VIN码: " + vehicleVin); + //根据车辆VIN码查询报文模板ID + // 根据车辆VIN码查询车辆信息 + Vehicle vehicle = vehicleCacheService.get(vehicleVin); + VehicleType vehicleType = vehicleTypeCacheService.get(String.valueOf(vehicle.getVehicleTypeId())); + Long templateId = vehicleType.getMessageTemplateId(); + List templateList = allMessageValueCacheService.get(String.valueOf(templateId)); + //判断报文模板列表不为空 + if (templateList.isEmpty()) { + log.info("报文模版为空"); + throw new RuntimeException("报文模版为空"); + } + //存储报文模版解析后的数据 + JSONObject jsonObject = new JSONObject(); + for (MessageValueListResp messageValue : templateList) { + //起始位下标 + Integer startIndex = messageValue.getMessageStartIndex() - 1; + //结束位下标 + Integer endIndex = messageValue.getMessageEndIndex(); + //根据报文模版截取数据 + String value = result.substring(startIndex, endIndex); + //存入数据 + jsonObject.put(messageValue.getMessageLabel(), value); + } + return jsonObject; + } + + // 接收信息 + @Override + public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) { + + } + }); + } catch (MqttException me) { + log.info("reason " + me.getReasonCode()); + log.info("msg " + me.getMessage()); + log.info("loc " + me.getLocalizedMessage()); + log.info("cause " + me.getCause()); + log.info("excep " + me); + System.out.println("reason " + me.getReasonCode()); + System.out.println("msg " + me.getMessage()); + System.out.println("loc " + me.getLocalizedMessage()); + System.out.println("cause " + me.getCause()); + System.out.println("excep " + me); + me.printStackTrace(); + } } @@ -184,4 +287,5 @@ public class ParsingMQTT { + } diff --git a/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/service/MqttClientService.java b/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/service/MqttClientService.java index 2113df5..2db6859 100644 --- a/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/service/MqttClientService.java +++ b/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/MQTT/service/MqttClientService.java @@ -1,110 +1,109 @@ -package com.muyu.analysis.parsing.mqtt.service; - - - -import cn.hutool.json.JSONObject; -import com.muyu.analysis.parsing.mqtt.ParsingMQTT; -import com.muyu.common.core.constant.KafkaConstants; -import com.muyu.enterprise.domain.MqttProperties; -import jakarta.annotation.Resource; -import lombok.extern.slf4j.Slf4j; -import org.apache.kafka.clients.producer.KafkaProducer; -import org.apache.kafka.clients.producer.ProducerRecord; -import org.eclipse.paho.client.mqttv3.*; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; - -import javax.annotation.PreDestroy; -import java.io.IOException; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; - - -/** - * @Author：李庆帅 - * @Package：com.muyu.analysis.parsing.mqtt.service - * @Project：cloud-server - * @name：MqttClientService - * @Date：2024/10/10 20:24 - */ - -@Service -@Slf4j -public class MqttClientService { - - @Autowired - private ParsingMQTT messageProcessor; - - @Resource - private KafkaProducer kafkaProducer; - - private final ExecutorService executorService = Executors.newCachedThreadPool(); - private MqttClient sampleClient; - - - public void connectAndSubscribeAsync(MqttProperties mqttProperties) { - executorService.submit(() -> { - try { - connectAndSubscribe(mqttProperties); - } catch (MqttException | IOException e) { - log.error("MQTT连接或订阅失败", e); - } - }); - } - - private void connectAndSubscribe(MqttProperties mqttProperties) throws MqttException, IOException { - if (sampleClient != null && sampleClient.isConnected()) { - log.info("MQTT客户端已经连接，跳过重新连接。"); - return; - } - - sampleClient = new MqttClient(mqttProperties.getBroker(), mqttProperties.getClientId()); - MqttConnectOptions connOpts = new MqttConnectOptions(); - connOpts.setUserName(mqttProperties.getUserName()); - connOpts.setPassword(mqttProperties.getPassword().toCharArray()); - connOpts.setCleanSession(true); - - sampleClient.connect(connOpts); - sampleClient.subscribe(mqttProperties.getTopic(), 0); - - sampleClient.setCallback(new MqttCallback() { - @Override - public void connectionLost(Throwable throwable) { - log.error("连接丢失：{}", throwable.getMessage()); - } - - @Override - public void messageArrived(String s, MqttMessage mqttMessage) { - executorService.submit(() -> messageProcessor.mqttClient(mqttMessage,new String(mqttMessage.getPayload()))); - System.out.println(new String(mqttMessage.getPayload())); - JSONObject entries =messageProcessor.mqttClient(mqttMessage,new String(mqttMessage.getPayload())); -// JSONObject entries = o.protocolParsing(new String(mqttMessage.getPayload())); - - ProducerRecord producerRecord = new ProducerRecord<>(KafkaConstants.MESSAGE_PARSING, - entries.toString() ); - kafkaProducer.send(producerRecord); - log.info("解析之后的数据："+entries); - - } - - @Override - public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) { - log.info("消息发送完成：{}", iMqttDeliveryToken); - } - }); - } - - @PreDestroy - public void shutdown() { - executorService.shutdown(); - if (sampleClient != null && sampleClient.isConnected()) { - try { - sampleClient.disconnect(); - } catch (MqttException e) { - log.error("MQTT客户端断开连接失败", e); - } - } - } - - -} +//package com.muyu.analysis.parsing.mqtt.service; +// +// +// +//import cn.hutool.json.JSONObject; +//import com.muyu.common.core.constant.KafkaConstants; +//import com.muyu.enterprise.domain.MqttProperties; +//import jakarta.annotation.Resource; +//import lombok.extern.slf4j.Slf4j; +//import org.apache.kafka.clients.producer.KafkaProducer; +//import org.apache.kafka.clients.producer.ProducerRecord; +//import org.eclipse.paho.client.mqttv3.*; +//import org.springframework.beans.factory.annotation.Autowired; +//import org.springframework.stereotype.Service; +// +//import javax.annotation.PreDestroy; +//import java.io.IOException; +//import java.util.concurrent.ExecutorService; +//import java.util.concurrent.Executors; +// +// +///** +// * @Author：李庆帅 +// * @Package：com.muyu.analysis.parsing.mqtt.service +// * @Project：cloud-server +// * @name：MqttClientService +// * @Date：2024/10/10 20:24 +// */ +// +//@Service +//@Slf4j +//public class MqttClientService { +// +// @Autowired +// private ParsingMQTT messageProcessor; +// +// @Resource +// private KafkaProducer kafkaProducer; +// +// private final ExecutorService executorService = Executors.newCachedThreadPool(); +// private MqttClient sampleClient; +// +// +// public void connectAndSubscribeAsync(MqttProperties mqttProperties) { +// executorService.submit(() -> { +// try { +// connectAndSubscribe(mqttProperties); +// } catch (MqttException | IOException e) { +// log.error("MQTT连接或订阅失败", e); +// } +// }); +// } +// +// private void connectAndSubscribe(MqttProperties mqttProperties) throws MqttException, IOException { +// if (sampleClient != null && sampleClient.isConnected()) { +// log.info("MQTT客户端已经连接，跳过重新连接。"); +// return; +// } +// +// sampleClient = new MqttClient(mqttProperties.getBroker(), mqttProperties.getClientId()); +// MqttConnectOptions connOpts = new MqttConnectOptions(); +// connOpts.setUserName(mqttProperties.getUserName()); +// connOpts.setPassword(mqttProperties.getPassword().toCharArray()); +// connOpts.setCleanSession(true); +// +// sampleClient.connect(connOpts); +// sampleClient.subscribe(mqttProperties.getTopic(), 0); +// +// sampleClient.setCallback(new MqttCallback() { +// @Override +// public void connectionLost(Throwable throwable) { +// log.error("连接丢失：{}", throwable.getMessage()); +// } +// +// @Override +// public void messageArrived(String s, MqttMessage mqttMessage) { +// executorService.submit(() -> messageProcessor.mqttClient(mqttMessage,new String(mqttMessage.getPayload()))); +// System.out.println(new String(mqttMessage.getPayload())); +// JSONObject entries =messageProcessor.mqttClient(mqttMessage,new String(mqttMessage.getPayload())); +//// JSONObject entries = o.protocolParsing(new String(mqttMessage.getPayload())); +// +// ProducerRecord producerRecord = new ProducerRecord<>(KafkaConstants.MESSAGE_PARSING, +// entries.toString() ); +// kafkaProducer.send(producerRecord); +// log.info("解析之后的数据："+entries); +// +// } +// +// @Override +// public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) { +// log.info("消息发送完成：{}", iMqttDeliveryToken); +// } +// }); +// } +// +// @PreDestroy +// public void shutdown() { +// executorService.shutdown(); +// if (sampleClient != null && sampleClient.isConnected()) { +// try { +// sampleClient.disconnect(); +// } catch (MqttException e) { +// log.error("MQTT客户端断开连接失败", e); +// } +// } +// } +// +// +//} diff --git a/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/consumer/RabbitListenerComponent.java b/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/consumer/RabbitListenerComponent.java index 9c83f18..1a3754e 100644 --- a/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/consumer/RabbitListenerComponent.java +++ b/cloud-modules/cloud-modules-protocol-analysis/src/main/java/com/muyu/analysis/parsing/consumer/RabbitListenerComponent.java @@ -1,43 +1,43 @@ -package com.muyu.analysis.parsing.consumer; - - -import com.muyu.analysis.parsing.mqtt.service.MqttClientService; -import com.muyu.enterprise.domain.MqttProperties; -import com.rabbitmq.client.Channel; -import lombok.extern.slf4j.Slf4j; -import org.springframework.amqp.core.Message; -import org.springframework.amqp.rabbit.annotation.Queue; -import org.springframework.amqp.rabbit.annotation.RabbitListener; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Component; - - - -/** - * @Author：李庆帅 - * @Package：com.muyu.analysis.parsing.consumer - * @Project：cloud-server - * @name：RabbitListenerComponent - * @Date：2024/10/10 20:24 - */ - -@Component -@Slf4j -public class RabbitListenerComponent { - @Autowired - private MqttClientService mqttClientService; - - private static final String FORM_QUEUE = "GO_LINE"; - - @RabbitListener(queuesToDeclare = @Queue(value = FORM_QUEUE, durable = "true")) - public void downline(MqttProperties mqttProperties, Message message, Channel channel) { - try { - mqttClientService.connectAndSubscribeAsync(mqttProperties); - channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); - } catch (Exception e) { - e.printStackTrace(); - log.error("处理RabbitMQ消息时发生错误", e); - } - } - -} +//package com.muyu.analysis.parsing.consumer; +// +// +//import com.muyu.analysis.parsing.mqtt.service.MqttClientService; +//import com.muyu.enterprise.domain.MqttProperties; +//import com.rabbitmq.client.Channel; +//import lombok.extern.slf4j.Slf4j; +//import org.springframework.amqp.core.Message; +//import org.springframework.amqp.rabbit.annotation.Queue; +//import org.springframework.amqp.rabbit.annotation.RabbitListener; +//import org.springframework.beans.factory.annotation.Autowired; +//import org.springframework.stereotype.Component; +// +// +// +///** +// * @Author：李庆帅 +// * @Package：com.muyu.analysis.parsing.consumer +// * @Project：cloud-server +// * @name：RabbitListenerComponent +// * @Date：2024/10/10 20:24 +// */ +// +//@Component +//@Slf4j +//public class RabbitListenerComponent { +// @Autowired +// private MqttClientService mqttClientService; +// +// private static final String FORM_QUEUE = "GO_LINE"; +// +// @RabbitListener(queuesToDeclare = @Queue(value = FORM_QUEUE, durable = "true")) +// public void downline(MqttProperties mqttProperties, Message message, Channel channel) { +// try { +// mqttClientService.connectAndSubscribeAsync(mqttProperties); +// channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); +// } catch (Exception e) { +// e.printStackTrace(); +// log.error("处理RabbitMQ消息时发生错误", e); +// } +// } +// +//} diff --git a/cloud-modules/cloud-modules-protocol-analysis/src/main/resources/bootstrap.yml b/cloud-modules/cloud-modules-protocol-analysis/src/main/resources/bootstrap.yml index 567d611..98fff25 100644 --- a/cloud-modules/cloud-modules-protocol-analysis/src/main/resources/bootstrap.yml +++ b/cloud-modules/cloud-modules-protocol-analysis/src/main/resources/bootstrap.yml @@ -7,7 +7,7 @@ nacos: addr: 106.15.136.7:8848 user-name: nacos password: nacos - namespace: dev + namespace: prod spring: application: diff --git a/cloud-modules/cloud-modules-system/src/main/resources/bootstrap.yml b/cloud-modules/cloud-modules-system/src/main/resources/bootstrap.yml index 44cf5e2..877e3b8 100644 --- a/cloud-modules/cloud-modules-system/src/main/resources/bootstrap.yml +++ b/cloud-modules/cloud-modules-system/src/main/resources/bootstrap.yml @@ -7,7 +7,7 @@ nacos: addr: 106.15.136.7:8848 user-name: nacos password: nacos - namespace: dev + namespace: prod spring: application: diff --git a/cloud-modules/cloud-modules-vehicle-gateway/src/main/resources/bootstrap.yml b/cloud-modules/cloud-modules-vehicle-gateway/src/main/resources/bootstrap.yml index 0eb5252..9972a1c 100644 --- a/cloud-modules/cloud-modules-vehicle-gateway/src/main/resources/bootstrap.yml +++ b/cloud-modules/cloud-modules-vehicle-gateway/src/main/resources/bootstrap.yml @@ -7,7 +7,7 @@ nacos: addr: 106.15.136.7:8848 user-name: nacos password: nacos - namespace: dev + namespace: prod spring: application: diff --git a/cloud-visual/cloud-visual-monitor/src/main/resources/bootstrap.yml b/cloud-visual/cloud-visual-monitor/src/main/resources/bootstrap.yml index da1f316..4138cab 100644 --- a/cloud-visual/cloud-visual-monitor/src/main/resources/bootstrap.yml +++ b/cloud-visual/cloud-visual-monitor/src/main/resources/bootstrap.yml @@ -7,7 +7,7 @@ nacos: addr: 106.15.136.7:8848 user-name: nacos password: nacos - namespace: dev + namespace: prod # Spring spring: