https://blog.csdn.net/tc979907461/article/details/106673570?utm_medium=distribute.pc_relevant_t0.none-task-blog-BlogCommendFromMachineLearnPai2-1.compare&depth_1-utm_source=distribute.pc_relevant_t0.none-task-blog-BlogCommendFromMachineLearnPai2-1.compare

minio的中文文档:https://docs.min.io/cn/

minio安装

  1. 首先查询docker镜像:
    docker search minio
    minio实现文件上传下载和删除功能

  2. 选着stars最高的那个拉取:
    docker pull minio/minio
    minio实现文件上传下载和删除功能

  3. 启动minio服务器,并设置端口号,容器名,账号和密码:
    docker run -p 9000:9000 --name minio -e MINIO_ACCESS_KEY=tanchuntcc -e MINIO_SECRET_KEY=tanchuntcc -v /data:/data minio/minio server /data
    minio实现文件上传下载和删除功能

minio操作

  1. 启动成功后,访问你minio的ip地址,这里我docker安装在本机,所以是http://localhost:9000,输入刚刚设置的账号密码。
    minio实现文件上传下载和删除功能

  2. 登陆后右下角可以创建bucket.
    minio实现文件上传下载和删除功能minio实现文件上传下载和删除功能

  3. 创建多个bucket后
    minio实现文件上传下载和删除功能

  4. 可以选择编辑和删除
    minio实现文件上传下载和删除功能

  5. 可以点击右下角上传文件
    minio实现文件上传下载和删除功能

  6. 支持各种类型的文件:
    minio实现文件上传下载和删除功能

首先创建一个Springboot项目,在resources中的application.yml文件添加如下配置:

server:
  port: 8080
  
spring:
  servlet:
    multipart:
      enabled: true #开启文件上传
      max-file-size: 500MB
      max-request-size: 500MB

minio:
  endpoint: http://localhost:9000 #Minio服务所在地址
  bucketName: tcc #存储桶名称
  accessKey: tanchuntcc #访问的key
  secretKey: tanchuntcc #访问的秘钥

 

添加minio的maven依赖:

   <dependency>
      <groupId>io.minio</groupId>
      <artifactId>minio</artifactId>
      <version>3.0.10</version>
    </dependency>

 

controller的代码如下:

@RestController("/minioDemo")
public class MinioDemoController {

    private static final Logger LOGGER = LoggerFactory.getLogger(MinioDemoController.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;

    //文件创建
    @PostMapping
    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;
    }

    //文件删除
    @DeleteMapping
    public String delete(String name) {
        try {
            MinioClient minioClient = new MinioClient(ENDPOINT, ACCESSKEY, SECRETKEY);
            minioClient.removeObject(BUCKETNAME, name);
        } catch (Exception e) {
            return "删除失败"+e.getMessage();
        }
        return "删除成功";
    }
}

    @GetMapping
    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

相关文章: