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

11111

master
zhang chengzhi 2024-09-02 12:02:15 +08:00
parent 5b752d593d
commit 53fae64087
3 changed files with 39 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
cloud-rule-server/src/main/java/com/muyu/rule/server/EngineConfig.java
View File

@ -11,26 +11,54 @@ import java.util.concurrent.atomic.AtomicReference;
*/ */
public class EngineConfig { public class EngineConfig {
// public static final AtomicReference<String> executionMethodName = new AtomicReference<>("run"); public static final AtomicReference<String> executionMethodName = new AtomicReference<>("execute");
public static final AtomicReference<String> executionMethodName = new AtomicReference<>("run"); //public static final AtomicReference<String> executionMethodName = new AtomicReference<>("run");
/** /**
* 包名称 * 本地包名称
*/ */
private String pack = "com.muyu.rule.server.basic.engine.value.";
//private String pack = "com.muyu.rule.server.engine."; private String pack = "com.muyu.rule.server.engine.";
// E:\\临时\\2024年8月23日\\ // E:\\临时\\2024年8月23日\\
/** /**
* 本地目录名称 * 本地目录名称
*/ */
// private String location = "E:\\practical_training\\cloud-etl-rule\\cloud-rule-server\\src\\main\\java\\com\\muyu\\rule\\server\\engine\\"; private String location = "E:\\practical_training\\cloud-etl-rule\\cloud-rule-server\\src\\main\\java\\com\\muyu\\rule\\server\\engine\\";
/**
/**
* 服务器目录 * 服务器目录
* @return * @return
*/ */
private String location = "home/"; // private String serverWay = "home/";
private String serverWay = "/home/config/source";
/**
* 服务器的包名
* @return
*/
private String serverPack="com.muyu.rule.server.basic.engine.value.";
public String getServerPack() {
return serverPack;
}
public void setServerPack(String serverPack) {
this.serverPack = serverPack;
}
public String getServerWay() {
return serverWay;
}
public void setServerWay(String serverWay) {
this.serverWay = serverWay;
}
public String getPack() { public String getPack() {
return pack; return pack;

3
cloud-rule-server/src/main/java/com/muyu/rule/server/complie/SourceCodeComplier.java
View File

@ -44,11 +44,8 @@ public static void javaCompilerFile(String... filePath){
for (int i = 0; i < filePathLength; i++) { for (int i = 0; i < filePathLength; i++) {
files[i] = new File(filePath[i]); files[i] = new File(filePath[i]);
} }
} }

9
cloud-rule-server/src/main/java/com/muyu/rule/server/service/impl/RuleEngineServiceImpl.java
View File

@ -111,21 +111,18 @@ public class RuleEngineServiceImpl extends ServiceImpl<RuleEngineVersionMapper,R
@Override @Override
public void HotLoadClass(String className, String versionClazz) { public void HotLoadClass(String className, String versionClazz) {
OssUtil.downloadFileForBucket(bucketName,className+Suffix_JAVA,"D:\\桌面");
String ossFilePath = className+Suffix_JAVA; String ossFilePath = className+Suffix_JAVA;
String filePath ="home/"+ossFilePath; String filePath ="home/"+ossFilePath;
OssUtil.downloadFileForBucket("zcz-vfd-1000",ossFilePath,filePath); OssUtil.downloadFileForBucket(bucketName,ossFilePath,filePath);
EngineConfig engineConfig = new EngineConfig(); EngineConfig engineConfig = new EngineConfig();
SourceCodeComplier.javaCompilerPath(engineConfig.getLocation()); SourceCodeComplier.javaCompilerPath(engineConfig.getServerWay());
//对class文件进行自定义类加载规则引擎 //对class文件进行自定义类加载规则引擎
Map<String ,Class<?>> stringClassMap = JavaBinaryClassLoader.loadClassesByLocation(engineConfig.getPack(),engineConfig.getLocation()); Map<String ,Class<?>> stringClassMap = JavaBinaryClassLoader.loadClassesByLocation(engineConfig.getServerPack(),engineConfig.getServerWay());
} }
static Map<String , BasicEngine<DataValue>> engineMap = new ConcurrentHashMap<>(); static Map<String , BasicEngine<DataValue>> engineMap = new ConcurrentHashMap<>();