From 12463389cf2a9e5325ccd96e613a5d677f9efef3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BB=BA=E6=98=8E=20=E6=B2=88?= <2431685932@qq.com> Date: Mon, 15 Jul 2024 23:19:10 +0800 Subject: [PATCH] feat: aliOssClient --- .../oss/core/ali/AliOssClient.java | 65 ++++++++++--------- 1 file changed, 34 insertions(+), 31 deletions(-) diff --git a/schisandra-cloud-storage-oss/schisandra-cloud-storage-oss-application/schisandra-cloud-storage-oss-application-controller/src/main/java/com/schisandra/oss/application/oss/core/ali/AliOssClient.java b/schisandra-cloud-storage-oss/schisandra-cloud-storage-oss-application/schisandra-cloud-storage-oss-application-controller/src/main/java/com/schisandra/oss/application/oss/core/ali/AliOssClient.java index 17a2ad0..b5919e8 100644 --- a/schisandra-cloud-storage-oss/schisandra-cloud-storage-oss-application/schisandra-cloud-storage-oss-application-controller/src/main/java/com/schisandra/oss/application/oss/core/ali/AliOssClient.java +++ b/schisandra-cloud-storage-oss/schisandra-cloud-storage-oss-application/schisandra-cloud-storage-oss-application-controller/src/main/java/com/schisandra/oss/application/oss/core/ali/AliOssClient.java @@ -6,7 +6,6 @@ import cn.hutool.core.date.DateUtil; import cn.hutool.core.io.IoUtil; import cn.hutool.core.io.file.FileNameUtil; import cn.hutool.core.io.unit.DataSizeUtil; -import cn.hutool.core.lang.hash.Hash; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ReflectUtil; import cn.hutool.core.util.StrUtil; @@ -14,8 +13,6 @@ import com.aliyun.oss.OSS; import com.aliyun.oss.common.utils.HttpHeaders; import com.aliyun.oss.model.*; -import com.qiniu.storage.BucketManager; -import com.qiniu.storage.model.FileInfo; import com.schisandra.oss.application.oss.constant.OssConstant; import com.schisandra.oss.application.oss.core.StandardOssClient; import com.schisandra.oss.application.oss.core.ali.model.AliOssConfig; @@ -35,6 +32,7 @@ import org.springframework.stereotype.Component; import java.io.File; import java.io.InputStream; import java.io.OutputStream; +import java.net.URL; import java.text.SimpleDateFormat; import java.util.*; @@ -57,23 +55,29 @@ public class AliOssClient implements StandardOssClient { private OSS oss; private AliOssConfig aliOssConfig; + + public String getAliPreviewUrl(String fileName) { + URL presignedUrl = oss.generatePresignedUrl(getBucketName(), fileName, new Date()); + return String.valueOf(presignedUrl); + } + public String getAliBucketSize(String bucket) { ObjectListing objectListing = oss.listObjects(bucket, ""); long x = 0L; List sums = objectListing.getObjectSummaries(); - for(OSSObjectSummary objectSummary : sums){ - x+=objectSummary.getSize(); + for (OSSObjectSummary objectSummary : sums) { + x += objectSummary.getSize(); } return DataSizeUtil.format(x); } - public List> selectAllBucket() { + public List> selectAllBucket() { List buckets = oss.listBuckets(); - List> list1 = new ArrayList<>(); + List> list1 = new ArrayList<>(); buckets.forEach(bucket -> { HashMap names = new HashMap<>(); - names.put("name",bucket.getName()); - names.put("size",getAliBucketSize(bucket.getName())); + names.put("name", bucket.getName()); + names.put("size", getAliBucketSize(bucket.getName())); list1.add(names); }); return list1; @@ -85,12 +89,12 @@ public class AliOssClient implements StandardOssClient { * @return: java.util.List * @date: 2024/7/5 13:34 */ - public String transfer(String before){ + public String transfer(String before) { SimpleDateFormat sdf = new SimpleDateFormat("EEE MMM dd HH:mm:ss zzz yyyy", Locale.US); Date date = new Date(); - try{ + try { date = sdf.parse(before); - }catch (Exception e){ + } catch (Exception e) { e.printStackTrace(); } String formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(date); @@ -98,23 +102,23 @@ public class AliOssClient implements StandardOssClient { return formatStr; } - public List listAliInfo(String bucket, String prefix){ + public List listAliInfo(String bucket, String prefix) { // 列举文件。如果不设置Prefix，则列举存储空间下的所有文件。如果设置Prefix，则列举包含指定前缀的文件。 ObjectListing objectListing = oss.listObjects(bucket, prefix); List sums = objectListing.getObjectSummaries(); List infos = new ArrayList<>(); - if(prefix == ""){ - for(OSSObjectSummary objectSummary : sums){ + if (prefix == "") { + for (OSSObjectSummary objectSummary : sums) { OssInfo info = new OssInfo(); String[] split_path = objectSummary.getKey().split("/"); - if(split_path.length>=2) + if (split_path.length >= 2) continue; String[] split_path_again = split_path[0].split("\\."); - if(split_path_again.length>=2) { + if (split_path_again.length >= 2) { info.setIsDir(false); - }else{ + } else { info.setIsDir(true); } info.setName(split_path[0]); @@ -126,21 +130,21 @@ public class AliOssClient implements StandardOssClient { infos.add(info); } - }else{ - for(OSSObjectSummary objectSummary : sums){ + } else { + for (OSSObjectSummary objectSummary : sums) { OssInfo info = new OssInfo(); int x = prefix.split("/").length; String[] split_path = objectSummary.getKey().split("/"); - if(split_path.length>=x+2) + if (split_path.length >= x + 2) continue; - String[] split_path_again = split_path[split_path.length-1].split("\\."); - if(split_path_again.length>=2){ + String[] split_path_again = split_path[split_path.length - 1].split("\\."); + if (split_path_again.length >= 2) { info.setIsDir(false); - }else{ + } else { info.setIsDir(true); } - info.setName(split_path[split_path.length-1]); + info.setName(split_path[split_path.length - 1]); info.setPath(objectSummary.getKey()); info.setLength(DataSizeUtil.format(objectSummary.getSize())); @@ -159,7 +163,7 @@ public class AliOssClient implements StandardOssClient { if (!oss.doesBucketExist(bucketName)) { Bucket bucket = oss.createBucket(bucketName); bucket.setRegion("chengdu"); - }else { + } else { return "bucket already exists"; } } catch (Exception e) { @@ -169,14 +173,13 @@ public class AliOssClient implements StandardOssClient { } public String deleteBucket(String bucketName) { - try{ - if (oss.doesBucketExist(bucketName)){ + try { + if (oss.doesBucketExist(bucketName)) { VoidResult voidResult = oss.deleteBucket(bucketName); - } - else{ + } else { return "bucket does not exist"; } - }catch(Exception e){ + } catch (Exception e) { e.printStackTrace(); } return "yes";