SpringBoot整合oss实现文件的上传,查看,删除,下载

转x33g5p2x  于2021-12-23 转载在 Spring  
字(8.3k)|赞(0)|评价(0)|浏览(627)

springboot整合oss实现文件的上传,查看,删除,下载

1.什么是对象存储 OSS?

答：阿里云对象存储服务（Object Storage Service，简称 OSS），是阿里云提供的海量、安全、低成本、高可靠的云存储服务。其数据设计持久性不低于 99.9999999999%（12 个 9），服务设计可用性（或业务连续性）不低于 99.995%。

OSS 具有与平台无关的 RESTful API 接口，您可以在任何应用、任何时间、任何地点存储和访问任意类型的数据。

您可以使用阿里云提供的 API、SDK 接口或者 OSS 迁移工具轻松地将海量数据移入或移出阿里云 OSS。数据存储到阿里云 OSS 以后，您可以选择标准存储（Standard）作为移动应用、大型网站、图片分享或热点音视频的主要存储方式，也可以选择成本更低、存储期限更长的低频访问存储（Infrequent Access）和归档存储（Archive）作为不经常访问数据的存储方式。

有关oss更多，更详细的介绍请参考阿里云oss对象储存官方文档地址

2.登录阿里云，进入到控制台

3.创建Bucket

点击确定，这样我们就建好了。

下面我们来开始写代码?

新建一个spring boot项目

导入如下依赖

pom.xml

  1. <dependency>
  2.             <groupId>org.springframework.boot</groupId>
  3.             <artifactId>spring-boot-starter-web</artifactId>
  4.         </dependency>
  6.         <dependency>
  7.             <groupId>org.springframework.boot</groupId>
  8.             <artifactId>spring-boot-starter-test</artifactId>
  9.             <scope>test</scope>
  10.         </dependency>
  12.         <dependency>
  13.             <groupId>org.springframework.boot</groupId>
  14.             <artifactId>spring-boot-devtools</artifactId>
  15.             <optional>true</optional>
  16.         </dependency>
  18.         <dependency>
  19.             <groupId>com.aliyun.oss</groupId>
  20.             <artifactId>aliyun-sdk-oss</artifactId>
  21.             <version>2.8.3</version>
  22.         </dependency>
  23.         <dependency>
  24.             <groupId>org.projectlombok</groupId>
  25.             <artifactId>lombok</artifactId>
  26.             <version>1.18.4</version>
  27.             <scope>provided</scope>
  28.         </dependency>
  29.         <dependency>
  30.             <groupId>joda-time</groupId>
  31.             <artifactId>joda-time</artifactId>
  32.             <version>2.9.9</version>
  33.         </dependency>
  35.         <dependency>
  36.             <groupId>org.apache.commons</groupId>
  37.             <artifactId>commons-lang3</artifactId>
  38.             <version>3.8.1</version>
  39.         </dependency>

application.properties配置文件

accessKeyId、accessKeySecret需要在accesskeys里面查看

编写一个配置文件AliyunConfig.class

  1. package com.tuanzi.config;
  3. import com.aliyun.oss.OSS;
  4. import com.aliyun.oss.OSSClient;
  5. import lombok.Data;
  6. import org.springframework.boot.context.properties.ConfigurationProperties;
  7. import org.springframework.context.annotation.Bean;
  8. import org.springframework.context.annotation.Configuration;
  9. import org.springframework.context.annotation.PropertySource;
  10. /** * @desc */
  11. @Configuration
  12. @PropertySource(value = {"classpath:application.properties"})
  13. @ConfigurationProperties(prefix = "aliyun")
  14. @Data
  15. public class AliyunConfig {
  16.     private String endpoint;
  17.     private String accessKeyId;
  18.     private String accessKeySecret;
  19.     private String bucketName;
  20.     private String urlPrefix;
  22.     @Bean
  23.     public OSS oSSClient() {
  24.         return new OSSClient(endpoint, accessKeyId, accessKeySecret);
  25.     }
  26. }

