spring boot 整合阿里云oss上传

末蓝、 2022-11-25 13:05 201阅读 0赞

### Spring Boot 整合 阿里云OSS上传 ###

*  OSS申请和配置
 *   *  1. 注册登录
     *  2.开通以及配置
 *  springboot整合使用
 *   *  1. 进入我们springboot的项目中，导入oss相关依赖
     *  2. 再配置文件中添加相关信息
     *  3. 书写获取配置信息的java文件，建立properties包（导入依赖，否则无法识别这个包）
     *  4. 整合oss,书写相关java文件
     *   *  1. 文件常量java文件 FileConstants.java
         *  2. 文件操作工具类 OssFileUtils.java
         *  3. 阿里云 对象云存储工具类 OssUtil.java
     *  5. controller 调用样例

# OSS申请和配置 #

## 1. 注册登录 ##

输入网址：[https://www.aliyun.com/product/oss][https_www.aliyun.com_product_oss]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70]  
如果没有账号点击免费注册，然后登录。

## 2.开通以及配置 ##

1.  点击立即开通  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 1]
2.  进入管理控制台  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 2]
3.  第一次使用会出现引导，按引导点击“我知道了”，然后点击创建Bucket。  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 3]  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 4]
4.  如果没有存储包或流量包点击购买。  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 5]
5.  点击确定，返回主页面，出现该页面，点击我知道了  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 6]
6.  将EndPoint记录下来，方便后期添加到我们项目的配置文件中  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 7]
7.  创建 AccessKeyID 和 AccessKeySecret  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 8]  
    点击创建Access key，第一次需要短信验证，验证成功后弹出  
    保留Access key 以及 AccessKeySecret 信息

# springboot整合使用 #

## 1. 进入我们springboot的项目中，导入oss相关依赖 ##

<dependency>
        <groupId>com.aliyun.oss</groupId>
        <artifactId>aliyun-sdk-oss</artifactId>
        <version>2.8.3</version>
    </dependency>

## 2. 再配置文件中添加相关信息 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 9]

oss.aliyun.accessKeyId= #
    oss.aliyun.accessKeySecret= #
    oss.aliyun.bucketName= mutest-qcby-oss
    oss.aliyun.endpoint= #
    oss.aliyun.pubFlag= false
    oss.aliyun.expiration= 100 
    oss.aliyun.sslNmae= #内网使用，不必须

## 3. 书写获取配置信息的java文件，建立properties包（导入依赖，否则无法识别这个包） ##

<dependency>
       	 <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-configuration-processor</artifactId>
         <optional>true</optional>
     </dependency>

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 10]  
OssProerties.java

import com.mbyte.easy.oss.OssUtil;
    import lombok.Data;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.boot.context.properties.EnableConfigurationProperties;
    import org.springframework.context.annotation.PropertySource;
    import org.springframework.stereotype.Component;
    
    import javax.annotation.PostConstruct;
    
    /** * @ClassName: OssProerties * @Description: 阿里云 对象云存储配置类 * @Author: zte * @Date: 2019-02-14 09:37 * @Version 1.0 **/
    @Data
    @Component
    @ConfigurationProperties(prefix = "oss.aliyun")
    public class OssProerties { 
        private  String accessKeyId;
        private  String accessKeySecret;
        private  String bucketName;
        private  String endpoint;
        private  String bucket;
        private  boolean pubFlag;
        private  String sslNmae;
    
        @PostConstruct
        public void init(){ 
            //Oss工具类配置初始化
            OssUtil.initConfig(this);
        }
    
    
        //过期时间
        private  int  expiration;
    
        public String getAccessKeyId() { 
            return accessKeyId;
        }
    
        public OssProerties setAccessKeyId(String accessKeyId) { 
            this.accessKeyId = accessKeyId;
            return this;
        }
    
        public String getAccessKeySecret() { 
            return accessKeySecret;
        }
    
        public OssProerties setAccessKeySecret(String accessKeySecret) { 
            this.accessKeySecret = accessKeySecret;
            return this;
        }
    
        public String getBucketName() { 
            return bucketName;
        }
    
        public OssProerties setBucketName(String bucketName) { 
            this.bucketName = bucketName;
            return this;
        }
    
        public String getEndpoint() { 
            return endpoint;
        }
    
        public OssProerties setEndpoint(String endpoint) { 
            this.endpoint = endpoint;
            return this;
        }
    
        public String getBucket() { 
            return bucket;
        }
    
        public OssProerties setBucket(String bucket) { 
            this.bucket = bucket;
            return this;
        }
    
        public boolean isPubFlag() { 
            return pubFlag;
        }
    
        public void setPubFlag(boolean pubFlag) { 
            this.pubFlag = pubFlag;
        }
    
        public int getExpiration() { 
            return expiration;
        }
    
        public OssProerties setExpiration(int expiration) { 
            this.expiration = expiration;
            return this;
        }
    
        @Override
        public String toString() { 
            return "OssPro{" +
                    "accessKeyId='" + accessKeyId + '\'' +
                    ", accessKeySecret='" + accessKeySecret + '\'' +
                    ", bucketName='" + bucketName + '\'' +
                    ", endpoint='" + endpoint + '\'' +
                    ", bucket='" + bucket + '\'' +
                    ", expiration=" + expiration +
                    '}';
        }
    }

