From 27743db2b7787803da2170b286807ea27544b266 Mon Sep 17 00:00:00 2001 From: zhang chengzhi <3144712872@qq.com> Date: Wed, 4 Sep 2024 11:53:10 +0800 Subject: [PATCH] 11111 --- .../com/muyu/rule/server/DownloadOss.java | 27 ++++++++----------- 1 file changed, 11 insertions(+), 16 deletions(-) diff --git a/cloud-rule-server/src/main/java/com/muyu/rule/server/DownloadOss.java b/cloud-rule-server/src/main/java/com/muyu/rule/server/DownloadOss.java index c26089d..59ca9ac 100644 --- a/cloud-rule-server/src/main/java/com/muyu/rule/server/DownloadOss.java +++ b/cloud-rule-server/src/main/java/com/muyu/rule/server/DownloadOss.java @@ -43,27 +43,22 @@ private static String serverPath ="home/code/"; public void run(ApplicationArguments args) throws Exception { log.info("开始从Oss下载规则引擎"); OSS ossClient = new OSSClientBuilder().build(endPoint, accessKeyId, accessKeySecret); -try { - //获取所有的oss存储的信息 - ObjectListing objectListing = ossClient.listObjects(bucketName); + // 获取存储桶信息 + ObjectListing objectListing = ossClient.listObjects(bucketName); + // 循环获取存储桶中的所有对象 - //循环获取存储中的所有对象 - while (true) { - for (OSSObjectSummary objectSummary : objectListing.getObjectSummaries()) { - String key = objectSummary.getKey(); - downloadFile(ossClient, bucketName, key, serverPath); - } + for (OSSObjectSummary objectSummary : objectListing.getObjectSummaries()) { + String key = objectSummary.getKey(); + downloadFile(ossClient, bucketName, key, serverPath); + } + + // 关闭OSSClient + ossClient.shutdown(); } -}finally { - ossClient.shutdown(); -} - - } - -private static void downloadFile(OSS ossClient, String bucketName, String key, String serverPath){ +private void downloadFile(OSS ossClient, String bucketName, String key, String serverPath){ //创建服务器项目容器的文件目录路径 File serverFile = new File(serverPath, key);