controller类

  1. package com.tuanzi.controller;
  3. import com.tuanzi.service.FileUploadService;
  4. import com.tuanzi.vo.FileUploadResult;
  5. import com.aliyun.oss.model.OSSObjectSummary;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.stereotype.Controller;
  8. import org.springframework.web.bind.annotation.RequestMapping;
  9. import org.springframework.web.bind.annotation.RequestParam;
  10. import org.springframework.web.bind.annotation.ResponseBody;
  11. import org.springframework.web.multipart.MultipartFile;
  13. import javax.servlet.http.HttpServletResponse;
  14. import java.io.IOException;
  15. import java.util.List;
  17. /** * @desc */
  18. @Controller
  19. public class FileUploadController {
  20.     @Autowired
  21.     private FileUploadService fileUploadService;
  23.     /** * @desc 文件上传到oss * @return FileUploadResult * @Param uploadFile */
  24.     @RequestMapping("file/upload")
  25.     @ResponseBody
  26.     public FileUploadResult upload(@RequestParam("file") MultipartFile uploadFile)
  27.             throws Exception {
  28.         return this.fileUploadService.upload(uploadFile);
  29.     }
  31.     /** * @return FileUploadResult * @desc 根据文件名删除oss上的文件 * @Param objectName */
  32.     @RequestMapping("file/delete")
  33.     @ResponseBody
  34.     public FileUploadResult delete(@RequestParam("fileName") String objectName)
  35.             throws Exception {
  36.         return this.fileUploadService.delete(objectName);
  37.     }
  39.     /** * @desc 查询oss上的所有文件 * @return List<OSSObjectSummary> * @Param */
  40.     @RequestMapping("file/list")
  41.     @ResponseBody
  42.     public List<OSSObjectSummary> list()
  43.             throws Exception {
  44.         return this.fileUploadService.list();
  45.     }
  47.     /** * @desc 根据文件名下载oss上的文件 * @return * @Param objectName */
  48.     @RequestMapping("file/download")
  49.     @ResponseBody
  50.     public void download(@RequestParam("fileName") String objectName, HttpServletResponse response) throws IOException {
  51.         //通知浏览器以附件形式下载
  52.         response.setHeader("Content-Disposition",
  53.                 "attachment;filename=" + new String(objectName.getBytes(), "ISO-8859-1"));
  54.         this.fileUploadService.exportOssFile(response.getOutputStream(),objectName);
  55.     }
  56. }