## 4. 整合oss,书写相关java文件 ##

### 1. 文件常量java文件 FileConstants.java ###

package com.mbyte.easy.oss;
    
    import org.springframework.util.ClassUtils;
    
    import java.io.File;
    
    /** * @ClassName: FileConstants * @Description: 文件常量 * @Author: zte * @Date: 2019-02-19 09:59 * @Version 1.0 **/
    public class FileConstants { 
        /** * 文件存储临时文件夹 */
        public final static String TEMP_ROOT = "temp";
        /** * 下载暂存目录 */
        public final static String DOWNLOAD = TEMP_ROOT+ File.separator+"download";
        /** * 后缀名相关常量(包含【.】) */
        public final static String SUFFIX_ZIP = ".zip";
        /** * png图片后缀 */
        public final static String SUFFIX_png = ".png";
        /** * 二维码暂存路径 eg：微信支付二维码 */
        public static final String QRCODE = "qrcode";
        public static final String QRCODE_PATH = ClassUtils.getDefaultClassLoader().getResource("static").getPath()+File.separator+QRCODE;
    
        /** * 文件的后缀名 */
        public static final String FILE_TYPE_AVI  = "avi";
        public static final String FILE_TYPE_CSV = "csv";
        public static final String FILE_TYPE_DOC  = "doc";
        public static final String FILE_TYPE_DOCX  = "docx";
        public static final String FILE_TYPE_MP3 = "mp3";
        public static final String FILE_TYPE_PDF  = "pdf";
        public static final String FILE_TYPE_PPT  = "ppt";
        public static final String FILE_TYPE_PPTX  = "pptx";
        public static final String FILE_TYPE_RAR  = "rar";
        public static final String FILE_TYPE_TXT  = "txt";
        public static final String FILE_TYPE_XLS = "xls";
        public static final String FILE_TYPE_ZIP  = "zip";
        /** * 文件对应图片的oss路径 */
        public static final String FILE_TYPE_AVI_ROUTE = "https://hmett.oss-cn-beijing.aliyuncs.com/20191205092751242.U27AJS.png?Expires=4731182871&OSSAccessKeyId=LTAI4FqUE3bJs9FK7Sj65JnM&Signature=0S4nIClHiI11Iw2SOnLoKuwpiDc%3D";
        public static final String FILE_TYPE_CSV_ROUTE = "https://hmett.oss-cn-beijing.aliyuncs.com/20191205092859378.A0J8R6.png?Expires=4731182939&OSSAccessKeyId=LTAI4FqUE3bJs9FK7Sj65JnM&Signature=McS77A%2BMOkmSjBfZziIxLeR5QCM%3D";
        public static final String FILE_TYPE_DOC_ROUTE = "https://hmett.oss-cn-beijing.aliyuncs.com/20191205092908602.QHFWCO.png?Expires=4731182949&OSSAccessKeyId=LTAI4FqUE3bJs9FK7Sj65JnM&Signature=%2Fr9V%2FP8nmfYKVbANe2fl1qR%2FFwg%3D";
        public static final String FILE_TYPE_DOCX_ROUTE = "https://hmett.oss-cn-beijing.aliyuncs.com/20191205092908602.QHFWCO.png?Expires=4731182949&OSSAccessKeyId=LTAI4FqUE3bJs9FK7Sj65JnM&Signature=%2Fr9V%2FP8nmfYKVbANe2fl1qR%2FFwg%3D";
        public static final String FILE_TYPE_MP3_ROUTE = "https://hmett.oss-cn-beijing.aliyuncs.com/20191205092920411.L5CBAF.png?Expires=4731182960&OSSAccessKeyId=LTAI4FqUE3bJs9FK7Sj65JnM&Signature=wPz2ylPAg%2FpBqyIz4LztacVfRwo%3D";
        public static final String FILE_TYPE_PDF_ROUTE = "https://hmett.oss-cn-beijing.aliyuncs.com/20191205092930146.CU0CAD.png?Expires=4731182970&OSSAccessKeyId=LTAI4FqUE3bJs9FK7Sj65JnM&Signature=Nwl6%2BkZmosARipe%2BoVJT3FdRLqM%3D";
        public static final String FILE_TYPE_PPT_ROUTE = "https://hmett.oss-cn-beijing.aliyuncs.com/20191205092939365.XHOX9G.png?Expires=4731182979&OSSAccessKeyId=LTAI4FqUE3bJs9FK7Sj65JnM&Signature=3CDxl0W5ymVXe2XLnxLn1ewc1gU%3D";
        public static final String FILE_TYPE_PPTX_ROUTE = "https://hmett.oss-cn-beijing.aliyuncs.com/20191205092939365.XHOX9G.png?Expires=4731182979&OSSAccessKeyId=LTAI4FqUE3bJs9FK7Sj65JnM&Signature=3CDxl0W5ymVXe2XLnxLn1ewc1gU%3D";
        public static final String FILE_TYPE_RAR_ROUTE = "https://hmett.oss-cn-beijing.aliyuncs.com/20191205092949684.9OW7L9.png?Expires=4731182989&OSSAccessKeyId=LTAI4FqUE3bJs9FK7Sj65JnM&Signature=RCKarsekmPG3CXI5D6MLpJ4ocj4%3D";
        public static final String FILE_TYPE_TXT_ROUTE = "https://hmett.oss-cn-beijing.aliyuncs.com/20191205092959887.TF1K0N.png?Expires=4731183000&OSSAccessKeyId=LTAI4FqUE3bJs9FK7Sj65JnM&Signature=9l44IQ0FZdQMcRq92PPOXlBKEFk%3D";
        public static final String FILE_TYPE_XLS_ROUTE = "https://hmett.oss-cn-beijing.aliyuncs.com/20191205093007830.M6O08Z.png?Expires=4731183008&OSSAccessKeyId=LTAI4FqUE3bJs9FK7Sj65JnM&Signature=GeNmvgi7TGMq3uk9AG0%2BJRWRFY0%3D";
        public static final String FILE_TYPE_ZIP_ROUTE = "https://hmett.oss-cn-beijing.aliyuncs.com/20191205093017998.Q39L45.png?Expires=4731183018&OSSAccessKeyId=LTAI4FqUE3bJs9FK7Sj65JnM&Signature=djzJ7rTgH8LvCeaMfWGXUAQIpJE%3D";
    }

