AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

minio项目实例

2022-09-22 370
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： minio项目实例

本文已参与「新人创作礼」活动,一起开启掘金创作之路。
接上篇文章写一下搭建完minio后怎么写一个java的测试工程，进行体验minio对象存储功能。

1.创建maven项目 导入pom依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.example</groupId>
    <artifactId>minio</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>2021.0.1.0</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>LATEST</version>
        </dependency>
    <!-- 引入thymeleaf 做简单网页测试-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-thymeleaf</artifactId>
            <version>2.6.3</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.6.3</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
            <version>1.18.22</version>
        </dependency>
    <!-- minio依赖-->
        <dependency>
            <groupId>io.minio</groupId>
            <artifactId>minio</artifactId>
            <version>7.0.1</version>
        </dependency>
        <dependency>
            <groupId>commons-io</groupId>
            <artifactId>commons-io</artifactId>
            <version>2.6</version>
        </dependency>
        <!-- 增加nacos配置 注册中心-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>

        <!-- 增加nacos配置 配置中心-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
    </dependencies>

    <build>
   na     <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal><!--可以把依赖的包都打包到生成的Jar包中 -->
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>

</project>

2.编写application.yml配置文件

server:
  port: 8085
spring:
  application:
    name: book-minio
  thymeleaf:
    cache: false
  servlet:
    multipart:
      max-file-size: 10MB
      max-request-size: 100MB
  cloud:
    nacos:
      discovery:
        server-addr: localhost:8848
        namespace: f5caca8a-aa97-4fed-a9b3-92691006dbff
      config:
        server-addr: localhost:8848
        namespace: f5caca8a-aa97-4fed-a9b3-92691006dbff
  config:
    import:
      - nacos:minio-config-client-dev.yaml

management:
  endpoints:
    web:
      exposure:
        include:'*'

这块用到nacos服务注册、配置中心,如果不想用可以直接将配置写在yml文件中。

nacos中minio-config-client-dev.yaml文件的详细配置

image.png
配置了搭建的minio的地址、ip、用户名、密码、文件大小限制信息

4.工程目录

image.png

MinioController

package com.ctsi.ssdx.controller;

import com.alibaba.fastjson.JSON;
import com.ctsi.ssdx.common.Res;
import com.ctsi.ssdx.config.MinioProp;
import io.minio.MinioClient;
import io.minio.ObjectStat;
import io.minio.PutObjectOptions;
import io.minio.Result;
import io.minio.messages.Item;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.IOUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.ui.ModelMap;
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.net.URLEncoder;
import java.text.DecimalFormat;
import java.util.*;

/**
 * @Author : lizzu
 * @create 2022/8/11 14:27
 */
@Slf4j
@RestController
public class MinioController {
    @Autowired
    private MinioClient minioClient;

    @Autowired
    private MinioProp minioProp;

    private static final String MINIO_BUCKET = "mybucket";

    @GetMapping("/list")
    public List<Object> list(ModelMap map) throws Exception {
        Iterable<Result<Item>> myObjects = minioClient.listObjects(MINIO_BUCKET);
        Iterator<Result<Item>> iterator = myObjects.iterator();
        List<Object> items = new ArrayList<>();
//        String format = "{'fileName':'%s','filePath':'%s','fileSize':'%s'}";
        String format = "{'fileName':'%s','fileSize':'%s'}";
        while (iterator.hasNext()) {
            Item item = iterator.next().get();
            items.add(JSON.parse(String.format(format,
//                    minioProp.getEndpoint()+"/"+MINIO_BUCKET+"/"+item.objectName(),
                    item.objectName(), formatFileSize(item.size()))));
        }
        return items;
    }

    @PostMapping("/upload")
    public Res upload(@RequestParam(name = "file", required = false) MultipartFile[] file) {
        Res res = new Res();
        res.setCode(500);

        if (file == null || file.length == 0) {
            res.setMessage("上传文件不能为空");
            return res;
        }

        List<String> orgfileNameList = new ArrayList<>(file.length);

        for (MultipartFile multipartFile : file) {
            String orgfileName = multipartFile.getOriginalFilename();
            orgfileNameList.add(orgfileName);

            try {
                InputStream in = multipartFile.getInputStream();
                minioClient.putObject(MINIO_BUCKET, orgfileName, in, new PutObjectOptions(in.available(), -1));
                in.close();
            } catch (Exception e) {
                log.error(e.getMessage());
                res.setMessage("上传失败");
                return res;
            }
        }

        Map<String, Object> data = new HashMap<String, Object>();
        data.put("bucketName", MINIO_BUCKET);
        data.put("fileName", orgfileNameList);
        res.setCode(200);
        res.setMessage("上传成功");
        res.setData(data);
        return res;
    }

    @RequestMapping("/download/{fileName}")
    public void download(HttpServletResponse response, @PathVariable("fileName") String fileName) {
        InputStream in = null;
        try {
            ObjectStat stat = minioClient.statObject(MINIO_BUCKET, fileName);
            response.setContentType(stat.contentType());
            response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"));

            in = minioClient.getObject(MINIO_BUCKET, fileName);
            IOUtils.copy(in, response.getOutputStream());
        } catch (Exception e) {
            log.error(e.getMessage());
        } finally {
            if (in != null) {
                try {
                    in.close();
                } catch (IOException e) {
                    log.error(e.getMessage());
                }
            }
        }
    }

