当前位置：安安资源网 > 网站系统源码 > JAVA源码 > SpringBoot集成minio实现文件的上传，下载，获取列表，增加桶等的基本操作
安安资源网安安资源网 JAVA源码 网站系统源码

SpringBoot集成minio实现文件的上传，下载，获取列表，增加桶等的基本操作

SpringBoot集成minio实现文件的上传，下载，获取列表，增加桶等的基本操作

用springboot集成minio首先介绍一下什么是minio： minio是一个基于Apache License v2.0开源协议的对象存储服务。它兼容亚马逊S3云存储服务接口，非常适合于存储大容量非结构化的数据，例如图片、视频、日志文件、备份数据和容器/虚拟机镜像等，而一个对象文件可以是任意大小，从几kb到最大5T不等。

第一步，我们导入minio的jar包

  1.     <!–minio–>
  2.         <dependency>
  3.             <groupId>io.minio</groupId>
  4.             <artifactId>minio</artifactId>
  5.             <version>8.2.0</version>
  6.         </dependency>
  7.         <!–minio–>

复制代码

第二步，编写配置类

  1. package com.wangfugui.apprentice.config;
  3. import io.minio.MinioClient;
  4. import org.springframework.beans.factory.annotation.Value;
  5. import org.springframework.context.annotation.Bean;
  6. import org.springframework.context.annotation.Configuration;
  8. @Configuration
  9. public class MinioConfig {
  11.         @Value(“${minio.url}”)
  12.     private String url;
  13.     @Value(“${minio.accessKey}”)
  14.     private String accessKey;
  15.     @Value(“${minio.secretKey}”)
  16.     private String secretKey;
  18.     @Bean
  19.     public MinioClient getMinioClient() {
  20.         return MinioClient.builder().endpoint(url)
  21.                                 .credentials(accessKey, secretKey).build();
  22.     }
  24. }

复制代码

这一步的目的是将MinioClient 给注入到spring的容器中以供我们使用

