所有文章 > 学习各类API > Minio搭建与整合SpringBoot的完整指南
Minio搭建与整合SpringBoot的完整指南

Minio搭建与整合SpringBoot的完整指南

本文详细介绍了如何使用Docker部署Minio,并在SpringBoot中整合Minio进行对象存储管理。通过阅读本文,您将了解如何拉取Minio镜像、创建必要的目录、配置和启动Minio容器,以及如何在SpringBoot项目中集成Minio进行文件上传、下载及存储管理。此外,还会介绍如何通过Vue和Element-UI实现前端交互,帮助开发者在项目中应用Minio进行高效的对象存储管理。

一、使用Docker部署Minio

1、拉取Minio镜像

要在Docker中部署Minio,首先需要拉取官方的Minio镜像。执行以下命令:

    docker pull minio/minio

这将从Docker Hub中获取最新的Minio镜像,确保您拥有最新的功能和安全更新。

2、创建目录

为了持久化Minio的数据和配置文件,您需要在主机上创建相应的目录:

    mkdir -p /home/minio/config
mkdir -p /home/minio/data

这些目录将被挂载到容器中,以便数据能够在容器重启或更新后保持不变。

3、创建Minio容器并运行

使用以下命令创建并运行Minio容器:

    docker run -p 9000:9000 -p 9090:9090 
--net=host
--name minio
-d --restart=always
-e "MINIO_ACCESS_KEY=minioadmin"
-e "MINIO_SECRET_KEY=minioadmin"
-v /home/minio/data:/data
-v /home/minio/config:/root/.minio
minio/minio server
/data --console-address ":9090" -address ":9000"

这将启动Minio服务,使其可以通过主机的9000端口和9090端口进行访问。请确保您的防火墙允许这些端口的流量。

Minio安装成功

4、登录Minio控制台

安装完成后,您可以通过浏览器访问Minio控制台,默认地址为http://localhost:9000。使用您设置的访问密钥和秘密密钥进行登录。

Minio登录界面

5、创建Buckets存储桶测试

登录成功后,您可以创建一个或多个存储桶来管理您的数据。以下截图展示了创建一个名为public的存储桶,该名字可以根据需要自定义。

创建存储桶

上传文件后,可以通过http://ip:9000/存储桶名/文件名的方式访问这些文件。如果您需要将存储桶的访问权限设置为公共,请调整存储桶的权限设置。

存储桶权限设置

二、SpringBoot整合Minio

1、创建minio-demo项目

在SpringBoot中整合Minio可以让您更高效地管理对象存储和文件上传。首先,创建一个新的SpringBoot项目,并命名为minio-demo

SpringBoot项目创建

2、引入pom依赖

在项目的pom.xml文件中添加Minio的依赖:

    
io.minio
minio
7.0.2

这将引入必要的库以便在您的SpringBoot应用中调用Minio的API。

3、编写配置文件

application.yml文件中编写Minio相关的配置,这些配置将帮助SpringBoot应用连接到Minio服务:

    server:
port: 8081
spring:
servlet:
multipart:
max-file-size: 200MB
max-request-size: 200MB
minio:
host: http://127.0.0.1:9000
url: ${minio.host}/${minio.bucket}/
access-key: minioadmin
secret-key: minioadmin
bucket: public

4、编写MinioConfig配置类

MinioConfig类负责初始化Minio客户端并提供各种文件操作的功能,如上传、下载和管理存储桶。

import io.minio.MinioClient;
import io.minio.ObjectStat;
import io.minio.PutObjectOptions;
import io.minio.Result;
import io.minio.messages.Bucket;
import io.minio.messages.Item;
import org.apache.tomcat.util.http.fileupload.IOUtils;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.util.Assert;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.util.UriUtils;

import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.InputStream;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.List;

@Component
public class MinioConfig implements InitializingBean {

    @Value(value = "${minio.bucket}")
    private String bucket;

    @Value(value = "${minio.host}")
    private String host;

    @Value(value = "${minio.url}")
    private String url;

    @Value(value = "${minio.access-key}")
    private String accessKey;

    @Value(value = "${minio.secret-key}")
    private String secretKey;

    private MinioClient minioClient;

    @Override
    public void afterPropertiesSet() throws Exception {
        Assert.hasText(url, "Minio url 为空");
        Assert.hasText(accessKey, "Minio accessKey为空");
        Assert.hasText(secretKey, "Minio secretKey为空");
        this.minioClient = new MinioClient(this.host, this.accessKey, this.secretKey);
    }