### 2. 文件操作工具类 OssFileUtils.java ###

import com.mbyte.easy.common.web.AjaxResult;
    import com.mbyte.easy.oss.OssUtil;
    import lombok.extern.slf4j.Slf4j;
    import org.apache.commons.lang3.StringUtils;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.web.multipart.MultipartFile;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.URL;
    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.nio.file.Paths;
    import java.nio.file.StandardCopyOption;
    import java.util.*;
    
    /** * @ClassName: DesignFileUtils * @Description: 文件操作工具类 * @Author: zte * @Date: 2019-02-15 14:50 * @Version 1.0 **/
    @Slf4j
    public class OssFileUtils { 
        /** * @Title: uploadSingleFile * @Description: 单个文件上传 * @Author: zte * @param: file * @Date: 2019-02-15 14:56 * @return: java.lang.String 成功返回 文件路径，失败返回null * @throws: */
        public static String uploadSingleFile(MultipartFile file){ 
            if(file == null){ 
                log.error("单文件上传失败，文件为空");
                return null;
            }
            try { 
                return OssUtil.upload(OssUtil.generateKey(file.getOriginalFilename()),file.getBytes());
            } catch (Exception e) { 
                log.error("单文件上传异常【"+file+"】",e);
            }
            return null;
        }
        /** * @Title: uploadSingleFile * @Description: 单个文件上传 * @Author: zte * @param: file * @Date: 2019-02-15 14:56 * @return: java.lang.String 成功返回 文件路径，失败返回null * @throws: */
        public static String uploadSingleFile(File file){ 
            if(file == null){ 
                log.error("单文件上传失败，文件为空");
                return null;
            }
            try { 
                return OssUtil.upload(OssUtil.generateKey(file.getName()),file);
            } catch (Exception e) { 
                log.error("单文件上传异常【"+file+"】",e);
            }
            return null;
        }
        /** * @Title: uploadMultipartFile * @Description: 多文件文件上传 * @Author: zte * @param: files * @Date: 2019-02-18 13:08 * @return: java.util.List<java.lang.String> 成功返回 文件路径集合，失败返回null * @throws: */
        public static List<String> uploadMultipartFile(List<MultipartFile> fileList){ 
            List<String> filePaths = new ArrayList<>();
            Optional.ofNullable(fileList).ifPresent(fl->{ 
                            fl.stream().forEach(f->{ 
                                try { 
                                    filePaths.add(OssUtil.upload(OssUtil.generateKey(f.getOriginalFilename()),f.getBytes()));
                                } catch (IOException e) { 
                                    log.error("多文件上传异常【"+f+"】",e);
                                }
                            });
                    }
            );
            return filePaths;
        }
        /** * @Title: downloadSingleFileByOss * @Description: 下载阿里云文件到本地 * @Author: zte * @param: url 阿里云链接 * @param: filePath 下载目录 * @Date: 2019-02-18 13:13 * @return: java.io.File * @throws: */
        public static File downloadSingleFile(String url,String filePath){ 
            try { 
                return OssUtil.download2File(url,filePath);
            } catch (Exception e) { 
                log.error("单文件下载异常【"+url+"】",e);
            }
            return null;
        }
        /** * @Title: downloadMultipartFileByOss * @Description: 批量下载阿里云文件到本地 * @Author: zte * @param: urlList 阿里云链接集合 * @param: dir 下载目录 * @Date: 2019-02-18 13:19 * @return: java.util.List<java.io.File> * @throws: */
        public static List<File> downloadMultipartFile(List<String> urlList,String dir){ 
            List<File> files = new ArrayList<>();
            Optional.ofNullable(urlList).ifPresent(fl->{ 
                        fl.stream().forEach(f->files.add(OssUtil.download2Dir(f,dir)));
                    }
            );
            return files;
        }
    
        /** * @Title: isFileBySuffix * @Description: 通过后缀名判断是否是某种文件 * @Author: zte * @param: fileName 文件名称 * @param: suffix 后缀名 * @Date: 2019-02-19 10:09 * @return: boolean * @throws: */
        public static boolean isFileBySuffix(String fileName,String suffix){ 
            if(StringUtils.isNoneBlank(fileName) && StringUtils.isNoneBlank(suffix)){ 
                return fileName.endsWith(suffix.toLowerCase()) || fileName.endsWith(suffix.toUpperCase());
            }
            return false;
        }
        /** * @Title: downloadByUrlPath * @Description: 下载网络文件 * @Author: zte * @param: urlPath * @param: saveDir * @param: fileName * @Date: 2019-02-23 16:26 * @return: java.io.File * @throws: */
        public static File downloadByUrlPath(String urlPath,String saveDir,String fileName){ 
            if(StringUtils.isBlank(urlPath)){ 
                log.error("下载网络文件失败，链接为空");
                return null;
            }
            try (InputStream ins = new URL(urlPath).openStream()) { 
                Path target = Paths.get(saveDir, fileName);
                Files.createDirectories(target.getParent());
                Files.copy(ins, target, StandardCopyOption.REPLACE_EXISTING);
                return new File(saveDir+File.separator+fileName);
            } catch (IOException e) { 
                log.error("下载网络文件异常",e);
            }
            return null;
        }
    }

