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

feat():测试

yuan
yuan 2024-08-31 23:09:31 +08:00
parent 70188d225b
commit f3448c7b64
2 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -28,32 +28,31 @@ public class OSSFileLoad {
// bucket // bucket
private static final String bucketName = "java-web-generating-class"; private static final String bucketName = "java-web-generating-class";
public static void streamingDownload(String fileName) { public static Result<Object> streamingDownload(String fileName) {
String source = null;
try { try {
// 创建 OSSClient 实例 // 创建 OSSClient 实例
OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret); OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
// 判断 bucket 是否存在 // 判断 bucket 是否存在
Boolean flag_bucket = ossClient.doesBucketExist(bucketName); Boolean flag_bucket = ossClient.doesBucketExist(bucketName);
if (!flag_bucket) { if (!flag_bucket) {
Result.error("bucket不存在"); return Result.error("bucket不存在");
return;
} }
// 判断 要下载的文件 是否存在 // 判断 要下载的文件 是否存在
Boolean flag_file = ossClient.doesObjectExist(bucketName, fileName); Boolean flag_file = ossClient.doesObjectExist(bucketName, fileName);
if (!flag_file) { if (!flag_file) {
Result.error("预下载文件不存在"); return Result.error("预下载文件不存在");
return;
} }
// ossObject包含文件所在的存储空间名称、文件名称、文件元信息以及一个输入流 // ossObject包含文件所在的存储空间名称、文件名称、文件元信息以及一个输入流
OSSObject ossObject = ossClient.getObject(bucketName, fileName); OSSObject ossObject = ossClient.getObject(bucketName, fileName);
// 按行读取文件内容 // 按行读取文件内容
BufferedReader reader = new BufferedReader(new InputStreamReader(ossObject.getObjectContent())); BufferedReader reader = new BufferedReader(new InputStreamReader(ossObject.getObjectContent()));
String source = null;
while(true){ while(true){
String line = reader.readLine(); String line = reader.readLine();
source = source + line; source += line;
if (line == null) break; if (line == null) break;
} }
System.out.println(source); System.out.println(source);
@ -69,6 +68,7 @@ public class OSSFileLoad {
} catch (IOException e) { } catch (IOException e) {
e.fillInStackTrace(); e.fillInStackTrace();
} }
return Result.success(source);
} }
} }

4
cloud-rule-server/src/main/java/com/muyu/controller/RuleVersionController.java
View File

@ -62,7 +62,9 @@ public class RuleVersionController {
ruleVersionService.save(RuleVersion.addBuild(ruleVersionAddReq)); ruleVersionService.save(RuleVersion.addBuild(ruleVersionAddReq));
Result<Object> objectResult = ALiYunUpload.uploadFiles(ruleVersionAddReq.getRuleVersionText(), ruleVersionAddReq.getRuleVersionType()); Result<Object> objectResult = ALiYunUpload.uploadFiles(ruleVersionAddReq.getRuleVersionText(), ruleVersionAddReq.getRuleVersionType());
System.out.println(objectResult.getMsg()); System.out.println(objectResult.getMsg());
OSSFileLoad.streamingDownload(ruleVersionAddReq.getRuleVersionType()+".java"); Result<Object> result = OSSFileLoad.streamingDownload(ruleVersionAddReq.getRuleVersionType() + ".java");
System.out.println("--------------");
System.out.println(result.getData());
return Result.success(null,"操作成功"); return Result.success(null,"操作成功");
} }