    // 上传
    public String putObject(MultipartFile multipartFile) throws Exception {
        if (!minioClient.bucketExists(this.bucket)) {
            minioClient.makeBucket(this.bucket);
        }
        try (InputStream inputStream = multipartFile.getInputStream()) {
            String fileName = multipartFile.getOriginalFilename();
            PutObjectOptions putObjectOptions = new PutObjectOptions(multipartFile.getSize(), PutObjectOptions.MIN_MULTIPART_SIZE);
            putObjectOptions.setContentType(multipartFile.getContentType());
            minioClient.putObject(this.bucket, fileName, inputStream, putObjectOptions);
            return this.url + UriUtils.encode(fileName, StandardCharsets.UTF_8);
        }
    }

    // 文件下载
    public void download(String fileName, HttpServletResponse response){
        InputStream inputStream;
        try {
            MinioClient minioClient = new MinioClient(host, accessKey, secretKey);
            ObjectStat stat = minioClient.statObject(bucket, fileName);
            inputStream = minioClient.getObject(bucket, fileName);
            response.setContentType(stat.contentType());
            response.setCharacterEncoding("UTF-8");
            response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8"));
            IOUtils.copy(inputStream, response.getOutputStream());
            inputStream.close();
        } catch (Exception e){
            e.printStackTrace();
            System.out.println("有异常:" + e);
        }
    }

    // 列出所有存储桶名称
    public List listBucketNames() throws Exception {
        List bucketList = listBuckets();
        List bucketListName = new ArrayList();
        for (Bucket bucket : bucketList) {
            bucketListName.add(bucket.name());
        }
        return bucketListName;
    }

    // 查看所有桶
    public List listBuckets() throws Exception {
        return minioClient.listBuckets();
    }

    // 检查存储桶是否存在
    public boolean bucketExists(String bucketName) throws Exception {
        return minioClient.bucketExists(bucketName);
    }

    // 创建存储桶
    public boolean makeBucket(String bucketName) throws Exception {
        if (!bucketExists(bucketName)) {
            minioClient.makeBucket(bucketName);
            return true;
        }
        return false;
    }

    // 删除桶
    public boolean removeBucket(String bucketName) throws Exception {
        if (bucketExists(bucketName)) {
            Iterable<Result> myObjects = listObjects(bucketName);
            for (Result result : myObjects) {
                Item item = result.get();
                if (item.size() > 0) {
                    return false;
                }
            }
            minioClient.removeBucket(bucketName);
            return !bucketExists(bucketName);
        }
        return false;
    }

    // 列出存储桶中的所有对象
    public Iterable<Result> listObjects(String bucketName) throws Exception {
        if (bucketExists(bucketName)) {
            return minioClient.listObjects(bucketName);
        }
        return null;
    }

    // 列出存储桶中的所有对象名称
    public List listObjectNames(String bucketName) throws Exception {
        List listObjectNames = new ArrayList();
        if (bucketExists(bucketName)) {
            Iterable<Result> myObjects = listObjects(bucketName);
            for (Result result : myObjects) {
                Item item = result.get();
                listObjectNames.add(item.objectName());
            }
        }
        return listObjectNames;
    }

    // 删除一个对象
    public boolean removeObject(String bucketName, String objectName) throws Exception {
        if (bucketExists(bucketName)) {
            List objectList = listObjectNames(bucketName);
            for (String s : objectList) {
                if(s.equals(objectName)){
                    minioClient.removeObject(bucketName, objectName);
                    return true;
                }
            }
        }
        return false;
    }

    // 文件访问路径
    public String getObjectUrl(String bucketName, String objectName) throws Exception {
        if (bucketExists(bucketName)) {
            return minioClient.getObjectUrl(bucketName, objectName);
        }
        return "";
    }
}

5、编写MinioController类

MinioController类负责处理HTTP请求,并调用MinioConfig类中的方法以执行上传、下载等操作。

import com.minio.demo.config.MinioConfig;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import javax.servlet.http.HttpServletResponse;
import java.util.List;

@RestController
@CrossOrigin
@RequestMapping("/test")
public class MinioController {

    @Autowired
    MinioConfig minioConfig;

    // 上传
    @PostMapping("/upload")
    public Object upload(@RequestParam("file") MultipartFile multipartFile) throws Exception {
        return this.minioConfig.putObject(multipartFile);
    }

    // 下载文件
    @GetMapping("/download")
    public void download(@RequestParam("fileName")String fileName, HttpServletResponse response) {
        this.minioConfig.download(fileName,response);
    }

