使用SpringBoot集成Minio实现文件上传、下载、删除功能
创始人
2024-12-27 09:38:14
0

1. 添加依赖

首先,在你的Spring Boot项目中添加Minio的依赖。在 pom.xml 文件中添加以下依赖:

     io.minio     minio     你的版本  

2. 配置application.properties

application.properties 中配置Minio连接信息:

# Minio文件服务配置 minio:   # 访问服务地址   url: "http://127.0.0.1:5000"   # 用户名   user-name: "madmin"   # mi码   password: "madmin"   # 桶的名称   bucket-name: "test" 

3. 创建Minio配置类

创建一个配置类 MinioConfig.java,用于初始化Minio客户端:

import io.minio.MinioClient; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;  @Configuration public class MinioConfig {      @Value("${minio.endpoint}")     private String endpoint;      @Value("${minio.accessKey}")     private String accessKey;      @Value("${minio.secretKey}")     private String secretKey;      @Bean     public MinioClient minioClient() {         return MinioClient.builder()                 .endpoint(endpoint)                 .credentials(accessKey, secretKey)                 .build();     } } 

4. 实现文件上传、下载、删除操作

创建一个服务类 MinioFileService.java,实现文件上传、下载、删除等操作:

import io.minio.*; import io.minio.errors.MinioException; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.util.StringUtils; import org.springframework.web.multipart.MultipartFile;  import java.io.IOException; import java.io.InputStream; import java.util.List; import java.util.stream.Collectors;  @Service public class MinioFileService {      @Autowired     private MinioClient minioClient;      @Value("${minio.bucketName}")     private String bucketName;      // 上传文件     public String uploadFile(MultipartFile file) throws IOException {         String fileName = StringUtils.cleanPath(file.getOriginalFilename());         try (InputStream inputStream = file.getInputStream()) {             minioClient.putObject(                     PutObjectArgs.builder()                             .bucket(bucketName)                             .object(fileName)                             .stream(inputStream, inputStream.available(), -1)                             .contentType(file.getContentType())                             .build());         } catch (MinioException | IOException e) {             throw new IOException("File upload failed: " + e.getMessage());         }         return fileName;     }      // 下载文件     public InputStream downloadFile(String fileName) throws IOException {         try {             return minioClient.getObject(                     GetObjectArgs.builder()                             .bucket(bucketName)                             .object(fileName)                             .build());         } catch (MinioException e) {             throw new IOException("File download failed: " + e.getMessage());         }     }      // 删除文件     public void deleteFile(String fileName) throws IOException {         try {             minioClient.removeObject(                     RemoveObjectArgs.builder()                             .bucket(bucketName)                             .object(fileName)                             .build());         } catch (MinioException e) {             throw new IOException("File deletion failed: " + e.getMessage());         }     }      // 获取所有文件列表     public List getAllFiles() throws IOException {         try {             return minioClient.listObjects(                     ListObjectsArgs.builder()                             .bucket(bucketName)                             .build())                     .stream()                     .map(Result::get)                     .map(Item::objectName)                     .collect(Collectors.toList());         } catch (MinioException e) {             throw new IOException("Failed to retrieve file list: " + e.getMessage());         }     } } 

5. 创建Controller层接口

创建一个Controller类 FileController.java,定义REST接口,实现文件上传、下载、删除的调用:

import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.io.InputStream; import java.util.List;  @RestController @RequestMapping("/files") public class FileController {      @Autowired     private MinioFileService minioFileService;      // 文件上传     @PostMapping("/upload")     public String uploadFile(@RequestParam("file") MultipartFile file) throws IOException {         return minioFileService.uploadFile(file);     }      // 文件下载     @GetMapping("/download/{fileName:.+}")     public void downloadFile(@PathVariable String fileName, HttpServletResponse response) throws IOException {         InputStream is = minioFileService.downloadFile(fileName);         response.setContentType("application/octet-stream");         response.setHeader("Content-Disposition", "attachment; filename=\"" + fileName + "\"");         org.apache.commons.io.IOUtils.copy(is, response.getOutputStream());         response.flushBuffer();     }      // 文件删除     @DeleteMapping("/delete/{fileName:.+}")     public void deleteFile(@PathVariable String fileName) throws IOException {         minioFileService.deleteFile(fileName);     }      // 获取所有文件列表     @GetMapping("/list")     public List getAllFiles() throws IOException {         return minioFileService.getAllFiles();     } } 

6. 测试接口

启动Spring Boot应用程序,使用Postman或浏览器访问接口测试文件上传、下载、删除功能。

这样,你就完成了Spring Boot与Minio的集成,实现了基本的文件上传、下载、删除操作。

相关内容

热门资讯

7分钟窍要!福建天天开心辅助,... 7分钟窍要!福建天天开心辅助,九哥玩辅助(辅助)切实真的是有下载(哔哩哔哩)1、实时福建天天开心辅助...
第四分钟攻略!熟客温州游戏辅助... 第四分钟攻略!熟客温州游戏辅助器,新九哥脚本(辅助)其实是真的辅助器(哔哩哔哩)运熟客温州游戏辅助器...
第七分钟机巧!雀友会潮汕麻雀总... 第七分钟机巧!雀友会潮汕麻雀总部辅助,新鸿狐挂机(辅助)都是存在有软件(哔哩哔哩)1、雀友会潮汕麻雀...
第7分钟项目!中至江西插件,新... 第7分钟项目!中至江西插件,新道游拼十辅助器(辅助)一直真的有app(哔哩哔哩)1、新道游拼十辅助器...
第一分钟大纲!家家盘锦开挂,反... 第一分钟大纲!家家盘锦开挂,反杀新大厅辅助(辅助)真是存在有app(哔哩哔哩)1、操作简单,无需反杀...
第5分钟绝活儿!白银胡乐辅助脚... 第5分钟绝活儿!白银胡乐辅助脚本下载,新超圣辅助器(辅助)本来真的有工具(哔哩哔哩)1、白银胡乐辅助...
第六分钟指南书!皇豪互娱控制系... 第六分钟指南书!皇豪互娱控制系统app,新超圣正版辅助(辅助)切实是有插件(哔哩哔哩)所有人都在同一...
五分钟教程书!闲逸辅助器辅助下... 五分钟教程书!闲逸辅助器辅助下载,随意玩app下载开挂辅助(辅助)好像是真的工具(哔哩哔哩)1、这是...
第一分钟大纲!家家盘锦开挂,反... 第一分钟大纲!家家盘锦开挂,反杀新大厅辅助(辅助)真是有挂工具(哔哩哔哩)1.反杀新大厅辅助 选牌创...
第5分钟窍门!四川麻将血战到底... 第5分钟窍门!四川麻将血战到底定制插件辅助,新祥心挂机(辅助)原来真的有工具(哔哩哔哩)1、四川麻将...