springboot配置minio上传下载删除

爱被打了一巴掌 2022-09-13 04:09 223阅读 0赞

> 记录一下

[转载原文][Link 1]

**application.xml**

minio:
      endpoint: http://xxx:9003 #Minio服务所在地址 端口号要改成api端口号
      bucketName:  #存储桶名称
      accessKey:  #访问的key
      secretKey:  #访问的秘钥

**Controller**

import io.minio.MinioClient;
    import io.minio.policy.PolicyType;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.web.bind.annotation.*;
    import org.springframework.web.multipart.MultipartFile;
    
    import javax.servlet.http.HttpServletResponse;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.URLEncoder;
    import java.text.SimpleDateFormat;
    import java.util.Date;
    
    
    
    @RestController
    @RequestMapping("/minio")
    public class minioController { 
    
        private static final Logger LOGGER = LoggerFactory.getLogger(minioController.class);
    
        @Value("${minio.endpoint}")
        private  String ENDPOINT;
        @Value("${minio.bucketName}")
        private  String BUCKETNAME;
        @Value("${minio.accessKey}")
        private  String ACCESSKEY;
        @Value("${minio.secretKey}")
        private  String SECRETKEY;
    
        //文件创建
        @RequestMapping("/put")
        public String upload(MultipartFile file) { 
            String s=null;
            try { 
                MinioClient minioClient = new MinioClient(ENDPOINT, ACCESSKEY, SECRETKEY);
                //存入bucket不存在则创建，并设置为只读
                if (!minioClient.bucketExists(BUCKETNAME)) { 
                    minioClient.makeBucket(BUCKETNAME);
                    minioClient.setBucketPolicy(BUCKETNAME, "*.*", PolicyType.READ_ONLY);
                }
                String filename = file.getOriginalFilename();
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
                // 文件存储的目录结构
                String objectName = sdf.format(new Date()) + "/" + filename;
                // 存储文件
                minioClient.putObject(BUCKETNAME, objectName, file.getInputStream(), file.getContentType());
                LOGGER.info("文件上传成功!");
                s=ENDPOINT + "/" + BUCKETNAME + "/" + objectName;
            } catch (Exception e) { 
                LOGGER.info("上传发生错误: {}！", e.getMessage());
            }
            return s;
        }
    
        //文件删除
        @RequestMapping("/delete")
        public String delete(String name) { 
            try { 
                MinioClient minioClient = new MinioClient(ENDPOINT, ACCESSKEY, SECRETKEY);
                minioClient.removeObject(BUCKETNAME, name);
            } catch (Exception e) { 
                return "删除失败"+e.getMessage();
            }
            return "删除成功";
        }
    
        @RequestMapping("/download")
        public void downloadFiles(@RequestParam("filename") String filename, HttpServletResponse httpResponse) { 
    
            try { 
    
                MinioClient minioClient = new MinioClient(ENDPOINT, ACCESSKEY, SECRETKEY);
                InputStream object = minioClient.getObject(BUCKETNAME, filename);
                byte buf[] = new byte[1024];
                int length = 0;
                httpResponse.reset();
    
                httpResponse.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(filename, "UTF-8"));
                httpResponse.setContentType("application/octet-stream");
                httpResponse.setCharacterEncoding("utf-8");
                OutputStream outputStream = httpResponse.getOutputStream();
                while ((length = object.read(buf)) > 0) { 
                    outputStream.write(buf, 0, length);
                }
                outputStream.close();
            } catch (Exception ex) { 
                LOGGER.info("导出失败：", ex.getMessage());
            }
        }
    }

[Link 1]: https://blog.csdn.net/tc979907461/article/details/106673570