    // 列出所有存储桶名称
    @PostMapping("/list")
    public List list() throws Exception {
        return this.minioConfig.listBucketNames();
    }

    // 创建存储桶
    @PostMapping("/createBucket")
    public boolean createBucket(String bucketName) throws Exception {
        return this.minioConfig.makeBucket(bucketName);
    }

    // 删除存储桶
    @PostMapping("/deleteBucket")
    public boolean deleteBucket(String bucketName) throws Exception {
        return this.minioConfig.removeBucket(bucketName);
    }

    // 列出存储桶中的所有对象名称
    @PostMapping("/listObjectNames")
    public List listObjectNames(String bucketName) throws Exception {
        return this.minioConfig.listObjectNames(bucketName);
    }

    // 删除一个对象
    @PostMapping("/removeObject")
    public boolean removeObject(String bucketName, String objectName) throws Exception {
        return this.minioConfig.removeObject(bucketName, objectName);
    }

    // 文件访问路径
    @PostMapping("/getObjectUrl")
    public String getObjectUrl(String bucketName, String objectName) throws Exception {
        return this.minioConfig.getObjectUrl(bucketName, objectName);
    }
}

6、测试(上传)

要测试上传功能,可以使用Postman或类似工具发送请求到http://127.0.0.1:8081/test/upload,并上传一个文件。成功后,您将获得文件的访问URL。

文件上传测试

三、Vue+Element-ui前端交互

在前端,我们可以使用Vue和Element-UI来创建一个简单的文件上传界面。

1、安装Element-UI

在Vue项目中安装Element-UI:

    npm install element-ui -S

并在项目中引入:

    import ElementUI from 'element-ui'
    import 'element-ui/lib/theme-chalk/index.css'
    Vue.use(ElementUI)

2、创建上传组件

以下是一个使用Element-UI的上传组件示例:


  
export default { data() { return { imageUrl: '' }; }, methods: { handleAvatarSuccess(res, file) { this.imageUrl = URL.createObjectURL(file.raw); }, beforeAvatarUpload(file) { const isJPG = file.type === 'image/jpeg' || file.type === 'image/png'; const isLt2M = file.size / 1024 / 1024 < 2; if (!isJPG) { this.$message.error('上传头像图片只能是 jpg或png 格式!'); } if (!isLt2M) { this.$message.error('上传头像图片大小不能超过 2MB!'); } return isJPG && isLt2M; } } } .avatar-uploader .el-upload { border: 1px dashed #d9d9d9; border-radius: 6px; cursor: pointer; position: relative; left: 200px; top: 120px; overflow: hidden; } .avatar-uploader .el-upload:hover { border-color: #409EFF; } .avatar-uploader-icon { position: relative; top: 80px; font-size: 28px; color: #8c939d; width: 389px; height: 204px; line-height: 178px; text-align: center; } .avatar { width: 389px; height: 204px; display: block; }

此组件允许用户上传头像,并在上传成功后显示上传的图像。

Vue应用交互

FAQ

问:如何使用Docker部署Minio?

  • 答:要在Docker中部署Minio,首先需要拉取官方的Minio镜像,执行命令docker pull minio/minio。接着,创建用于持久化数据和配置的目录,然后使用docker run命令创建并运行Minio容器。

问:如何在SpringBoot项目中整合Minio?

  • 答:在SpringBoot项目中整合Minio可以通过以下步骤实现:首先创建一个新的SpringBoot项目,并在pom.xml文件中添加Minio依赖。然后,编写application.yml配置文件以连接Minio服务,创建MinioConfig类以初始化Minio客户端,并编写MinioController类以处理HTTP请求。

问:如何测试SpringBoot项目中的文件上传功能?

  • 答:可以使用Postman或类似工具发送请求到http://127.0.0.1:8081/test/upload进行测试。在请求中上传一个文件,成功后将返回文件的访问URL。

问:如何设置Minio的存储桶权限为公共?

  • 答:在Minio控制台中登录后,选择要修改权限的存储桶,进入权限设置页面,调整权限设置为公共即可。

问:如何在Vue项目中使用Element-UI创建文件上传界面?

  • 答:首先在Vue项目中安装Element-UI,然后在项目中引入Element-UI。接着,创建一个上传组件,使用<el-upload>标签配置上传路径及上传限制。在上传成功后,可以通过显示上传的图像来确认上传结果。
#你可能也喜欢这些API文章!