第三步，编写util类

  1. package com.wangfugui.apprentice.common.util;
  3. import com.wangfugui.apprentice.dao.dto.Fileinfo;
  4. import io.minio.BucketExistsArgs;
  5. import io.minio.CopyObjectArgs;
  6. import io.minio.CopySource;
  7. import io.minio.GetObjectArgs;
  8. import io.minio.GetPresignedObjectUrlArgs;
  9. import io.minio.ListObjectsArgs;
  10. import io.minio.MakeBucketArgs;
  11. import io.minio.MinioClient;
  12. import io.minio.PutObjectArgs;
  13. import io.minio.RemoveBucketArgs;
  14. import io.minio.RemoveObjectArgs;
  15. import io.minio.Result;
  16. import io.minio.StatObjectArgs;
  17. import io.minio.http.Method;
  18. import io.minio.messages.Bucket;
  19. import io.minio.messages.Item;
  20. import org.springframework.beans.factory.annotation.Autowired;
  21. import org.springframework.stereotype.Component;
  23. import java.io.InputStream;
  24. import java.util.ArrayList;
  25. import java.util.List;
  27. @Component
  28. public class MinioUtil {
  29.         @Autowired
  30.     private MinioClient minioClient;
  32.         /**
  33.          * 创建一个桶
  34.          */
  35.         public void createBucket(String bucket) throws Exception {
  36.                 boolean found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucket).build());
  37.                 if (!found) {
  38.                         minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucket).build());
  39.                 }
  40.         }
  42.         /**
  43.          * 上传一个文件
  44.          */
  45.         public void uploadFile(InputStream stream, String bucket, String objectName) throws Exception {
  46.                 minioClient.putObject(PutObjectArgs.builder().bucket(bucket).object(objectName)
  47.                                 .stream(stream, -1, 10485760).build());
  48.         }
  50.         /**
  51.          * 列出所有的桶
  52.          */
  53.         public List<String> listBuckets() throws Exception {
  54.                 List<Bucket> list = minioClient.listBuckets();
  55.                 List<String> names = new ArrayList<>();
  56.                 list.forEach(b -> {
  57.                         names.add(b.name());
  58.                 });
  59.                 return names;
  60.         }
  62.         /**
  63.          * 列出一个桶中的所有文件和目录
  64.          */
  65.         public List<Fileinfo> listFiles(String bucket) throws Exception {
  66.                 Iterable<Result<Item>> results = minioClient.listObjects(
  67.                             ListObjectsArgs.builder().bucket(bucket).recursive(true).build());
  69.                         List<Fileinfo> infos = new ArrayList<>();
  70.                                 results.forEach(r->{
  71.                                         Fileinfo info = new Fileinfo();
  72.                                         try {
  73.                                                 Item item = r.get();
  74.                                                 info.setFilename(item.objectName());
  75.                                                 info.setDirectory(item.isDir());
  76.                                                 infos.add(info);
  77.                                         } catch (Exception e) {
  78.                                                 e.printStackTrace();
  79.                                         }
  80.                                 });
  81.                 return infos;
  82.         }
  84.         /**
  85.          * 下载一个文件
  86.          */
  87.         public InputStream download(String bucket, String objectName) throws Exception {
  88.                 InputStream stream = minioClient.getObject(
  89.                               GetObjectArgs.builder().bucket(bucket).object(objectName).build());
  90.                 return stream;
  91.         }
  93.         /**
  94.          * 删除一个桶
  95.          */
  96.         public void deleteBucket(String bucket) throws Exception {
  97.                 minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucket).build());
  98.         }
  100.         /**
  101.          * 删除一个对象
  102.          */
  103.         public void deleteObject(String bucket, String objectName) throws Exception {
  104.                 minioClient.removeObject(RemoveObjectArgs.builder().bucket(bucket).object(objectName).build());
  105.         }
  108.         /**
  109.          * 复制文件
  110.          *
  111.          * @Param: [sourceBucket, sourceObject, targetBucket, targetObject]
  112.          * @return: void
  113.          * @Author: MrFugui
  114.          * @Date: 2021/11/15
  115.          */
  116.         public void copyObject(String sourceBucket, String sourceObject, String targetBucket, String targetObject) throws Exception {
  117.                 this.createBucket(targetBucket);
  118.                 minioClient.copyObject(CopyObjectArgs.builder().bucket(targetBucket).object(targetObject)
  119.                                 .source(CopySource.builder().bucket(sourceBucket).object(sourceObject).build()).build());
  120.         }
  122.         /**
  123.          * 获取文件信息
  124.          *
  125.          * @Param: [bucket, objectName]
  126.          * @return: java.lang.String
  127.          * @Author: MrFugui
  128.          * @Date: 2021/11/15
  129.          */
  130.         public String getObjectInfo(String bucket, String objectName) throws Exception {
  132.                 return minioClient.statObject(StatObjectArgs.builder().bucket(bucket).object(objectName).build()).toString();
  134.         }
  136.         /**
  137.          * 生成一个给HTTP GET请求用的presigned URL。浏览器/移动端的客户端可以用这个URL进行下载，即使其所在的存储桶是私有的。
  138.          *
  139.          * @Param: [bucketName, objectName, expires]
  140.          * @return: java.lang.String
  141.          * @Author: MrFugui
  142.          * @Date: 2021/11/15
  143.          */
  144.         public String getPresignedObjectUrl(String bucketName, String objectName, Integer expires) throws Exception {
  145.                 GetPresignedObjectUrlArgs build = GetPresignedObjectUrlArgs
  146.                                 .builder().bucket(bucketName).object(objectName).expiry(expires).method(Method.GET).build();
  147.                 return minioClient.getPresignedObjectUrl(build);
  148.         }
  150.         /**
  151.          * 获取minio中所有的文件
  152.          *
  153.          * @Param: []
  154.          * @return: java.util.List<boot.spring.domain.Fileinfo>
  155.          * @Author: MrFugui
  156.          * @Date: 2021/11/15
  157.          */
  158.         public List<Fileinfo> listAllFile() throws Exception {
  159.                 List<String> list = this.listBuckets();
  160.                 List<Fileinfo> fileinfos = new ArrayList<>();
  161.                 for (String bucketName : list) {
  162.                         fileinfos.addAll(this.listFiles(bucketName));
  163.                 }
  166.                 return fileinfos;
  167.         }
  169. }

复制代码

这里集成了minio sdk中的api 这是minio的api文档

第四步，编写controller类

  1. package com.wangfugui.apprentice.controller;
  3. import com.wangfugui.apprentice.common.util.MinioUtil;
  4. import com.wangfugui.apprentice.common.util.ResponseUtils;
  5. import io.swagger.annotations.Api;
  6. import io.swagger.annotations.ApiOperation;
  7. import org.apache.tomcat.util.http.fileupload.IOUtils;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.web.bind.annotation.GetMapping;
  10. import org.springframework.web.bind.annotation.RequestMapping;
  11. import org.springframework.web.bind.annotation.RequestMethod;
  12. import org.springframework.web.bind.annotation.RequestParam;
  13. import org.springframework.web.bind.annotation.RestController;
  14. import org.springframework.web.multipart.MultipartFile;
  16. import javax.servlet.ServletOutputStream;
  17. import javax.servlet.http.HttpServletResponse;
  18. import java.io.InputStream;
  19. import java.net.URLEncoder;
  21. @Api(tags = “文件操作接口”)
  22. @RestController
  23. @RequestMapping(value = “/file”)
  24. public class FileController {
  26.     @Autowired
  27.     MinioUtil minioUtil;
  29.     @ApiOperation(“上传一个文件”)
  30.     @RequestMapping(value = “/uploadfile”, method = RequestMethod.POST)
  31.     public ResponseUtils fileupload(@RequestParam MultipartFile uploadfile, @RequestParam String bucket,
  32.                                     @RequestParam(required = false) String objectName) throws Exception {
  33.         minioUtil.createBucket(bucket);
  34.         if (objectName != null) {
  35.             minioUtil.uploadFile(uploadfile.getInputStream(), bucket, objectName + “/” + uploadfile.getOriginalFilename());
  36.         } else {
  37.             minioUtil.uploadFile(uploadfile.getInputStream(), bucket, uploadfile.getOriginalFilename());
  38.         }
  39.         return ResponseUtils.success();
  40.     }
  42.     @ApiOperation(“列出所有的桶”)
  43.     @RequestMapping(value = “/listBuckets”, method = RequestMethod.GET)
  44.     public ResponseUtils listBuckets() throws Exception {
  45.         return ResponseUtils.success(minioUtil.listBuckets());
  46.     }
  48.     @ApiOperation(“递归列出一个桶中的所有文件和目录”)
  49.     @RequestMapping(value = “/listFiles”, method = RequestMethod.GET)
  50.     public ResponseUtils listFiles(@RequestParam String bucket) throws Exception {
  51.         return ResponseUtils.success(minioUtil.listFiles(bucket));
  52.     }
  54.     @ApiOperation(“下载一个文件”)
  55.     @RequestMapping(value = “/downloadFile”, method = RequestMethod.GET)
  56.     public void downloadFile(@RequestParam String bucket, @RequestParam String objectName,
  57.                              HttpServletResponse response) throws Exception {
  58.         InputStream stream = minioUtil.download(bucket, objectName);
  59.         ServletOutputStream output = response.getOutputStream();
  60.         response.setHeader(“Content-Disposition”, “attachment;filename=” + URLEncoder.encode(objectName.substring(objectName.lastIndexOf(“/”) + 1), “UTF-8”));
  61.         response.setContentType(“application/octet-stream”);
  62.         response.setCharacterEncoding(“UTF-8”);
  63.         IOUtils.copy(stream, output);
  64.     }
  67.     @ApiOperation(“删除一个文件”)
  68.     @RequestMapping(value = “/deleteFile”, method = RequestMethod.GET)
  69.     public ResponseUtils deleteFile(@RequestParam String bucket, @RequestParam String objectName) throws Exception {
  70.         minioUtil.deleteObject(bucket, objectName);
  71.         return ResponseUtils.success();
  72.     }
  74.     @ApiOperation(“删除一个桶”)
  75.     @RequestMapping(value = “/deleteBucket”, method = RequestMethod.GET)
  76.     public ResponseUtils deleteBucket(@RequestParam String bucket) throws Exception {
  77.         minioUtil.deleteBucket(bucket);
  78.         return ResponseUtils.success();
  79.     }
  82.     @ApiOperation(“复制一个文件”)
  83.     @GetMapping(“/copyObject”)
  84.     public ResponseUtils copyObject(@RequestParam String sourceBucket, @RequestParam String sourceObject, @RequestParam String targetBucket, @RequestParam String targetObject) throws Exception {
  85.         minioUtil.copyObject(sourceBucket, sourceObject, targetBucket, targetObject);
  86.         return ResponseUtils.success();
  87.     }
  89.     @GetMapping(“/getObjectInfo”)
  90.     @ApiOperation(“获取文件信息”)
  91.     public ResponseUtils getObjectInfo(@RequestParam String bucket, @RequestParam String objectName) throws Exception {
  93.         return ResponseUtils.success(minioUtil.getObjectInfo(bucket, objectName));
  94.     }
  96.     @GetMapping(“/getPresignedObjectUrl”)
  97.     @ApiOperation(“获取一个连接以供下载”)
  98.     public ResponseUtils getPresignedObjectUrl(@RequestParam String bucket, @RequestParam String objectName, @RequestParam Integer expires) throws Exception {
  100.         return ResponseUtils.success(minioUtil.getPresignedObjectUrl(bucket, objectName, expires));
  101.     }
  103.     @GetMapping(“/listAllFile”)
  104.     @ApiOperation(“获取minio中所有的文件”)
  105.     public ResponseUtils listAllFile() throws Exception {
  107.         return ResponseUtils.success(minioUtil.listAllFile());
  108.     }
  111. }

复制代码

注意这里的ResponseUtils请去附件中下载，在yml中配置minio的地址
第五步，配置yml文件

  1. minio:
  2.   url: http://1localhost:9000  #对象存储服务的URL
  3.   accessKey: root #账户
  4.   secretKey: 123456 #密码

复制代码

第六步，启动项目，访问api

到这里就完成了springboot集成minio实现文件的上传等功能

PS:附件中包含了本例的源码及spring-minio源码

下载说明：
1.本站资源都是白菜价出售，同样的东西，我们不卖几百，也不卖几十，甚至才卖几块钱，一个永久会员能下载全站100%源码了，所以单独购买也好，会员也好均不提供相关技术服务。
2.如果源码下载地址失效请联系站长QQ进行补发。
3.本站所有资源仅用于学习及研究使用,请必须在24小时内删除所下载资源，切勿用于商业用途，否则由此引发的法律纠纷及连带责任本站和发布者概不承担。资源除标明原创外均来自网络整理,版权归原作者或本站特约原创作者所有,如侵犯到您权益请联系本站删除!
4.本站站内提供的所有可下载资源（软件等等）本站保证未做任何负面改动（不包含修复bug和完善功能等正面优化或二次开发）；但本网站不能保证资源的准确性、安全性和完整性，由于源码具有复制性，一经售出，概不退换。用户下载后自行斟酌，我们以交流学习为目的，并不是所有的源码都100%无错或无bug；同时本站用户必须明白，【安安资源网】对提供下载的软件等不拥有任何权利（本站原创和特约原创作者除外），其版权归该资源的合法拥有者所有。
5.请您认真阅读上述内容，购买即以为着您同意上述内容，由于源码具有复制性，一经售出，概不退换。
安安资源网 » SpringBoot集成minio实现文件的上传，下载，获取列表，增加桶等的基本操作

相关推荐