SpringBoot集成Minio实现文件上传

目录

创建Springboot项目

配置上传信息

编写配置文件

编写JAVA测试类

1、文件上传

2、Minio工具类

总结

---

上一篇文章详细介绍了在Windows环境如何安装服务minio服务器，接下来就是最重要的一部分了，如何通过java代码实现文件相关的操作呢？今天通过SpringBoot来整合Minio示例，实现文件的上传、读取、下载、删除等操作。

windows安装教程：Windows安装Minio(超详细)-CSDN博客

创建Springboot项目

引入minio相关依赖

        io.minio      minio      8.5.6  

配置上传信息

在application.yml种添加minio配置

minio:  config:    url: http://127.0.0.1:9005 #ip地址    accessKey: admin #  账号    secretKey: admin962464 #  密码    secure: false #如果是true，则用的是https而不是http,默认值是true    bucketName: "test"  # 桶的名字 相当于文件夹

编写配置文件

@Data@Configuration@ConfigurationProperties(prefix = "minio.config")public class MinioConfig {    /**     * 服务地址     */    private String url;    /**     * 用户名     */    private String accessKey;    /**     * 密码     */    private String secretKey;    /**     * 存储桶名称     */    private String bucketName;    @Bean    public MinioClient getMinioClient() {        return MinioClient.builder().endpoint(url).credentials(accessKey, secretKey).build();    }}

编写JAVA测试类

1、文件上传

Controller

@RestController@RequestMapping("/file")@Tag(name = "文件管理")public class FileController {    @Autowired    private UploadService uploadService;    @PostMapping("upload")    @Operation(summary = "上传文件")    public Result upload(@RequestParam("file") MultipartFile file) throws IOException {        FileVO upload = uploadService.upload(file);        return new Result().ok(upload);    }}

Service

@Slf4j@Servicepublic class MinioSysFileServiceImpl implements UploadService {    // 注入minio配置文件    @Autowired    private MinioConfig minioConfig;    // 注入minio client    @Autowired    private MinioClient client;    @Override    public FileVO upload(MultipartFile file) {        FileVO fileVO = new FileVO();        try {            // 获取文件真实名称            String originalFilename = file.getOriginalFilename();            // 获取文件的扩展名 例如.jpg .doc            String extname = originalFilename.substring(originalFilename.lastIndexOf("."));            // 构建文件上传相关信息            PutObjectArgs args = PutObjectArgs.builder()                    .bucket(minioConfig.getBucketName())                    .object(originalFilename)                    .stream(file.getInputStream(), file.getSize(), -1)                    .contentType(file.getContentType())                    .build();            // 将文件上传到minio服务器            client.putObject(args);            log.info("文件上传成功");            // 组装文件信息，返回前端 或者存入数据路            String url = minioConfig.getUrl() + "/" + minioConfig.getBucketName() + "/" + originalFilename;            fileVO.setUrl(url);            fileVO.setSize(file.getSize());            fileVO.setFileName(originalFilename);            fileVO.setExtname(extname);        } catch (Exception e) {            throw new ServerException("文件上传异常" + e.getCause().toString());        }        return fileVO;    }}

文件返回VO

@Data@Schema(description = "文件信息")public class FileVO {    @Schema(description = "文件url")    private String url;    @Schema(description = "文件名称")    private String fileName;    @Schema(description = "文件大小")    private Long size;    @Schema(description = "文件扩展名")    private String extname;}

测试结果

ok ok ok

2、Minio工具类

@Configuration@Slf4jpublic class MinioFileUtil {    @Autowired    MinioConfig minioConfig;    @Autowired    MinioClient minioClient;    /**     * 创建桶     *     * @param bucketName 桶名称     */    public void createBucket(String bucketName) throws Exception {        if (!StringUtils.hasLength(bucketName)) {            throw new ServerException("桶名不能为");        }        minioClient.makeBucket(MakeBucketArgs.builder()                .bucket(bucketName)                .build());    }    /**     * 创建文件夹     *     * @param bucketName 桶名     * @param folderName 文件夹名称     * @return     * @throws Exception     */    public ObjectWriteResponse createBucketFolder(String bucketName, String folderName) throws Exception {        if (!checkBucketExist(bucketName)) {            throw new ServerException("桶不存在，无法创建文件夹");        }        if (!StringUtils.hasLength(folderName)) {            throw new RuntimeException("创建的文件夹名不能为空");        }        PutObjectArgs putObjectArgs = PutObjectArgs.builder()                .bucket(bucketName)                .object(folderName + "/")                .stream(new ByteArrayInputStream(new byte[0]), 0, 0)                .build();        ObjectWriteResponse objectWriteResponse = minioClient.putObject(putObjectArgs);        return objectWriteResponse;    }    /**     * 检查桶是否存在     *     * @param bucketName 桶名称     * @return boolean true-存在 false-不存在     */    public boolean checkBucketExist(String bucketName) throws Exception {        if (!StringUtils.hasLength(bucketName)) {            throw new ServerException("桶名不能为空");        }        return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());    }    /**     * 删除文件     *     * @param bucketName 桶名      * @param objectName 文件所在的路径 + 文件名称  例如100000/im/750510573649620992.xlsx     * @return     */    public Boolean deleteBucketFile(String bucketName, String objectName) {        if (!StringUtils.hasLength(bucketName) || !StringUtils.hasLength(objectName)) {            throw new ServerException("桶名或文件名不能为空");        }        try {            minioClient.removeObject(RemoveObjectArgs.builder().bucket(bucketName).object(objectName).build());            return true;        } catch (Exception e) {            log.info("删除文件失败");            return false;        }    }}

总结