springboot整合minio最新版

作者: Code人生 | 来源:发表于2020-12-31 11:07 被阅读0次

    不知不觉,2020马上就过去了,在这最后一天的时间里,还是得把留下的内容更新了。2021新的开始,树立新的目标,过去的就让它成为过去吧。元旦临近,在这里祝大家元旦快乐!今天我还是把上篇说的Springboot整合minio的内容更新一下,作为2020年最后一篇文章。废话不多说,直接进入主题。

    第一步:查找minio最新依赖,通过maven查询网站查询,这搜索框输入minio,如下:

    image.png
    点击minio进入查看maven依赖,可以看到最新版为8.0.3
    <dependency>
        <groupId>io.minio</groupId>
        <artifactId>minio</artifactId>
        <version>8.0.3</version>
    </dependency>
    

    gradle

    compile group: 'io.minio', name: 'minio', version: '8.0.3'
    

    第二步:(整合到项目中)
    1.将依赖添加到新建的springboot项目中,在pom.xml添加
    2.配置minio客户端,不会的话参考minio java sdk文档,但是这个文档给的是3.0.10版本的sdk,与新版的不兼容,最新版的还是看github地址

    参数 说明
    Endpoint 对象存储服务的URL
    Access Key Access key就像用户ID,可以唯一标识你的账户
    Secret Key Secret key是你账户的密码

    默认安装不指定Access key 和Secret key 的话都是minioadmin, Endpoint则为服务器地址:如我安装的的端口为1024,那Endpoint就是:http://localhost:1024
    为了方便我们通过bean的方式注入客户端如下:
    yml

    spring:
      # 配置文件上传大小限制
      servlet:
        multipart:
          max-file-size: 100MB
          max-request-size: 100MB
    
    # minio 参数配置
    minio:
      endpoint: http://localhost:1024
      accessKey: minioadmin
      secretKey: minioadmin
    
    
    @Configuration
    public class MinIoClientConfig {
    
        @Value("${minio.endpoint}")
        private String endpoint;
        @Value("${minio.accessKey}")
        private String accessKey;
        @Value("${minio.secretKey}")
        private String secretKey;
    
        /**
         * 注入minio 客户端
         * @return
         */
        @Bean
        public MinioClient minioClient(){
    
        return MinioClient.builder()
                            .endpoint(endpoint)
                            .credentials(accessKey, secretKey)
                            .build();
        }
    }
    

    ok,现在客户端已注入spring容器中,在使用的时候,只需要获取就可以了。

    第三步: 文件上传
    1.新增一个UploadController控制器用于处理文件上传,如下:

    @RestController
    public class UploadController {
    
        @Resource
        private MinioClient minioClient;
    
        /**
         * 文件上传
         * @param file
         * @return
         */
        @PostMapping("/upload")
        public String upload(MultipartFile file){
    
            try {
                PutObjectArgs objectArgs = PutObjectArgs.builder().object(file.getOriginalFilename())
                        .bucket("test")
                        .contentType(file.getContentType())
                        .stream(file.getInputStream(),file.getSize(),-1).build();
    
                minioClient.putObject(objectArgs);
                return "ok";
            } catch (Exception e) {
                e.printStackTrace();
                return e.getMessage();
            }
        }
    }
    

    注意这里的bucket是我提前在minio中新增好的,如果没有的话,可以自己手动添加,也可以通过代码添加,具体参考sdk的说明,这里就不多说了。
    2.通过postman测试文件上传


    image.png

    点击执行后返回ok,执成功,此时通过minio web端看看文件是否上传成功

    image.png
    看到刚上传的文件就说明成功了。
    3.其他说明,如何通过浏览器访问刚上传的图片呢,就是通过endpoint服务地址加bucket名称加图片的名称,在本例子访问路径则为:http://localhost:1024/test/5b01ca40273bcf53f4e6d84c0c595642.gif,可是为什么点击之后不能访问呢,原因是因为每个bucket都有权限控制,要能访问的话需要放开权限,用过阿里云的oss存储的都应该知道这个机制的。
    image.png
    设置好后,再访问:
    image.png
    ok,此时就可以正常访问我们刚上传的图片了。

    第四步:文件下载
    在UploadController控制其中新增download方法,如下:

      /**
         * 下载文件
         * @param filename
         */
        @GetMapping("/download/{filename}")
        public void download(@PathVariable String filename, HttpServletResponse res){
    
            GetObjectArgs objectArgs = GetObjectArgs.builder().bucket("test")
                    .object(filename).build();
    
            try (GetObjectResponse response = minioClient.getObject(objectArgs)){
                byte[] buf = new byte[1024];
    
                int len;
    
                try (FastByteArrayOutputStream os = new FastByteArrayOutputStream()){
    
                    while ((len=response.read(buf))!=-1){
    
                        os.write(buf,0,len);
    
                    }
                    os.flush();
    
                    byte[] bytes = os.toByteArray();
    
                    res.setCharacterEncoding("utf-8");
                    res.setContentType("application/force-download");// 设置强制下载不打开
                    res.addHeader("Content-Disposition", "attachment;fileName=" + filename);
                    try ( ServletOutputStream stream = res.getOutputStream()){
                        stream.write(bytes);
                        stream.flush();
                    }
                }
    
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    

    通过访问下载地址:http://localhost:8421/download/5b01ca40273bcf53f4e6d84c0c595642.gif,文件下载下来能够正常显示,则说明成功。

    总结:
    通过以上操作,我们已经完成springboot与minio的整合,可以通过minio sdk实现文件上传与下载功能。当然还有其他api操作,我就不多介绍了,都是一个思路,调用传值就可以了,自己尝试一下,就能get到了。今天就到这里,demo代码会放到码云上,需要的同学可以下载参考一下。最后,祝大家元旦快乐,喜欢我的文章记得关注我哦😊!

    demo代码地址:https://gitee.com/zzj1992/minio-demo.git

    相关文章

      网友评论

        本文标题:springboot整合minio最新版

        本文链接:https://www.haomeiwen.com/subject/qhlloktx.html