a_bazu
/
cloud-rule
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat():测试

yuan
yuan 2024-09-06 10:05:41 +08:00
parent a4a81e0813
commit 2952c5a2f5
3 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cloud-rule-engine/src/main/java/com/muyu/compile/FilesCompilerLoad.java
View File

@ -49,7 +49,7 @@ public class FilesCompilerLoad {
}
bufferedReader.close();
log.info("文件存储:" + fileName + MethodSuffix.CLASSSUFFIX);
ALiYunUpload.uploadClassFiles(classContent,fileName + MethodSuffix.CLASSSUFFIX);
ALiYunUpload.uploadClassFiles(classContent,fileName);
} catch (IOException e) {
e.printStackTrace();
@ -62,7 +62,7 @@ public class FilesCompilerLoad {
try {
// class文件路径
String externalClassFilePath = "/home/lib/com/muyu/generate/"+fileName;
String externalClassFilePath = "/home/lib/com/muyu/generate/"+fileName + MethodSuffix.CLASSSUFFIX;
log.info(externalClassFilePath);
Path path = Paths.get(externalClassFilePath);
@ -71,7 +71,7 @@ public class FilesCompilerLoad {
URL[] urls = new URL[]{new File(externalClassDir).toURI().toURL()};
ExternalClassLoader externalClassLoader = new ExternalClassLoader(urls);
log.info("开始创建记载器...");
log.info("开始创建加载器...");
// 加载类
// 注意类名必须是完全限定名（包括包名）
Class<?> clazz = externalClassLoader.loadClassFromPath(path, "com.muyu.generate."+fileName);

6
cloud-rule-engine/src/main/java/com/muyu/load/OSSFileLoad.java
View File

@ -103,18 +103,18 @@ public class OSSFileLoad {
System.out.println("bucket不存在");
return Result.error("bucket不存在");
}
Boolean flag_file = ossClient.doesObjectExist(bucketName, fileClassPath+fileName);
Boolean flag_file = ossClient.doesObjectExist(bucketName, fileClassPath+fileName+ MethodSuffix.CLASSSUFFIX);
if (!flag_file) {
System.out.println("预下载文件不存在");
return Result.error("预下载文件不存在");
}
// 本地文件下载路径
String localPath = "/home/lib/com/muyu/generate/" + fileName ;
String localPath = "/home/lib/com/muyu/generate/" + fileName + MethodSuffix.CLASSSUFFIX;
try {
log.info("执行下载class文件:[{}]",localPath);
// 从OSS下载文件
InputStream inputStream = ossClient.getObject(bucketName, fileClassPath + fileName ).getObjectContent();
InputStream inputStream = ossClient.getObject(bucketName, fileClassPath + fileName + MethodSuffix.CLASSSUFFIX).getObjectContent();
File downloadFile = new File(localPath);
log.info("下载地址:[{}]",downloadFile);
FileOutputStream outputStream = new FileOutputStream(downloadFile);

6
cloud-rule-engine/src/main/java/com/muyu/upload/ALiYunUpload.java
View File

@ -69,12 +69,12 @@ public class ALiYunUpload {
System.out.println(classContent);
System.out.println(fileName);
System.out.println(fileName+ MethodSuffix.CLASSSUFFIX);
OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
// 上传到OSS后文件保存的目录，例如：folder/subfolder/，最后以斜杠结尾
String objectName = "build/version/class/"+fileName;
String objectName = "build/version/class/"+fileName+ MethodSuffix.CLASSSUFFIX;
try {
// 将内容转换为字节数组输入流
@ -87,7 +87,7 @@ public class ALiYunUpload {
ossClient.putObject(putObjectRequest);
OSSFileLoad.streamingClassDownload(fileName);
System.out.println(fileName);
System.out.println(fileName+ MethodSuffix.CLASSSUFFIX);
return Result.success(null,"文件"+fileName+".class"+"存储成功");
} catch (Exception e) {