    @DeleteMapping("/delete/{fileName}")
    public Res delete(@PathVariable("fileName") String fileName) {
        Res res = new Res();
        res.setCode(200);
        try {
            minioClient.removeObject(MINIO_BUCKET, fileName);
        } catch (Exception e) {
            res.setCode(500);
            log.error(e.getMessage());
        }
        return res;
    }

    private static String formatFileSize(long fileS) {
        DecimalFormat df = new DecimalFormat("#.00");
        String fileSizeString = "";
        String wrongSize = "0B";
        if (fileS == 0) {
            return wrongSize;
        }
        if (fileS < 1024) {
            fileSizeString = df.format((double) fileS) + " B";
        } else if (fileS < 1048576) {
            fileSizeString = df.format((double) fileS / 1024) + " KB";
        } else if (fileS < 1073741824) {
            fileSizeString = df.format((double) fileS / 1048576) + " MB";
        } else {
            fileSizeString = df.format((double) fileS / 1073741824) + " GB";
        }
        return fileSizeString;
    }
}

配置信息MinioProp


import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

/**
 * @Author : lizzu
 * @create 2022/8/11 14:24
 */
@Data
//@ConfigurationProperties(prefix = "minio")
@Component
public class MinioProp {

    @Value("${minio.endpoint}")
    private String endpoint;

    @Value("${minio.accesskey}")

    private String accesskey;

    @Value("${minio.secretKey}")
    private String secretKey;

}

MinioConfiguration


import io.minio.MinioClient;
import io.minio.errors.InvalidEndpointException;
import io.minio.errors.InvalidPortException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Author : lizzu
 * @create 2022/8/11 14:25
 */
@Configuration
public class MinioConfiguration {
    @Autowired
    private MinioProp minioProp;

    @Bean
    public MinioClient minioClient() throws InvalidPortException, InvalidEndpointException {
        MinioClient client = new MinioClient(minioProp.getEndpoint(), minioProp.getAccesskey(), minioProp.getSecretKey());
        return client;
    }
}

简单前端测试：
image.png

image.png
附gitee源码地址 https://gitee.com/qlglg123/minio

文章标签：
Java
前端开发
数据安全/隐私保护
对象存储
Nacos
Maven
奇了怪了怪
目录
相关文章
阿甘兄
|
11月前
|
Linux 对象存储 Windows
MinIO 客户端安装与使用教程
MinIO 客户端安装与使用教程
阿甘兄
386 0
dc73hre37f4my
|
Java 项目管理 开发工具
springboot集成minio SDK实现文件上传下载（上）
springboot集成minio SDK实现文件上传下载
dc73hre37f4my
657 0
springboot集成minio SDK实现文件上传下载（上）
运营研究坊
|
26天前
|
XML Java Kotlin
springboot + minio + kkfile实现文件预览
本文介绍了如何在容器中安装和启动kkfileviewer，并通过Spring Boot集成MinIO实现文件上传与预览功能。首先，通过下载kkfileviewer源码并构建Docker镜像来部署文件预览服务。接着，在Spring Boot项目中添加MinIO依赖，配置MinIO客户端，并实现文件上传与获取预览链接的接口。最后，通过测试验证文件上传和预览功能的正确性。
运营研究坊
54 4
springboot + minio + kkfile实现文件预览
nanshaws
|
1月前
|
存储 前端开发 Java
springboot整合最新版minio和minio的安装（完整教程，新人必看）
本文详细介绍了如何使用Docker安装配置最新版的MinIO，并展示了如何在Spring Boot应用中整合MinIO以及如何通过前端进行文件上传测试。
nanshaws
177 3
springboot整合最新版minio和minio的安装（完整教程，新人必看）
最好zzz
|
15天前
|
存储 Java API
SpringBoot结合Minio实现文件切片上传：提升上传效率的秘诀
【10月更文挑战第29天】
最好zzz
62 3
杀死一只知更鸟debug
|
2月前
|
存储 对象存储 数据安全/隐私保护
Minio图床介绍和使用
本文介绍了MinIO这一开源对象存储服务器的特点和优势，并提供了基于Docker的快速部署方法，以及如何使用MinIO进行文件上传和通过Web界面管理存储桶的详细步骤。
杀死一只知更鸟debug
72 3
Minio图床介绍和使用
花酒锄作田
|
3月前
|
存储 算法 Cloud Native
[minio]简介与安装
[minio]简介与安装
花酒锄作田
59 2
最好zzz
|
3月前
|
存储 Java API
SpringBoot + MinIO 实现文件切片极速上传技术
【8月更文挑战第19天】在现代互联网应用中，文件上传是一个常见且重要的功能。然而，随着文件体积的增大，传统的文件上传方式往往面临效率低下、耗时过长等问题。为了提升大文件上传的速度和效率，我们可以采用文件切片上传技术，并结合SpringBoot和MinIO来实现这一功能。
最好zzz
221 0
hhzz
|
6月前
|
JavaScript Java jenkins
如何利用CentOS7+docker+jenkins+gitee部署springboot+vue前后端项目（保姆教程）
如何利用CentOS7+docker+jenkins+gitee部署springboot+vue前后端项目（保姆教程）
hhzz
315 0
yuanzhengme
|
6月前
|
Java Linux 开发工具
MinIO【部署 01】MinIO安装及SpringBoot集成简单测试
MinIO【部署 01】MinIO安装及SpringBoot集成简单测试
yuanzhengme
313 0