java 阿里云 oss 文件上传

雨点打透心脏的1/2处 2022-12-29 11:27 113阅读 0赞

一、配置信息，在 application.properties中配置

import java.io.Serializable;
    
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    @ConfigurationProperties(prefix="ali.oss")
    public class OSSConfig implements Serializable {
    
        private static final long serialVersionUID = -119396871324982279L;
    
        /**
         * 阿里云 oss 站点
         */
        private String endpoint;
    
        /**
         * 阿里云 oss 资源访问 url
         */
        private String url;
    
        /**
         * 阿里云 oss 公钥
         */
        private String accessKeyId;
    
        /**
         * 阿里云 oss 私钥
         */
        private String accessKeySecret;
    
        /**
         * 阿里云 oss 文件根目录
         */
        private String bucketName;
    
    	public String getEndpoint() {
    		return endpoint;
    	}
    
    	public void setEndpoint(String endpoint) {
    		this.endpoint = endpoint;
    	}
    
    	public String getUrl() {
    		return url;
    	}
    
    	public void setUrl(String url) {
    		this.url = url;
    	}
    
    	public String getAccessKeyId() {
    		return accessKeyId;
    	}
    
    	public void setAccessKeyId(String accessKeyId) {
    		this.accessKeyId = accessKeyId;
    	}
    
    	public String getAccessKeySecret() {
    		return accessKeySecret;
    	}
    
    	public void setAccessKeySecret(String accessKeySecret) {
    		this.accessKeySecret = accessKeySecret;
    	}
    
    	public String getBucketName() {
    		return bucketName;
    	}
    
    	public void setBucketName(String bucketName) {
    		this.bucketName = bucketName;
    	}
    
    
    }

二、上传工具类

import com.aliyun.oss.ClientConfiguration;
    import com.aliyun.oss.OSSClient;
    import com.aliyun.oss.common.auth.DefaultCredentialProvider;
    import com.dy.config.OSSConfig;
    
    import org.springframework.web.multipart.MultipartFile;
    
    import java.io.IOException;
    import java.util.UUID;
    
    /**
     * @Description: 阿里云 oss 上传工具类(高依赖版)
     */
    public class OSSBootUtil {
    
        private OSSBootUtil(){}
    
        /**
         * oss 工具客户端
         */
        private volatile static OSSClient ossClient = null;
    
        /**
         * 上传文件至阿里云 OSS
         * 文件上传成功,返回文件完整访问路径
         * 文件上传失败,返回 null
         *
         * @param ossConfig oss 配置信息
         * @param file 待上传文件
         * @param fileDir 文件保存目录
         * @return oss 中的相对文件路径
         */
        public static String upload(OSSConfig ossConfig, MultipartFile file, String fileDir){
            initOSS(ossConfig);
            StringBuilder fileUrl = new StringBuilder();
            try {
                String suffix = file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf('.'));
                String fileName = System.currentTimeMillis() + "-" + UUID.randomUUID().toString().substring(0,18) + suffix;
                if (!fileDir.endsWith("/")) {
                    fileDir = fileDir.concat("/");
                }
                fileUrl = fileUrl.append(fileDir + fileName);
    
                ossClient.putObject(ossConfig.getBucketName(), fileUrl.toString(), file.getInputStream());
            } catch (IOException e) {
                e.printStackTrace();
                return null;
            }
            fileUrl = fileUrl.insert(0,ossConfig.getUrl());
            return fileUrl.toString();
        }
        
        /**
         * 上传文件至阿里云 OSS
         * 文件上传成功,返回文件完整访问路径
         * 文件上传失败,返回 null
         *
         * @param ossConfig oss 配置信息
         * @param file 待上传文件
         * @param fileDir 文件保存目录
         * @return oss 中的相对文件路径
         */
        public static String del(OSSConfig ossConfig, String fileDir){
            initOSS(ossConfig);
            try {
            	// 删除文件。如需删除文件夹，请将ObjectName设置为对应的文件夹名称。如果文件夹非空，则需要将文件夹下的所有object删除后才能删除该文件夹。
            	ossClient.deleteObject(ossConfig.getBucketName(), fileDir);
            } catch (Exception e) {
                e.printStackTrace();
                return "删除失败";
            }
            return "";
        }
    
        /**
         * 初始化 oss 客户端
         * @param ossConfig
         * @return
         */
        private static OSSClient initOSS(OSSConfig ossConfig) {
            if (ossClient == null ) {
                synchronized (OSSBootUtil.class) {
                    if (ossClient == null) {
                        ossClient = new OSSClient(ossConfig.getEndpoint(),
                                new DefaultCredentialProvider(ossConfig.getAccessKeyId(), ossConfig.getAccessKeySecret()),
                                new ClientConfiguration());
                    }
                }
            }
            return ossClient;
        }
    }

三、service

@Autowired
        private OSSConfig ossConfig;
    
        /**
         * 上传文件至阿里云 oss
         *
         * @param file
         * @param uploadKey
         * @return
         * @throws Exception
         */
        @Override
        public ReturnResult uploadOSS(MultipartFile file, String uploadKey) throws Exception {
            // 高依赖版本 oss 上传工具
            String ossFileUrlBoot = null;
            String dataDir = new SimpleDateFormat("yyyy/MM/dd").format(new Date());
            ossFileUrlBoot = OSSBootUtil.upload(ossConfig, file, dataDir);
            return ReturnResult.ok(ossFileUrlBoot);
        }