service

  1. package com.tuanzi.service;
  3. import com.tuanzi.config.AliyunConfig;
  4. import com.tuanzi.vo.FileUploadResult;
  5. import com.aliyun.oss.OSS;
  6. import com.aliyun.oss.model.*;
  7. import org.apache.commons.lang3.RandomUtils;
  8. import org.apache.commons.lang3.StringUtils;
  9. import org.joda.time.DateTime;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.stereotype.Service;
  12. import org.springframework.web.multipart.MultipartFile;
  14. import java.io.*;
  15. import java.util.List;
  17. /** * @desc */
  18. @Service
  19. public class FileUploadService {
  20.     // 允许上传的格式
  21.     private static final String[] IMAGE_TYPE = new String[]{".bmp", ".jpg",
  22.             ".jpeg", ".gif", ".png"};
  23.     @Autowired
  24.     private OSS ossClient;
  25.     @Autowired
  26.     private AliyunConfig aliyunConfig;
  28.     /** * @desc 文件上传 */
  29.     public FileUploadResult upload(MultipartFile uploadFile) {
  30.         // 校验图片格式
  31.         boolean isLegal = false;
  32.         for (String type : IMAGE_TYPE) {
  33.             if (StringUtils.endsWithIgnoreCase(uploadFile.getOriginalFilename(),
  34.                     type)) {
  35.                 isLegal = true;
  36.                 break;
  37.             }
  38.         }
  39.         //封装Result对象，并且将文件的byte数组放置到result对象中
  40.         FileUploadResult fileUploadResult = new FileUploadResult();
  41.         if (!isLegal) {
  42.             fileUploadResult.setStatus("error");
  43.             return fileUploadResult;
  44.         }
  45.         //文件新路径
  46.         String fileName = uploadFile.getOriginalFilename();
  47.         String filePath = getFilePath(fileName);
  48.         // 上传到阿里云
  49.         try {
  50.             ossClient.putObject(aliyunConfig.getBucketName(), filePath, new
  51.                     ByteArrayInputStream(uploadFile.getBytes()));
  52.         } catch (Exception e) {
  53.             e.printStackTrace();
  54.             //上传失败
  55.             fileUploadResult.setStatus("error");
  56.             return fileUploadResult;
  57.         }
  58.         fileUploadResult.setStatus("done");
  59.         fileUploadResult.setResponse("success");
  60.         fileUploadResult.setName(this.aliyunConfig.getUrlPrefix() + filePath);
  61.         fileUploadResult.setUid(String.valueOf(System.currentTimeMillis()));
  62.         return fileUploadResult;
  63.     }
  65.     /** * @desc 生成路径以及文件名 例如：//images/2019/08/10/15564277465972939.jpg */
  66.     private String getFilePath(String sourceFileName) {
  67.         DateTime dateTime = new DateTime();
  68.         return "images/" + dateTime.toString("yyyy")
  69.                 + "/" + dateTime.toString("MM") + "/"
  70.                 + dateTime.toString("dd") + "/" + System.currentTimeMillis() +
  71.                 RandomUtils.nextInt(100, 9999) + "." +
  72.                 StringUtils.substringAfterLast(sourceFileName, ".");
  73.     }
  75.     /** * @desc 查看文件列表 */
  76.     public List<OSSObjectSummary> list() {
  77.         // 设置最大个数。
  78.         final int maxKeys = 200;
  79.         // 列举文件。
  80.         ObjectListing objectListing = ossClient.listObjects(new ListObjectsRequest(aliyunConfig.getBucketName()).withMaxKeys(maxKeys));
  81.         List<OSSObjectSummary> sums = objectListing.getObjectSummaries();
  82.         return sums;
  83.     }
  85.     /** * @desc 删除文件 */
  86.     public FileUploadResult delete(String objectName) {
  87.         // 根据BucketName,objectName删除文件
  88.         ossClient.deleteObject(aliyunConfig.getBucketName(), objectName);
  89.         FileUploadResult fileUploadResult = new FileUploadResult();
  90.         fileUploadResult.setName(objectName);
  91.         fileUploadResult.setStatus("removed");
  92.         fileUploadResult.setResponse("success");
  93.         return fileUploadResult;
  94.     }
  96.     /** * @desc 下载文件 */
  97.     public void exportOssFile(OutputStream os, String objectName) throws IOException {
  98.         // ossObject包含文件所在的存储空间名称、文件名称、文件元信息以及一个输入流。
  99.         OSSObject ossObject = ossClient.getObject(aliyunConfig.getBucketName(), objectName);
  100.         // 读取文件内容。
  101.         BufferedInputStream in = new BufferedInputStream(ossObject.getObjectContent());
  102.         BufferedOutputStream out = new BufferedOutputStream(os);
  103.         byte[] buffer = new byte[1024];
  104.         int lenght = 0;
  105.         while ((lenght = in.read(buffer)) != -1) {
  106.             out.write(buffer, 0, lenght);
  107.         }
  108.         if (out != null) {
  109.             out.flush();
  110.             out.close();
  111.         }
  112.         if (in != null) {
  113.             in.close();
  114.         }
  115.     }
  116. }

返回值类

  1. package com.tuanzi.vo;
  3. import lombok.Data;
  5. /** * @desc 返回值 */
  6. @Data
  7. public class FileUploadResult {
  8.     // 文件唯一标识
  9.     private String uid;
  10.     // 文件名
  11.     private String name;
  12.     // 状态有：uploading done error removed
  13.     private String status;
  14.     // 服务端响应内容，如：'{"status": "success"}'
  15.     private String response;
  16. }

这样就完成了
我们来运行一下项目
看看效果：访问http://localhost:8080/upload.html

我们来上传一个不符合格式的图片，会有提示信息

来上传一个符合的

上传成功后会直接显示出来。我们来看看oss里面是否有我们上传的图片

发现也有
接下来我们来测试一下查询，下载，和删除
访问：http://localhost:8080/manager.html

会看到我们上传的图片
这里简单的写了个例子
下载图片

删除图片

来看看oss里面

也已经删除了！！！

版权说明 : 本文为转载文章, 版权归原作者所有 版权申明

原文链接 : https://blog.csdn.net/qq_43842093/article/details/122097460

内容来源于网络，如有侵权，请联系作者删除！

springboot云计算腾讯云阿里云

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com