From eddd3311a0e78d711d58010c64e0f8bb0fafed7a Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Mon, 7 Apr 2025 11:21:48 +0800 Subject: [PATCH 1/5] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E9=85=8D=E7=BD=AE?= =?UTF-8?q?=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- analysis/stat/stat-boot/src/main/resources/bootstrap.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/analysis/stat/stat-boot/src/main/resources/bootstrap.yml b/analysis/stat/stat-boot/src/main/resources/bootstrap.yml index 6dde5df..d66e6d9 100644 --- a/analysis/stat/stat-boot/src/main/resources/bootstrap.yml +++ b/analysis/stat/stat-boot/src/main/resources/bootstrap.yml @@ -29,7 +29,7 @@ spring: shared-configs: - data-id: share-config.yaml refresh: true - - data-Id: data-platform.yaml + - data-Id: share-config-datasource-db.yaml refresh: true main: allow-bean-definition-overriding: true From 72e63be140b603d12c89bd4f57d5663376ce941c Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Mon, 7 Apr 2025 11:24:11 +0800 Subject: [PATCH 2/5] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E9=85=8D=E7=BD=AE?= =?UTF-8?q?=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../consumer/FrontDataConsumerTest.java | 173 ++++++++++++++++++ .../src/main/resources/bootstrap.yml | 2 +- 2 files changed, 174 insertions(+), 1 deletion(-) create mode 100644 message/message-boot/src/main/java/com/njcn/message/consumer/FrontDataConsumerTest.java diff --git a/message/message-boot/src/main/java/com/njcn/message/consumer/FrontDataConsumerTest.java b/message/message-boot/src/main/java/com/njcn/message/consumer/FrontDataConsumerTest.java new file mode 100644 index 0000000..b9a90ef --- /dev/null +++ b/message/message-boot/src/main/java/com/njcn/message/consumer/FrontDataConsumerTest.java @@ -0,0 +1,173 @@ +package com.njcn.message.consumer; + +import com.alibaba.fastjson.JSONObject; +import com.njcn.message.constant.MessageStatus; +import com.njcn.message.messagedto.MessageDataDTO; +import com.njcn.middle.rocket.constant.EnhanceMessageConstant; +import com.njcn.middle.rocket.handler.EnhanceConsumerMessageHandler; +import com.njcn.redis.pojo.enums.RedisKeyEnum; +import com.njcn.redis.utils.RedisUtil; +import com.njcn.stat.api.MessAnalysisFeignClient; +import com.njcn.system.api.RocketMqLogFeignClient; +import com.njcn.system.pojo.po.RocketmqMsgErrorLog; +import lombok.extern.slf4j.Slf4j; +import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; +import org.apache.rocketmq.spring.core.RocketMQListener; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.ArrayList; +import java.util.List; +import java.util.Objects; + + +/** + * 类的介绍： + * + * @author xuyang + * @version 1.0.0 + * @createTime 2023/8/11 15:32 + */ +@Component +@RocketMQMessageListener( + topic = "Test_Topic", + consumerGroup = "Test_consumer", + selectorExpression = "Test_Tag||Test_Keys", + consumeThreadNumber = 10, + enableMsgTrace = true +) +@Slf4j +public class FrontDataConsumerTest extends EnhanceConsumerMessageHandler implements RocketMQListener { + + @Autowired + private MessAnalysisFeignClient messAnalysisFeignClient; + + + + @Resource + private RedisUtil redisUtil; + + @Resource + private RocketMqLogFeignClient rocketMqLogFeignClient; + + + private List messageList = new ArrayList<>(1); + + @Override + public void onMessage(String baseMessage) { + MessageDataDTO messageDataDTO = JSONObject.parseObject(baseMessage,MessageDataDTO.class); + super.dispatchMessage(messageDataDTO); + + } + + /*** + * 通过redis分布式锁判断当前消息所处状态 + * 1、null 查不到该key的数据，属于第一次消费，放行 + * 2、fail 上次消息消费时发生异常，放行 + * 3、being processed 正在处理，打回去 + * 4、success 最近72小时消费成功，避免重复消费，打回去 + */ + @Override + public boolean filter(MessageDataDTO message) { + String keyStatus = redisUtil.getStringByKey(message.getKey()); + if (Objects.isNull(keyStatus) || keyStatus.equalsIgnoreCase(MessageStatus.FAIL)) { + redisUtil.saveByKeyWithExpire(message.getKey(), MessageStatus.BEING_PROCESSED, 60L); + return false; + } + return true; + } + /** + * 消费成功，缓存到redis72小时，避免重复消费 + */ + @Override + protected void consumeSuccess(MessageDataDTO message) { + redisUtil.saveByKeyWithExpire(message.getKey(), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime()); + } + + + @Override + protected void handleMessage(MessageDataDTO message) { + synchronized (messageList) { + messageList.add(message); + if (messageList.size() >= 1) { + saveToDatabase(); + } + } + } + + + + + /** + * 发生异常时，进行错误信息入库保存 + * 默认没有实现类，子类可以实现该方法，调用feign接口进行入库保存 + */ + @Override + protected void saveExceptionMsgLog(MessageDataDTO message, String identity, Exception exception) { + redisUtil.saveByKeyWithExpire(message.getKey(), MessageStatus.FAIL, RedisKeyEnum.ROCKET_MQ_KEY.getTime()); + RocketmqMsgErrorLog rocketmqMsgErrorLog = new RocketmqMsgErrorLog(); + rocketmqMsgErrorLog.setMsgKey(message.getKey()); + rocketmqMsgErrorLog.setResource(message.getSource()); + if (identity.equalsIgnoreCase(EnhanceMessageConstant.IDENTITY_SINGLE)) { + //数据库字段配置长度200，避免插入失败，大致分析异常原因 + String exceptionMsg = exception.getMessage(); + if(exceptionMsg.length() > 200){ + exceptionMsg = exceptionMsg.substring(0,180); + } + rocketmqMsgErrorLog.setRecord(exceptionMsg); + //如果是当前消息重试的则略过 + if(!message.getSource().startsWith(EnhanceMessageConstant.RETRY_PREFIX)){ + //单次消费异常 + rocketMqLogFeignClient.add(rocketmqMsgErrorLog); + } + } else { + rocketmqMsgErrorLog.setRecord("重试消费" + super.getMaxRetryTimes() + "次，依旧消费失败。"); + //重试N次后，依然消费异常 + rocketMqLogFeignClient.add(rocketmqMsgErrorLog); + } + } + + + /*** + * 处理失败后，是否重试 + * 一般开启 + */ + @Override + protected boolean isRetry() { + return false; + } + + + /*** + * 消费失败是否抛出异常，抛出异常后就不再消费了 + */ + @Override + protected boolean throwException() { + return false; + } + + + + //50个消息做一组插入数据库 + public void saveToDatabase(){ + try { + long start = System.currentTimeMillis(); + + messAnalysisFeignClient.analysis(messageList); + + long end = System.currentTimeMillis(); + log.info("处理120条消息所需时间------------"+(end-start)); + }catch (Exception e){{ + log.info(e.toString()); + } + }finally{ + messageList.clear(); + } + + } + + + + +} diff --git a/message/message-boot/src/main/resources/bootstrap.yml b/message/message-boot/src/main/resources/bootstrap.yml index 3898c94..1f93eda 100644 --- a/message/message-boot/src/main/resources/bootstrap.yml +++ b/message/message-boot/src/main/resources/bootstrap.yml @@ -29,7 +29,7 @@ spring: shared-configs: - data-id: share-config.yaml refresh: true - - data-Id: algorithm-config.yaml + - data-Id: data-platform.yaml refresh: true main: allow-bean-definition-overriding: true From 92c64873e6a59bce3c59d826ea8dc84a3d936ba1 Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Mon, 7 Apr 2025 11:24:58 +0800 Subject: [PATCH 3/5] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E9=85=8D=E7=BD=AE?= =?UTF-8?q?=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../consumer/FrontDataConsumerTest.java | 346 +++++++++--------- 1 file changed, 173 insertions(+), 173 deletions(-) diff --git a/message/message-boot/src/main/java/com/njcn/message/consumer/FrontDataConsumerTest.java b/message/message-boot/src/main/java/com/njcn/message/consumer/FrontDataConsumerTest.java index b9a90ef..2daacca 100644 --- a/message/message-boot/src/main/java/com/njcn/message/consumer/FrontDataConsumerTest.java +++ b/message/message-boot/src/main/java/com/njcn/message/consumer/FrontDataConsumerTest.java @@ -1,173 +1,173 @@ -package com.njcn.message.consumer; - -import com.alibaba.fastjson.JSONObject; -import com.njcn.message.constant.MessageStatus; -import com.njcn.message.messagedto.MessageDataDTO; -import com.njcn.middle.rocket.constant.EnhanceMessageConstant; -import com.njcn.middle.rocket.handler.EnhanceConsumerMessageHandler; -import com.njcn.redis.pojo.enums.RedisKeyEnum; -import com.njcn.redis.utils.RedisUtil; -import com.njcn.stat.api.MessAnalysisFeignClient; -import com.njcn.system.api.RocketMqLogFeignClient; -import com.njcn.system.pojo.po.RocketmqMsgErrorLog; -import lombok.extern.slf4j.Slf4j; -import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; -import org.apache.rocketmq.spring.core.RocketMQListener; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Component; - -import javax.annotation.Resource; -import java.util.ArrayList; -import java.util.List; -import java.util.Objects; - - -/** - * 类的介绍： - * - * @author xuyang - * @version 1.0.0 - * @createTime 2023/8/11 15:32 - */ -@Component -@RocketMQMessageListener( - topic = "Test_Topic", - consumerGroup = "Test_consumer", - selectorExpression = "Test_Tag||Test_Keys", - consumeThreadNumber = 10, - enableMsgTrace = true -) -@Slf4j -public class FrontDataConsumerTest extends EnhanceConsumerMessageHandler implements RocketMQListener { - - @Autowired - private MessAnalysisFeignClient messAnalysisFeignClient; - - - - @Resource - private RedisUtil redisUtil; - - @Resource - private RocketMqLogFeignClient rocketMqLogFeignClient; - - - private List messageList = new ArrayList<>(1); - - @Override - public void onMessage(String baseMessage) { - MessageDataDTO messageDataDTO = JSONObject.parseObject(baseMessage,MessageDataDTO.class); - super.dispatchMessage(messageDataDTO); - - } - - /*** - * 通过redis分布式锁判断当前消息所处状态 - * 1、null 查不到该key的数据，属于第一次消费，放行 - * 2、fail 上次消息消费时发生异常，放行 - * 3、being processed 正在处理，打回去 - * 4、success 最近72小时消费成功，避免重复消费，打回去 - */ - @Override - public boolean filter(MessageDataDTO message) { - String keyStatus = redisUtil.getStringByKey(message.getKey()); - if (Objects.isNull(keyStatus) || keyStatus.equalsIgnoreCase(MessageStatus.FAIL)) { - redisUtil.saveByKeyWithExpire(message.getKey(), MessageStatus.BEING_PROCESSED, 60L); - return false; - } - return true; - } - /** - * 消费成功，缓存到redis72小时，避免重复消费 - */ - @Override - protected void consumeSuccess(MessageDataDTO message) { - redisUtil.saveByKeyWithExpire(message.getKey(), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime()); - } - - - @Override - protected void handleMessage(MessageDataDTO message) { - synchronized (messageList) { - messageList.add(message); - if (messageList.size() >= 1) { - saveToDatabase(); - } - } - } - - - - - /** - * 发生异常时，进行错误信息入库保存 - * 默认没有实现类，子类可以实现该方法，调用feign接口进行入库保存 - */ - @Override - protected void saveExceptionMsgLog(MessageDataDTO message, String identity, Exception exception) { - redisUtil.saveByKeyWithExpire(message.getKey(), MessageStatus.FAIL, RedisKeyEnum.ROCKET_MQ_KEY.getTime()); - RocketmqMsgErrorLog rocketmqMsgErrorLog = new RocketmqMsgErrorLog(); - rocketmqMsgErrorLog.setMsgKey(message.getKey()); - rocketmqMsgErrorLog.setResource(message.getSource()); - if (identity.equalsIgnoreCase(EnhanceMessageConstant.IDENTITY_SINGLE)) { - //数据库字段配置长度200，避免插入失败，大致分析异常原因 - String exceptionMsg = exception.getMessage(); - if(exceptionMsg.length() > 200){ - exceptionMsg = exceptionMsg.substring(0,180); - } - rocketmqMsgErrorLog.setRecord(exceptionMsg); - //如果是当前消息重试的则略过 - if(!message.getSource().startsWith(EnhanceMessageConstant.RETRY_PREFIX)){ - //单次消费异常 - rocketMqLogFeignClient.add(rocketmqMsgErrorLog); - } - } else { - rocketmqMsgErrorLog.setRecord("重试消费" + super.getMaxRetryTimes() + "次，依旧消费失败。"); - //重试N次后，依然消费异常 - rocketMqLogFeignClient.add(rocketmqMsgErrorLog); - } - } - - - /*** - * 处理失败后，是否重试 - * 一般开启 - */ - @Override - protected boolean isRetry() { - return false; - } - - - /*** - * 消费失败是否抛出异常，抛出异常后就不再消费了 - */ - @Override - protected boolean throwException() { - return false; - } - - - - //50个消息做一组插入数据库 - public void saveToDatabase(){ - try { - long start = System.currentTimeMillis(); - - messAnalysisFeignClient.analysis(messageList); - - long end = System.currentTimeMillis(); - log.info("处理120条消息所需时间------------"+(end-start)); - }catch (Exception e){{ - log.info(e.toString()); - } - }finally{ - messageList.clear(); - } - - } - - - - -} +//package com.njcn.message.consumer; +// +//import com.alibaba.fastjson.JSONObject; +//import com.njcn.message.constant.MessageStatus; +//import com.njcn.message.messagedto.MessageDataDTO; +//import com.njcn.middle.rocket.constant.EnhanceMessageConstant; +//import com.njcn.middle.rocket.handler.EnhanceConsumerMessageHandler; +//import com.njcn.redis.pojo.enums.RedisKeyEnum; +//import com.njcn.redis.utils.RedisUtil; +//import com.njcn.stat.api.MessAnalysisFeignClient; +//import com.njcn.system.api.RocketMqLogFeignClient; +//import com.njcn.system.pojo.po.RocketmqMsgErrorLog; +//import lombok.extern.slf4j.Slf4j; +//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; +//import org.apache.rocketmq.spring.core.RocketMQListener; +//import org.springframework.beans.factory.annotation.Autowired; +//import org.springframework.stereotype.Component; +// +//import javax.annotation.Resource; +//import java.util.ArrayList; +//import java.util.List; +//import java.util.Objects; +// +// +///** +// * 类的介绍： +// * +// * @author xuyang +// * @version 1.0.0 +// * @createTime 2023/8/11 15:32 +// */ +//@Component +//@RocketMQMessageListener( +// topic = "Test_Topic", +// consumerGroup = "Test_consumer", +// selectorExpression = "Test_Tag||Test_Keys", +// consumeThreadNumber = 10, +// enableMsgTrace = true +//) +//@Slf4j +//public class FrontDataConsumerTest extends EnhanceConsumerMessageHandler implements RocketMQListener { +// +// @Autowired +// private MessAnalysisFeignClient messAnalysisFeignClient; +// +// +// +// @Resource +// private RedisUtil redisUtil; +// +// @Resource +// private RocketMqLogFeignClient rocketMqLogFeignClient; +// +// +// private List messageList = new ArrayList<>(1); +// +// @Override +// public void onMessage(String baseMessage) { +// MessageDataDTO messageDataDTO = JSONObject.parseObject(baseMessage,MessageDataDTO.class); +// super.dispatchMessage(messageDataDTO); +// +// } +// +// /*** +// * 通过redis分布式锁判断当前消息所处状态 +// * 1、null 查不到该key的数据，属于第一次消费，放行 +// * 2、fail 上次消息消费时发生异常，放行 +// * 3、being processed 正在处理，打回去 +// * 4、success 最近72小时消费成功，避免重复消费，打回去 +// */ +// @Override +// public boolean filter(MessageDataDTO message) { +// String keyStatus = redisUtil.getStringByKey(message.getKey()); +// if (Objects.isNull(keyStatus) || keyStatus.equalsIgnoreCase(MessageStatus.FAIL)) { +// redisUtil.saveByKeyWithExpire(message.getKey(), MessageStatus.BEING_PROCESSED, 60L); +// return false; +// } +// return true; +// } +// /** +// * 消费成功，缓存到redis72小时，避免重复消费 +// */ +// @Override +// protected void consumeSuccess(MessageDataDTO message) { +// redisUtil.saveByKeyWithExpire(message.getKey(), MessageStatus.SUCCESS, RedisKeyEnum.ROCKET_MQ_KEY.getTime()); +// } +// +// +// @Override +// protected void handleMessage(MessageDataDTO message) { +// synchronized (messageList) { +// messageList.add(message); +// if (messageList.size() >= 1) { +// saveToDatabase(); +// } +// } +// } +// +// +// +// +// /** +// * 发生异常时，进行错误信息入库保存 +// * 默认没有实现类，子类可以实现该方法，调用feign接口进行入库保存 +// */ +// @Override +// protected void saveExceptionMsgLog(MessageDataDTO message, String identity, Exception exception) { +// redisUtil.saveByKeyWithExpire(message.getKey(), MessageStatus.FAIL, RedisKeyEnum.ROCKET_MQ_KEY.getTime()); +// RocketmqMsgErrorLog rocketmqMsgErrorLog = new RocketmqMsgErrorLog(); +// rocketmqMsgErrorLog.setMsgKey(message.getKey()); +// rocketmqMsgErrorLog.setResource(message.getSource()); +// if (identity.equalsIgnoreCase(EnhanceMessageConstant.IDENTITY_SINGLE)) { +// //数据库字段配置长度200，避免插入失败，大致分析异常原因 +// String exceptionMsg = exception.getMessage(); +// if(exceptionMsg.length() > 200){ +// exceptionMsg = exceptionMsg.substring(0,180); +// } +// rocketmqMsgErrorLog.setRecord(exceptionMsg); +// //如果是当前消息重试的则略过 +// if(!message.getSource().startsWith(EnhanceMessageConstant.RETRY_PREFIX)){ +// //单次消费异常 +// rocketMqLogFeignClient.add(rocketmqMsgErrorLog); +// } +// } else { +// rocketmqMsgErrorLog.setRecord("重试消费" + super.getMaxRetryTimes() + "次，依旧消费失败。"); +// //重试N次后，依然消费异常 +// rocketMqLogFeignClient.add(rocketmqMsgErrorLog); +// } +// } +// +// +// /*** +// * 处理失败后，是否重试 +// * 一般开启 +// */ +// @Override +// protected boolean isRetry() { +// return false; +// } +// +// +// /*** +// * 消费失败是否抛出异常，抛出异常后就不再消费了 +// */ +// @Override +// protected boolean throwException() { +// return false; +// } +// +// +// +// //50个消息做一组插入数据库 +// public void saveToDatabase(){ +// try { +// long start = System.currentTimeMillis(); +// +// messAnalysisFeignClient.analysis(messageList); +// +// long end = System.currentTimeMillis(); +// log.info("处理120条消息所需时间------------"+(end-start)); +// }catch (Exception e){{ +// log.info(e.toString()); +// } +// }finally{ +// messageList.clear(); +// } +// +// } +// +// +// +// +//} From e6194dbcf09ca2661225c20aae39255fc19d7d3c Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Mon, 7 Apr 2025 11:25:46 +0800 Subject: [PATCH 4/5] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E9=85=8D=E7=BD=AE?= =?UTF-8?q?=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- analysis/event/event-boot/src/main/resources/bootstrap.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/analysis/event/event-boot/src/main/resources/bootstrap.yml b/analysis/event/event-boot/src/main/resources/bootstrap.yml index da86ebe..1964979 100644 --- a/analysis/event/event-boot/src/main/resources/bootstrap.yml +++ b/analysis/event/event-boot/src/main/resources/bootstrap.yml @@ -29,7 +29,7 @@ spring: shared-configs: - data-id: share-config.yaml refresh: true - - data-Id: algorithm-config.yaml + - data-Id: data-platform.yaml refresh: true main: allow-bean-definition-overriding: true From 20d1489fe968a3c42bf0c5d3be5f3d2be9ca6e25 Mon Sep 17 00:00:00 2001 From: chendaofei <857448963@qq.com> Date: Mon, 7 Apr 2025 11:32:56 +0800 Subject: [PATCH 5/5] =?UTF-8?q?=E9=85=8D=E7=BD=AE=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../serviceimpl/line/DataCleanServiceImpl.java | 17 +++++++++++++++++ .../src/main/resources/bootstrap.yml | 2 ++ .../event-boot/src/main/resources/bootstrap.yml | 2 +- .../rt/rt-boot/src/main/resources/bootstrap.yml | 2 +- .../src/main/resources/bootstrap.yml | 2 ++ 5 files changed, 23 insertions(+), 2 deletions(-) diff --git a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java index 720c846..58e1b67 100644 --- a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java +++ b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/serviceimpl/line/DataCleanServiceImpl.java @@ -69,6 +69,23 @@ public class DataCleanServiceImpl implements IDataCleanService { @Override public void dataVCleanHandler(CalculatedParam calculatedParam) { + Runtime runtime = Runtime.getRuntime(); + // 获取 JVM 最大可用内存（以字节为单位） + long maxMemory = runtime.maxMemory(); + // 获取 JVM 当前已分配的内存（以字节为单位） + long totalMemory = runtime.totalMemory(); + // 获取 JVM 当前空闲内存（以字节为单位） + long freeMemory = runtime.freeMemory(); + // 计算已使用的内存 + long usedMemory = totalMemory - freeMemory; + + System.out.println("最大可用内存: " + maxMemory / (1024 * 1024) + " MB"); + System.out.println("当前已分配的内存: " + totalMemory / (1024 * 1024) + " MB"); + System.out.println("当前空闲内存: " + freeMemory / (1024 * 1024) + " MB"); + System.out.println("已使用的内存: " + usedMemory / (1024 * 1024) + " MB"); + System.out.println("第一次分析结束-----------------------------------------"); + + logger.info("{},dataV表异常数据算法执行=====》", LocalDateTime.now()); List result = new ArrayList<>(); //获取标准 diff --git a/algorithm/algorithm-boot/src/main/resources/bootstrap.yml b/algorithm/algorithm-boot/src/main/resources/bootstrap.yml index 6d0bdba..152a842 100644 --- a/algorithm/algorithm-boot/src/main/resources/bootstrap.yml +++ b/algorithm/algorithm-boot/src/main/resources/bootstrap.yml @@ -31,6 +31,8 @@ spring: refresh: true - data-Id: share-config-datasource-db.yaml refresh: true + - data-Id: data-platform.yaml + refresh: true main: allow-bean-definition-overriding: true diff --git a/analysis/event/event-boot/src/main/resources/bootstrap.yml b/analysis/event/event-boot/src/main/resources/bootstrap.yml index 1964979..2a90fcb 100644 --- a/analysis/event/event-boot/src/main/resources/bootstrap.yml +++ b/analysis/event/event-boot/src/main/resources/bootstrap.yml @@ -29,7 +29,7 @@ spring: shared-configs: - data-id: share-config.yaml refresh: true - - data-Id: data-platform.yaml + - data-Id: share-config-datasource-db.yaml refresh: true main: allow-bean-definition-overriding: true diff --git a/analysis/rt/rt-boot/src/main/resources/bootstrap.yml b/analysis/rt/rt-boot/src/main/resources/bootstrap.yml index 4e273c4..b919c3f 100644 --- a/analysis/rt/rt-boot/src/main/resources/bootstrap.yml +++ b/analysis/rt/rt-boot/src/main/resources/bootstrap.yml @@ -29,7 +29,7 @@ spring: shared-configs: - data-id: share-config.yaml refresh: true - - data-Id: algorithm-config.yaml + - data-Id: share-config-datasource-db.yaml refresh: true main: allow-bean-definition-overriding: true diff --git a/data-processing/data-processing-boot/src/main/resources/bootstrap.yml b/data-processing/data-processing-boot/src/main/resources/bootstrap.yml index c32d6f1..69fc72b 100644 --- a/data-processing/data-processing-boot/src/main/resources/bootstrap.yml +++ b/data-processing/data-processing-boot/src/main/resources/bootstrap.yml @@ -30,6 +30,8 @@ spring: shared-configs: - data-id: share-config.yaml refresh: true + - data-Id: share-config-datasource-db.yaml + refresh: true - data-Id: data-platform.yaml refresh: true main: