devbox
神奇cpp
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

SpringBoot集成Minio

作者：神奇cpp | 2024-08-05 10:49:40

赞

踩

SpringBoot集成Minio
  1. public class MinIOConfig {
  2.     @Autowired
  3.     private MinIOConfigProperties minIOConfigProperties;
  4.  
  5.     @Bean
  6.     public MinioClient buildMinioClient() {
  7.         return MinioClient
  8.                 .builder()
  9.                 .credentials(minIOConfigProperties.getAccessKey(), minIOConfigProperties.getSecretKey())
  10.                 .endpoint(minIOConfigProperties.getEndpoint())
  11.                 .build();
  12.     }
  13. }
  1. @Data
  2. @ConfigurationProperties(prefix = "minio")
  3. @Component
  4. public class MinIOConfigProperties implements Serializable {
  5.  
  6.     private String accessKey;
  7.     private String secretKey;
  8.     private String bucket;
  9.     private String endpoint;
  10.     private String readPath;
  11.  
  12. }
  1. public interface MinioFileService {
  2.  
  3.     /**
  4.      * 下载文件
  5.      * @param pathUrl
  6.      * @param response
  7.      */
  8.     void downLoadFile(String pathUrl, HttpServletResponse response) ;
  9.  
  10.     /**
  11.      * 上传文件到指定tong桶下面的指定目录
  12.      * @param bucketName   桶名称
  13.      * @param folderPath   目录名称
  14.      * @param file         文件
  15.      */
  16.     String downLoadFileByPath(String bucketName,String folderPath, MultipartFile file) throws Exception;
  17.  
  18.  
  19.     /**
  20.      * 上传文件
  21.      * @param file
  22.      * @return
  23.      * @throws Exception
  24.      */
  25.      String uploadFile(File file) throws Exception;
  26.  
  27.  
  28.     /**
  29.      * 创建临时目录
  30.      * @return
  31.      */
  32.     File createTempDir();
  33.  
  34.  
  35.     /**
  36.      * 删除文件
  37.      * @param pathUrl
  38.      */
  39.      void delete(String pathUrl) ;
  40.  
  41.     /**
  42.      * 列出所有bucket名称
  43.      * @return
  44.      * @throws Exception
  45.      */
  46.      List<String> listBucketNames() throws Exception;
  47.  
  48.     /**
  49.      * 创建bucket
  50.      * @param bucketName
  51.      * @return
  52.      * @throws Exception
  53.      */
  54.      boolean makeBucket(String bucketName) throws Exception;
  55.  
  56.     /**
  57.      * 删除bucket
  58.      * @param bucketName
  59.      * @return
  60.      * @throws Exception
  61.      */
  62.      boolean removeBucket(String bucketName) throws Exception;
  63.  
  64.     /**
  65.      * 列出bucket的所有对象名称
  66.      * @param bucketName
  67.      * @return
  68.      * @throws Exception
  69.      */
  70.      List<String> listObjectNames(String bucketName) throws Exception;
  71.  
  72.  
  73.      Iterable<Result<Item>> listObjects(String bucketName) throws Exception;
  74. }
  1. @Slf4j
  2. @Import(MinIOConfig.class)
  3. @Service
  4. public class MinioFileServiceImpl  implements MinioFileService {
  5.  
  6.  
  7.     @Autowired
  8.     private MinioClient minioClient;
  9.  
  10.     @Autowired
  11.     private MinIOConfigProperties minIOConfigProperties;
  12.  
  13.     private final static String separator = "/";
  14.  
  15.     @Value("${Temporary_file_address}")
  16.     private String Temporary_file_address;
  17.  
  18.     /**
  19.      * 下载文件
  20.      *
  21.      * @param pathUrl 文件全路径
  22.      * @return 文件流
  23.      */
  24.     @Override
  25.     public  void downLoadFile(String pathUrl, HttpServletResponse response) {
  26.         String[] pathItems = pathUrl.split("/");
  27.         String originFileName = pathItems[pathItems.length - 1];
  28.         String key = pathUrl.replace(minIOConfigProperties.getEndpoint() + "/", "");
  29.         int index = key.indexOf(separator);
  30.         //String bucket = key.substring(0,index);
  31.         String filePath = key.substring(index + 1);
  32.         InputStream inputStream = null;
  33.         try {
  34.             inputStream = minioClient.getObject(GetObjectArgs.builder().bucket(minIOConfigProperties.getBucket()).object(filePath).build());
  35.             response.setHeader("Content-Disposition", "attachment;filename=" + originFileName);
  36.             response.setContentType("application/force-download");
  37.             response.setCharacterEncoding("UTF-8");
  38.             IOUtils.copy(inputStream, response.getOutputStream());
  39.             System.out.println("下载成功");
  40.         } catch (Exception e) {
  41.             log.error("minio down file error.  pathUrl:{}", pathUrl);
  42.             e.printStackTrace();
  43.         } finally {
  44.             try {
  45.                 inputStream.close();
  46.             } catch (IOException e) {
  47.                 e.printStackTrace();
  48.             }
  49.         }
  50.     }
  51.  
  52.     @Override
  53.     public String downLoadFileByPath(String bucketName, String folderPath, MultipartFile file)  throws Exception{
  54.         String endpoint = minIOConfigProperties.getEndpoint();
  55.         // 上传文件到指定文件夹
  56.         String objectName = folderPath+"/" + file.getOriginalFilename();
  57.         PutObjectArgs objectArgs = PutObjectArgs.builder().object(objectName)
  58.                 .bucket(bucketName)
  59.                 .contentType(file.getContentType())
  60.                 .stream(file.getInputStream(), file.getSize(), -1).build();
  61.         minioClient.putObject(objectArgs);
  62.         return endpoint + "/" + bucketName + "/" + objectName;
  63.  
  64.     }
  65.  
  66.     //    @Override
  67. //    public String uploadFile(MultipartFile file) throws Exception {
  68. //        String bucketName = minIOConfigProperties.getBucket();
  69. //        String endpoint = minIOConfigProperties.getEndpoint();
  70. //        InputStream inputStream = file.getInputStream();
  71. //        // 检查存储桶是否已经存在
  72. //        boolean isExist = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
  73. //        if (isExist) {
  74. //            System.out.println("Bucket already exists.");
  75. //        } else {
  76. //            minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
  77. //        }
  78. //        String originalFilename = file.getOriginalFilename();
  79. //        //拼接生成新的UUID形式的文件名
  80. //        String objectName = new SimpleDateFormat("yyyy/MM/dd/").format(new Date()) +
  81. //                UUID.randomUUID().toString().replaceAll("-", "")
  82. //                + originalFilename.substring(originalFilename.lastIndexOf("."));
  83. //
  84. //        PutObjectArgs objectArgs = PutObjectArgs.builder().object(objectName)
  85. //                .bucket(bucketName)
  86. //                .contentType(file.getContentType())
  87. //                .stream(inputStream, file.getSize(), -1).build();
  88. //        minioClient.putObject(objectArgs);
  89. //        inputStream.close();
  90. //        //组装桶中文件的访问url
  91. //        String resUrl = endpoint + "/" + bucketName + "/" + objectName;
  92. //        return resUrl;
  93. //    }
  94.     @Override
  95.     public String uploadFile(File file) throws Exception {
  96.         String bucketName = minIOConfigProperties.getBucket();
  97.         String endpoint = minIOConfigProperties.getEndpoint();
  98.  
  99.         try {
  100.             // 检查存储桶是否已经存在
  101.             if (!minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build())) {
  102.                 minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
  103.             }
  104.             // 拼接生成新的UUID形式的文件名
  105.             String objectName = new SimpleDateFormat("yyyy/MM/dd/").format(new Date()) +
  106.                     UUID.randomUUID().toString().replaceAll("-", "") +
  107.                     file.getName().substring(file.getName().lastIndexOf("."));
  108.             // 上传
  109.             minioClient.uploadObject(UploadObjectArgs.builder()
  110.                     .bucket(bucketName)
  111.                     .object(objectName)
  112.                     .filename(file.getAbsolutePath())
  113.                     .build());
  114.             // 组装桶中文件的访问url
  115.             return endpoint + "/" + bucketName + "/" + objectName;
  116.         } catch (Exception e) {
  117.             log.error("上传文件 {} 失败： {}", file.getName(), e.getMessage());
  118.             e.printStackTrace();
  119.             throw new ServiceException(1000000500, "上传文件失败：" + e);
  120.         } finally {
  121.             // 删除临时文件
  122.             this.deleteTempFile(file);
  123.         }
  124.     }
  125.  
  126.     /**
  127.      * 在应用启动时
  128.      * 创建临时目录
  129.      */
  130.     @Override
  131.     public File createTempDir() {
  132.         String property = System.getProperty("user.home");
  133.         // 生成或指定文件存储的目录
  134.         File dir = new File(property);
  135.         if (!dir.exists()) {
  136.             dir.mkdirs();
  137.         }
  138.         return dir;
  139.     }
  140.     /**
  141.      * 删除临时文件
  142.      * @param file file
  143.      */
  144.     private void deleteTempFile(File file) {
  145.         try {
  146.             Files.deleteIfExists(Paths.get(file.getAbsolutePath()));
  147.         } catch (IOException e) {
  148.             log.error("删除临时文件失败： {}", file.getAbsolutePath(), e);
  149.         }
  150.     }
  151.  
  152.  
  153.     /**
  154.      * 删除文件
  155.      *
  156.      * @param pathUrl 文件全路径
  157.      */
  158.     @Override
  159.     public void delete(String pathUrl) {
  160.         String key = pathUrl.replace(minIOConfigProperties.getEndpoint() + "/", "");
  161.         int index = key.indexOf(separator);
  162.         String bucket = key.substring(0, index);
  163.         String filePath = key.substring(index + 1);
  164.         // 删除Objects
  165.         RemoveObjectArgs removeObjectArgs = RemoveObjectArgs.builder().bucket(bucket).object(filePath).build();
  166.         try {
  167.             minioClient.removeObject(removeObjectArgs);
  168.         } catch (Exception e) {
  169.             log.error("minio remove file error.  pathUrl:{}", pathUrl);
  170.             e.printStackTrace();
  171.         }
  172.     }
  173.  
  174.     public List<Bucket> listBuckets()
  175.             throws Exception {
  176.         return minioClient.listBuckets();
  177.     }
  178.  
  179.     public boolean bucketExists(String bucketName) throws Exception {
  180.         boolean flag = minioClient.bucketExists( BucketExistsArgs.builder().bucket(bucketName).build());
  181.         if (flag) {
  182.             return true;
  183.         }
  184.         return false;
  185.     }
  186.  
  187.     @Override
  188.     public List<String> listBucketNames() throws Exception{
  189.         List<Bucket> bucketList = listBuckets();
  190.         List<String> bucketListName = new ArrayList<>();
  191.         for (Bucket bucket : bucketList) {
  192.             bucketListName.add(bucket.name());
  193.         }
  194.         return bucketListName;
  195.     }
  196.  
  197.     @Override
  198.     public boolean makeBucket(String bucketName) throws Exception{
  199.         boolean flag = this.bucketExists(bucketName);
  200.         if (!flag) {
  201.             minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
  202.             return true;
  203.         } else {
  204.             return false;
  205.         }
  206.     }
  207.  
  208.     @Override
  209.     public boolean removeBucket(String bucketName) throws Exception{
  210.         boolean flag = bucketExists(bucketName);
  211.         if (flag) {
  212.             Iterable<Result<Item>> myObjects = listObjects(bucketName);
  213.             for (Result<Item> result : myObjects) {
  214.                 Item item = result.get();
  215.                 // 有对象文件，则删除失败
  216.                 if (item.size() > 0) {
  217.                     return false;
  218.                 }
  219.             }
  220.             // 删除存储桶，注意，只有存储桶为空时才能删除成功。
  221.             minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build());
  222.             flag = bucketExists(bucketName);
  223.             if (!flag) {
  224.                 return true;
  225.             }
  226.         }
  227.         return false;
  228.     }
  229.     @Override
  230.     public List<String> listObjectNames(String bucketName) throws Exception{
  231.         List<String> listObjectNames = new ArrayList<>();
  232.         boolean flag = bucketExists(bucketName);
  233.         if (flag) {
  234.             Iterable<Result<Item>> myObjects = listObjects(bucketName);
  235.             for (Result<Item> result : myObjects) {
  236.                 Item item = result.get();
  237.                 listObjectNames.add(item.objectName());
  238.             }
  239.         }
  240.         return listObjectNames;
  241.     }
  242.  
  243.     public Iterable<Result<Item>> listObjects(String bucketName) throws Exception {
  244.         boolean flag = bucketExists(bucketName);
  245.         if (flag) {
  246.             return minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).build());
  247.         }
  248.         return null;
  249.     }
  250.  
  251. }
  1. public class MultipartConfigElement {
  2.     @Bean
  3.     public javax.servlet.MultipartConfigElement multipartConfigElement() {
  4.         MultipartConfigFactory factory = new MultipartConfigFactory();
  5.         factory.setLocation("/home/temp");
  6.         return factory.createMultipartConfig();
  7.     }
  8.  
  9.  
  10. }

添加依赖：

  1.  <dependency>
  2.             <groupId>io.minio</groupId>
  3.             <artifactId>minio</artifactId>
  4.             <version>7.1.0</version>
  5.  </dependency>

配置application.yam文件：

  1. //application.yam文件
  2. minio:
  3.   accesskey: xxxxxxxxxxxxxxxxxxxxxxx
  4.   secretKey: xxxxxxxxxxxxxxxxxxxxx
  5.   endpoint: http://xxxxxxxx:端口号
  6.   readPath: http://xxxxxxxx:端口号
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/神奇cpp/article/detail/932045
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号