### 3. 阿里云 对象云存储工具类 OssUtil.java ###

import com.aliyun.oss.OSS;
    import com.aliyun.oss.OSSClient;
    import com.aliyun.oss.model.GetObjectRequest;
    import com.aliyun.oss.model.OSSObject;
    import com.mbyte.easy.properties.OssProerties;
    import com.mbyte.easy.util.Utility;
    import lombok.extern.slf4j.Slf4j;
    import org.apache.commons.io.FilenameUtils;
    import org.apache.commons.lang3.StringUtils;
    import org.apache.commons.lang3.time.DateFormatUtils;
    import org.apache.commons.lang3.time.DateUtils;
    import org.apache.logging.log4j.util.Strings;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.multipart.MultipartFile;
    
    import javax.servlet.http.HttpServletResponse;
    import java.io.*;
    import java.net.URLEncoder;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.Map;
    
    /** * @ClassName: OSSUtill * @Description: 阿里云 对象云存储工具类 * @Author: zte * @Date: 2019-02-13 14:38 * @Version 1.0 **/
    @Slf4j
    public class OssUtil { 
        /** * 注入配置 */
        private static OssProerties ossProerties;
        /** * @Title: initConfig * @Description: 配置初始化 * @Author: zte * @param: ossProertiesInit * @Date: 2019-02-14 09:25 * @throws: */
        public static void initConfig(OssProerties ossProertiesInit){ 
            ossProerties = ossProertiesInit;
        }
    
        /** * @Title: generateKey * @Description: 生成oss对象名称 * @Author: zte * @param: fileName * @Date: 2019-02-13 15:21 * @return: java.lang.String * @throws: */
        public  static String generateKey(String fileName) { 
            //对象名称格式：yyyymm.name.6位随机字符.ext
            return new StringBuilder(DateFormatUtils.format(new Date(), "yyyyMMddHHmmssSSS"))
                    .append(".").append(Utility.getRandomStrByNum(6))
                    .append(".").append(FilenameUtils.getExtension(fileName))
                    .toString();
        }
    
        public static String getHttpsAddress(String url){ 
            return url.replaceAll("http://"+ossProerties.getBucket(),ossProerties.getSslNmae());
        }
    
        /** * @Title: upload * @Description: 上传方法 * @Author: zte * @param: key 对象名称 * @param: file待上传文件 * @Date: 2019-02-13 15:35 * @return: java.lang.String * @throws: */
        public  static String upload(String key,File file) { 
            if(file == null || !file.exists()){ 
                log.error("阿里云上传文件失败【"+file+"】不存在");
                return null;
            }
            log.info("阿里云上传文件开始：【"+file+"】");
            OSS ossClient = new OSSClient(ossProerties.getEndpoint(), ossProerties.getAccessKeyId(), ossProerties.getAccessKeySecret());
            try { 
                ossClient.putObject(ossProerties.getBucketName(),key,file);
                //设置url过期时间
                Date expirationDate = DateUtils.addYears(new Date(), ossProerties.getExpiration());
                String url = ossClient.generatePresignedUrl(ossProerties.getBucketName(), key, expirationDate).toString();
                log.info("阿里云上传文件结束：【"+file+"】=>【"+url+"】");
                return getHttpsAddress(url);
            }catch(Exception e) { 
                log.error("阿里云上传文件异常【"+file+"】",e);
            }finally { 
                ossClient.shutdown();
            }
            return null;
        }
        /** * @Title: upload * @Description: 上传方法 * @Author: zte * @param: key 对象名称 * @param: file待上传文件 * @Date: 2019-02-13 15:35 * @return: java.lang.String * @throws: */
        public  static String upload(String key,byte[] bytes) { 
            if(bytes == null || StringUtils.isBlank(key)){ 
                log.error("阿里云上传文件不存在:【"+key+"】");
                return null;
            }
            log.info("阿里云上传文件开始:【"+key+"】");
            OSS ossClient = new OSSClient(ossProerties.getEndpoint(), ossProerties.getAccessKeyId(), ossProerties.getAccessKeySecret());
            try { 
                ossClient.putObject(ossProerties.getBucketName(),key, new ByteArrayInputStream(bytes));
                //设置url过期时间
                Date expirationDate = DateUtils.addYears(new Date(), 100);
                String url = ossClient.generatePresignedUrl(ossProerties.getBucketName(), key, expirationDate).toString();
                log.info("阿里云上传文件结束：【"+key+"】=>【"+url+"】");
                return getHttpsAddress(url);
            }catch(Exception e) { 
                log.error("阿里云上传文件异常:【"+key+"】",e);
            }finally { 
                ossClient.shutdown();
            }
            return null;
        }
        /** * @Title: uploadWithObjectName * @Description: 上传方法，返回对象名称和 url * @Author: zte * @param: file待上传文件 * @Date: 2019-02-13 15:35 * @return: java.lang.Map<String,String> * @throws: */
        public  static Map<String,String> uploadWithObjectName(File file) { 
            if(file == null || !file.exists()){ 
                log.error("阿里云上传文件失败【"+file+"】不存在");
                return null;
            }
            Map<String,String> map = new HashMap<>();
            log.info("阿里云上传文件开始：【"+file+"】");
            OSS ossClient = new OSSClient(ossProerties.getEndpoint(), ossProerties.getAccessKeyId(), ossProerties.getAccessKeySecret());
            try { 
                String key = generateKey(file.getName());
    
                ossClient.putObject(ossProerties.getBucketName(),key, new FileInputStream(file));
                //设置url过期时间
                Date expirationDate = DateUtils.addYears(new Date(), ossProerties.getExpiration());
                String url = ossClient.generatePresignedUrl(ossProerties.getBucketName(), key, expirationDate).toString();
                log.info("阿里云上传文件结束：【"+file+"】=>【"+url+"】");
                map.put("objectName",key);
                map.put("url",url);
                return map;
            }catch(Exception e) { 
                log.error("阿里云上传文件异常【"+file+"】",e);
            }finally { 
                ossClient.shutdown();
            }
            return null;
        }
        /** * @Title: delete * @Description: 删除方法 * @Author: zte * @param: url 待删除对象url * @Date: 2019-02-13 15:54 * @throws: */
        public  static void delete(String url) { 
            if(StringUtils.isBlank(url)){ 
                log.error("阿里云删除文件失败，对象url为空");
                return;
            }
            log.info("阿里云删除文件开始：【"+url+"】");
            if(url.contains(ossProerties.getBucket())){ 
                //根据url获取对象名称
                url = getObjectNameByUrl(url);
            }
            OSS ossClient = new OSSClient(ossProerties.getEndpoint(), ossProerties.getAccessKeyId(), ossProerties.getAccessKeySecret());
            try { 
                // 删除文件
                ossClient.deleteObject(ossProerties.getBucketName(), url);
                log.info("阿里云删除文件结束：【"+url+"】");
            }catch(Exception e) { 
                log.error("阿里云删除文件异常【"+url+"】",e);
            }finally { 
                ossClient.shutdown();
            }
        }
        /** * @Title: download * @Description: 下载文件到本地文件 * @Author: zte * @param: url 待下载对象url * @param: filePath 下载到本地文件 * @Date: 2019-02-13 15:56 * @return: java.io.File * @throws: */
        public static File download2File(String url, String filePath) { 
            log.info("阿里云下载文件开始：【"+url+"】");
            if(url.contains(ossProerties.getBucket())){ 
                //根据url获取对象名称
                url = getObjectNameByUrl(url);
            }
            OSS ossClient = new OSSClient(ossProerties.getEndpoint(), ossProerties.getAccessKeyId(), ossProerties.getAccessKeySecret());
            try { 
                File file = new File(filePath);
                // 下载OSS文件到本地文件。如果指定的本地文件存在会覆盖，不存在则新建。
                ossClient.getObject(new GetObjectRequest(ossProerties.getBucketName(), url),file);
                log.info("阿里云下载文件结束：【"+url+"】");
                return file;
            }catch(Exception e) { 
                log.error("阿里云下载文件异常【"+url+"】",e);
            }finally { 
                ossClient.shutdown();
            }
            return null;
        }
        /** * @Title: download * @Description: 通过流下载文件 * @Author: zte * @param: url 待下载对象url * @param: filePath 下载到本地文件 * @Date: 2019-02-13 15:56 * @return: java.io.File * @throws: */
        public static void download2FileByStream(String url, String fileName, HttpServletResponse response) { 
            BufferedInputStream inputStream = null;
            OSS ossClient = new OSSClient(ossProerties.getEndpoint(), ossProerties.getAccessKeyId(), ossProerties.getAccessKeySecret());
            try(
                    BufferedOutputStream outputStream = new BufferedOutputStream(response.getOutputStream());){ 
                // 配置文件下载
                response.setHeader("content-type", "application/octet-stream");
                response.setContentType("application/octet-stream");
                if(url.contains(ossProerties.getBucket())){ 
                    //根据url获取对象名称
                    url = getObjectNameByUrl(url);
                }
                // 下载文件能正常显示中文
                response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(StringUtils.isBlank(fileName) ? url : fileName, "UTF-8"));
                log.info("阿里云下载文件开始：【"+url+"】");
                // ossObject包含文件所在的存储空间名称、文件名称、文件元信息以及一个输入流。
                OSSObject ossObject = ossClient.getObject(ossProerties.getBucketName(), url);
                inputStream = new BufferedInputStream(ossObject.getObjectContent());
                byte[] buff = new byte[2048];
                int bytesRead;
                while (-1 != (bytesRead = inputStream.read(buff, 0, buff.length))){ 
                    outputStream.write(buff, 0, bytesRead);
                }
                outputStream.flush();
            } catch (Exception e) { 
                log.error("下载异常！", e);
            }finally { 
                log.info("阿里云下载文件结束：【"+url+"】");
                ossClient.shutdown();
                if(inputStream != null){ 
                    try { 
                        inputStream.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
            }
        }
        /** * @Title: download * @Description: 下载文件到指定目录,文件名称为阿里云文件对象名称 * @Author: zte * @param: url 待下载对象url * @param: dir 下载到本地目录 * @Date: 2019-02-13 15:56 * @return: java.io.File * @throws: */
        public static File download2Dir(String url, String dir) { 
            log.info("阿里云下载文件开始：【"+url+"】");
            if(url.contains(ossProerties.getBucket())){ 
                //根据url获取对象名称
                url = getObjectNameByUrl(url);
            }
            OSS ossClient = new OSSClient(ossProerties.getEndpoint(), ossProerties.getAccessKeyId(), ossProerties.getAccessKeySecret());
            try { 
                File file = new File(dir+File.separator+url);
                // 下载OSS文件到本地文件。如果指定的本地文件存在会覆盖，不存在则新建。
                ossClient.getObject(new GetObjectRequest(ossProerties.getBucketName(), url),file);
                log.info("阿里云下载文件结束：【"+url+"】");
                return file;
            }catch(Exception e) { 
                log.error("阿里云下载文件异常【"+url+"】",e);
            }finally { 
                ossClient.shutdown();
            }
            return null;
        }
        /* * @Title: getObjectNameByUrl * @Description: 通过url获取对象名称 * @Author: zte * @param: url * @Date: 2019-02-13 16:20 * @return: java.lang.String * @throws: */
        public  static String getObjectNameByUrl(String url){ 
            if(StringUtils.isBlank(url)){ 
                return null;
            }
            return url.substring(url.indexOf(ossProerties.getBucket())+ossProerties.getBucket().length()+1,url.indexOf("?"));
        }
    
        /** * @author: zte * @description: 重载方法,根据file生成文件名称并且上传文件到阿里云 * @date: 2019/9/21 10:56 * @param file : MultipartFile文件 * @see #upload(String,byte[]) * @return 数据库中要存入的路径 */
        public static String upload(MultipartFile file) throws IOException { 
            if (file == null || Strings.isEmpty(file.getOriginalFilename())){ 
                return null;
            }
            return upload(generateKey(file.getOriginalFilename()), file.getBytes());
        }
    
    
        /** * 调用浏览器下载 * @param url * @param response */
        public static void download2FileByStream(String url,HttpServletResponse response,String name) { 
    
            File file = new File(url);
            String fileName=file.getName();
            fileName= StringUtils.substringBefore(fileName,"?");
            String fileLast=StringUtils.substringAfterLast(fileName,".");
    
            fileName=name+"."+fileLast;
    
    
            BufferedInputStream inputStream = null;
            OSS ossClient = new OSSClient(ossProerties.getEndpoint(), ossProerties.getAccessKeyId(), ossProerties.getAccessKeySecret());
            try(
    
                    BufferedOutputStream outputStream = new BufferedOutputStream(response.getOutputStream());){ 
                // 配置文件下载
                response.setHeader("content-type", "application/octet-stream");
                response.setContentType("application/octet-stream");
                if(url.contains(ossProerties.getBucket())){ 
                    //根据url获取对象名称
                    url = getObjectNameByUrl(url);
                }
                // 下载文件能正常显示中文
                response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(StringUtils.isBlank(fileName) ? url : fileName, "UTF-8"));
                log.info("阿里云下载文件开始：【"+url+"】");
                // ossObject包含文件所在的存储空间名称、文件名称、文件元信息以及一个输入流。
                OSSObject ossObject = ossClient.getObject(ossProerties.getBucketName(), url);
                inputStream = new BufferedInputStream(ossObject.getObjectContent());
                byte[] buff = new byte[2048];
                int bytesRead;
                while (-1 != (bytesRead = inputStream.read(buff, 0, buff.length))){ 
                    outputStream.write(buff, 0, bytesRead);
                }
                outputStream.flush();
            } catch (Exception e) { 
                log.error("下载异常！", e);
            }finally { 
                log.info("阿里云下载文件结束：【"+url+"】");
                ossClient.shutdown();
                if(inputStream != null){ 
                    try { 
                        inputStream.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
            }
        }
    }

## 5. controller 调用样例 ##

我这里使用的是我自己项目封装的 AjaxResult工具类，大家可以使用Map,通过这个方法呢，我们就可以使用oss将图片保存，并且返回前端图片的保存地址(可以访问)。

/** * 上传 * @param fileupload * @return */
        @PostMapping("uploadImg")
        @ResponseBody
        public AjaxResult uploadImg(MultipartFile fileupload){ 
            if(fileupload != null){ 
                String path = OssFileUtils.uploadSingleFile(fileupload);
                return AjaxResult.success(path);
            }else { 
                return AjaxResult.error();
            }
    
        }

[https_www.aliyun.com_product_oss]: https://www.aliyun.com/product/oss
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70]: /images/20221124/3e6dfa97614f43e2bbe85233d5f54ac1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 1]: /images/20221124/423d2b02a7d64f9c952d0699a0a9b2ad.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 2]: /images/20221124/02c952ae34c3427b96512ac6b382af18.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 3]: /images/20221124/84b2c540d9014da4980de575946528a3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 4]: /images/20221124/b37187b57e204f28abb6577025825913.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 5]: /images/20221124/f4e40b7288984cfd8c44192ae4ec9bf5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 6]: /images/20221124/76551840b65b41fc9d649974902293e7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 7]: /images/20221124/74a72b7f751243b4b813598c5002d015.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 8]: /images/20221124/24eaca3ea6784e7eaab3595c30ebd85d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 9]: /images/20221124/b74f24f4ca3a4f679c3974b33bb846c5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ0OTIyMTEz_size_16_color_FFFFFF_t_70 10]: /images/20221124/0ca1edcedde94549be31a920458505b1.png