etl
/
cloud-etl-rule
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

11111

master
zhang chengzhi 2024-09-06 11:01:42 +08:00
parent 84069ba64e
commit 30cd9fc1c3
2 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
cloud-rule-server/src/main/java/com/muyu/rule/server/DownloadOssSynchronization.java
View File

@ -49,23 +49,18 @@ public class DownloadOssSynchronization implements ApplicationRunner {
// 获取存储桶信息 // 获取存储桶信息
ObjectListing objectListing = ossClient.listObjects(bucketName); ObjectListing objectListing = ossClient.listObjects(bucketName);
// 循环获取存储桶中的所有对象 // 循环获取Oss存储桶中的所有对象
for (OSSObjectSummary objectSummary : objectListing.getObjectSummaries()) { for (OSSObjectSummary objectSummary : objectListing.getObjectSummaries()) {
String key = objectSummary.getKey(); String key = objectSummary.getKey();
downloadFile(ossClient, bucketName, key, serverClassPath); downloadFile(ossClient, bucketName, key, serverClassPath);
} }
// 关闭OSSClient // 关闭OSSClient
ossClient.shutdown(); ossClient.shutdown();
//下载完成实现批量批量类加载 //下载完成实现批量批量类加载
} }
private void downloadFile(OSS ossClient, String bucketName, String key, String serverPath) { private void downloadFile(OSS ossClient, String bucketName, String key, String serverPath) {
log.info("开始下载文件[]{}:"+key);
//创建服务器项目容器的文件目录路径 //创建服务器项目容器的文件目录路径
File serverFile = new File(serverPath, key); File serverFile = new File(serverPath, key);
//如果目录不存在,则创建目录 //如果目录不存在,则创建目录

3
cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineVersionServiceImpl.java
View File

@ -179,9 +179,8 @@ public static final String importClassAndPackPath="home/lib/";
public void loadEngineClass(String className) { public void loadEngineClass(String className) {
//查询类是否已加载,避免重复加载规则引擎 //查询类是否已加载,避免重复加载规则引擎
if(!engineMap.containsKey(className)){ if(!engineMap.containsKey(className)){
log.info("引擎map集合下没有该实例的容器,进行类加载"); log.info("引擎map集合下没有该实例的规则,进行自定义类加载");
try { try {
// 假设这是你的外部类文件路径 // 假设这是你的外部类文件路径
String externalClassFilePath = String externalClassFilePath =