SpringBoot整合Minio

文章目录

1 Minio

1.1 概述

Minio

官网地址：https://min.io/
文档地址：https://docs.min.io/

Minio

是一款开源的对象存储服务器，它可以运行在多种操作系统上，包括

Linux、Windows和MacOS

等。它提供了一种简单、可扩展、高可用的对象存储解决方案，支持多种数据格式，包括对象、块和文件等。

Minio

的主要特点：

简单易用： Minio的安装和配置非常简单，只需要下载并运行相应的二进制文件即可。它提供了一个Web UI,可以通过界面管理存储桶和对象。
可扩展性： Minio可以轻松地扩展到多个节点，以提供高可用性和容错能力。它支持多种部署模式，包括单节点、主从复制和集群等。
高可用性： Minio提供了多种机制来保证数据的可靠性和可用性，包括冗余备份、数据复制和故障转移等。
安全性： Minio提供了多种安全机制来保护数据的机密性和完整性，包括SSL/TLS加密、访问控制和数据加密等。
多语言支持： Minio支持多种编程语言，包括Java、Python、Ruby和Go等。
社区支持： Minio是一个开源项目，拥有庞大的社区支持和贡献者。它的源代码可以在GitHub上获得，并且有一个活跃的邮件列表和论坛。
对象存储： Minio的核心功能是对象存储。它允许用户上传和下载任意数量和大小的对象，并提供了多种API和SDK来访问这些对象。
块存储： Minio还支持块存储，允许用户上传和下载大型文件(例如图像或视频)。块存储是一种快速、高效的方式来处理大型文件。
文件存储： Minio还支持文件存储，允许用户上传和下载单个文件。文件存储是一种简单、快速的方式来处理小型文件。

总之，Minio是一款强大、灵活、可扩展的对象存储服务器，适用于各种应用场景，包括云存储、大数据存储和物联网等。

1.2 应用场景

MinIO是一种高性能、扩展性好的对象存储系统，它可以适用于许多应用场景，其中包括但不限于以下几种：

大规模数据存储：由于MinIO使用分布式环境来存储数据，因此可以轻松扩展以满足需要管理大量数据的组织和企业的需求。
图像和媒体存储：由于MinIO对原始二进制数据进行了优化，因此非常适合存储图像、音频和视频等媒体文件。它还支持WebP、JPEG和PNG等格式，可在多种设备和浏览器上工作。
云原生应用程序： MinIO是一个云原生的对象存储系统，可以与Kubernetes、Docker Swarm和Mesosphere等容器编排工具无缝集成，可以很好地满足基于云的应用程序的需求。
数据保护和灾难恢复： MinIO的多副本写入功能和内置的纠删码支持，使得数据备份和恢复变得简单而强大。
分布式计算和机器学习： MinIO提供STS（S3 Select）和HDFS接口，支持在数据仓库中直接运行SQL查询和MapReduce等并行处理框架。这使得它成为用于Big Data、AI和ML等分布式计算任务的理想选择。

需要注意的是，以上列出的应用场景并不是MinIO所有可适用的场景。具体取决于每个使用情况的细节和需求。

1.3 Minio实现分片上传的主要步骤

使用

SpringBoot和MinIO

实现分片上传、秒传、续传主要包含以下几个步骤：

前端选择文件并对其进行切割：可以使用JavaScript等前端技术将文件切成多个片段，并为每个片段生成唯一标识。
将每个分片上传到MinIO对象存储：调用MinIO的Java SDK将每个分片上传到MinIO中，每个分片的KEY名称包含基础名称和片段ID。
将所有分片合并成最终文件：在前端完成所有分片的上传之后，在后台开发一个接口，按照唯一标识将所有分片合并成最终文件。合并过程可以在应用服务器上完成，也可以使用MinIO Object Storage本身的合并功能完成。
实现秒传：在前端上传分片之前，通过请求后台接口来根据文件名称和文件MD5值判断该文件是否已经存在，如果存在则可以直接返回文件URL，即可实现秒传。
实现续传：在前端上传分片时出现了网络问题或客户端故障导致文件上传被中断，这时候只需记录已上传的分片序列号和状态标志，从下一个分片重新开始上传即可。
处理错误和异常：在文件上传过程中可能会遇到各种问题，比如服务故障、网络中断、客户端处理超时等。因此需要加入错误和异常处理，保证整个上传过程顺利进行。

总体而言，使用SpringBoot和MinIO实现分片上传、秒传、续传的难度不算大，可以根据上述步骤进行开发和实现。

1.4 Centos7安装Minio

创建目标文件夹：

mkdir minio

使用docker查看目标镜像状况：

docker search minio

使用docker拉去镜像：

docker pull minio/minio

查看镜像是否拉取成功：

docker images

启动Minio容器

docker run 
    -p9000:9000 -p9090:9090      
    --net=host      
    --name minio      
    -d--restart=always      
    -e"MINIO_ACCESS_KEY=IT@test"-e"MINIO_SECRET_KEY=IT@test"            
    minio/minio server  /data --console-address ":9000"-address":9090"

注意一下，对于密码强度是有要求的，不然报错

这是一个运行 MinIO 容器的 Docker 命令，具体参数解释如下：

-p：映射容器内部的端口到宿主机上。其中 9000 和 9090 分别映射到宿主机的 9000 和 9090 端口上。冒号前是宿主机端口，后是容器端口
--net=host：将容器加入到主机网络中，共享宿主机的 IP 地址。
--name minio：指定容器的名称为 minio。
--restart=always：设置容器在退出后自动重新启动。
-e：设置环境变量。这里设置了两个环境变量：MINIO_ACCESS_KEY 和 MINIO_SECRET_KEY，值分别为 IT@test和 IT@test。
--mount：将容器内部的目录挂载到宿主机上。这里将容器内的 /data 目录挂载到了宿主机的 /data 目录上。
--console-address：指定容器的控制台地址。这里设置为 :9000,表示可以通过宿主机上的 9000 端口访问容器的控制台。
-address：指定容器的网络地址。这里设置为 :9090,表示可以通过宿主机上的 9090 端口访问容器的服务。

提示：页面访问9000，代码里面9090

用户名密码就是启动参数里面的数据
如果访问失败，那就是防火墙问题或者是启动参数最后两项没有添加，再不会有其他的，除非容器没有启动成功
查看放行端口可以使用如下命令：

firewall-cmd --list-ports

要放行CentOS 7上的9000端口和9090端口，可以按照以下步骤操作：
检查防火墙状态
使用以下命令检查防火墙状态：

systemctl status firewalld

如果防火墙已停止，则启动它：

systemctl start firewalld

允许9000端口通过防火墙
使用以下命令允许TCP流量通过9000端口：

firewall-cmd --zone=public --add-port=9000/tcp --permanent
firewall-cmd --zone=public --add-port=9090/tcp --permanent

这将向防火墙添加一个规则，以允许TCP流量通过9000端口。要永久保存此更改，请运行以下命令：

firewall-cmd --reload

重新启动防火墙服务shell
使用以下命令重新启动防火墙服务：

systemctl restart firewalld

1.5 搭建springboot 环境

1.5.1 pom.xml

<!-- 操作minio的java客户端--><dependency><groupId>io.minio</groupId><artifactId>minio</artifactId><version>8.5.2</version></dependency><!--        jwt鉴权相应依赖--><dependency><groupId>ch.qos.logback</groupId><artifactId>logback-classic</artifactId><version>1.2.3</version></dependency><dependency><groupId>io.jsonwebtoken</groupId><artifactId>jjwt-jackson</artifactId><version>0.11.2</version></dependency>

1.5.2 创建容器桶

获取API访问凭证

1.5.3 编写配置文件

server:port:8080spring:servlet:multipart:max-file-size: 10MB
            max-request-size: 10MB
    #minio配置minio:access-key: dAMaxkWaXUD1CV1JHbqw
        secret-key: AXt3SD0JFkDENFbMeJKOOQb5wj8KvabZWu33Rs84
        url: http://127.0.0.1:9090#访问地址bucket-name: wanghui

首先是服务器的配置：

端口号为8080,用于监听请求。
使用了一个Servlet来处理multipart/form-data类型的请求。
在接收到multipart/form-data类型的请求时，会将上传的文件大小限制在10MB以内，并将请求大小限制在10MB以内。

接下来是minio的配置：

access-key和secret-key是访问minio服务的凭证，需要根据实际情况进行填写。
url是minio服务的地址，需要根据实际情况进行填写。
bucket-name是存储文件的桶名，需要根据实际情况进行填写。

1.5.4 常量类

http请求状态

publicclassHttpStatus{/**
     * 操作成功
     */publicstaticfinalintSUCCESS=200;/**
     * 对象创建成功
     */publicstaticfinalintCREATED=201;/**
     * 请求已经被接受
     */publicstaticfinalintACCEPTED=202;/**
     * 操作已经执行成功，但是没有返回数据
     */publicstaticfinalintNO_CONTENT=204;/**
     * 资源已被移除
     */publicstaticfinalintMOVED_PERM=301;/**
     * 重定向
     */publicstaticfinalintSEE_OTHER=303;/**
     * 资源没有被修改
     */publicstaticfinalintNOT_MODIFIED=304;/**
     * 参数列表错误（缺少，格式不匹配）
     */publicstaticfinalintBAD_REQUEST=400;/**
     * 未授权
     */publicstaticfinalintUNAUTHORIZED=401;/**
     * 访问受限，授权过期
     */publicstaticfinalintFORBIDDEN=403;/**
     * 资源，服务未找到
     */publicstaticfinalintNOT_FOUND=404;/**
     * 不允许的http方法
     */publicstaticfinalintBAD_METHOD=405;/**
     * 资源冲突，或者资源被锁
     */publicstaticfinalintCONFLICT=409;/**
     * 不支持的数据，媒体类型
     */publicstaticfinalintUNSUPPORTED_TYPE=415;/**
     * 系统内部错误
     */publicstaticfinalintERROR=500;/**
     * 接口未实现
     */publicstaticfinalintNOT_IMPLEMENTED=501;/**
     * 系统警告消息
     */publicstaticfinalintWARN=601;}

通用常量信息

importio.jsonwebtoken.Claims;publicclassConstants{/**
     * UTF-8 字符集
     */publicstaticfinalStringUTF8="UTF-8";/**
     * GBK 字符集
     */publicstaticfinalStringGBK="GBK";/**
     * www主域
     */publicstaticfinalStringWWW="www.";/**
     * http请求
     */publicstaticfinalStringHTTP="http://";/**
     * https请求
     */publicstaticfinalStringHTTPS="https://";/**
     * 通用成功标识
     */publicstaticfinalStringSUCCESS="0";/**
     * 通用失败标识
     */publicstaticfinalStringFAIL="1";/**
     * 登录成功
     */publicstaticfinalStringLOGIN_SUCCESS="Success";/**
     * 注销
     */publicstaticfinalStringLOGOUT="Logout";/**
     * 注册
     */publicstaticfinalStringREGISTER="Register";/**
     * 登录失败
     */publicstaticfinalStringLOGIN_FAIL="Error";/**
     * 验证码有效期（分钟）
     */publicstaticfinalIntegerCAPTCHA_EXPIRATION=2;/**
     * 令牌
     */publicstaticfinalStringTOKEN="token";/**
     * 令牌前缀
     */publicstaticfinalStringTOKEN_PREFIX="Bearer ";/**
     * 令牌前缀
     */publicstaticfinalStringLOGIN_USER_KEY="login_user_key";/**
     * 用户ID
     */publicstaticfinalStringJWT_USERID="userid";/**
     * 用户名称
     */publicstaticfinalStringJWT_USERNAME=Claims.SUBJECT;/**
     * 用户头像
     */publicstaticfinalStringJWT_AVATAR="avatar";/**
     * 创建时间
     */publicstaticfinalStringJWT_CREATED="created";/**
     * 用户权限
     */publicstaticfinalStringJWT_AUTHORITIES="authorities";/**
     * 资源映射路径 前缀
     */publicstaticfinalStringRESOURCE_PREFIX="/profile";/**
     * RMI 远程方法调用
     */publicstaticfinalStringLOOKUP_RMI="rmi:";/**
     * LDAP 远程方法调用
     */publicstaticfinalStringLOOKUP_LDAP="ldap:";/**
     * LDAPS 远程方法调用
     */publicstaticfinalStringLOOKUP_LDAPS="ldaps:";/**
     * 定时任务白名单配置（仅允许访问的包名，如其他需要可以自行添加）
     */publicstaticfinalString[]JOB_WHITELIST_STR={"com.ruoyi"};/**
     * 定时任务违规的字符
     */publicstaticfinalString[]JOB_ERROR_STR={"java.net.URL","javax.naming.InitialContext","org.yaml.snakeyaml","org.springframework","org.apache","com.ruoyi.common.utils.file","com.ruoyi.common.config"};}

1.5.5 创建Minio的配置类

importio.minio.MinioClient;importlombok.Data;importorg.springframework.boot.context.properties.ConfigurationProperties;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;@Data@Configuration@ConfigurationProperties(prefix ="spring.minio")publicclassMinioConfig{privateString accessKey;privateString secretKey;privateString url;privateString bucketName;@BeanpublicMinioClientminioClient(){returnMinioClient.builder().endpoint(url).credentials(accessKey,secretKey).build();}}

这段代码是Java中的一个配置类，用于配置与MinIO(一个对象存储服务)相关的属性。

minioClient()

方法返回了一个

MinioClient

对象，用于连接到MinIO服务并操作存储桶。其中，

endpoint()

方法用于设置MinIO服务的URL地址，

credentials()

方法用于设置访问密钥和密钥值。

1.5.5 创建Minio的工具类

importio.minio.*;importio.minio.errors.*;importio.minio.http.Method;importlombok.SneakyThrows;importorg.apache.tomcat.util.http.fileupload.IOUtils;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.http.HttpHeaders;importorg.springframework.http.MediaType;importorg.springframework.http.ResponseEntity;importorg.springframework.stereotype.Component;importorg.springframework.web.multipart.MultipartFile;importjava.io.ByteArrayOutputStream;importjava.io.IOException;importjava.io.InputStream;importjava.io.UnsupportedEncodingException;importjava.net.URLEncoder;importjava.security.InvalidKeyException;importjava.security.NoSuchAlgorithmException;importjava.time.ZonedDateTime;importjava.util.Arrays;importjava.util.HashMap;importjava.util.Map;importjava.util.concurrent.TimeUnit;@ComponentpublicclassMinioUtils{@AutowiredprivateMinioClient minioClient;@AutowiredprivateMinioConfig configuration;/**
     * @param name 名字
     * @return boolean
     * @Description description: 判断bucket是否存在，不存在则创建
     */publicbooleanexistBucket(String name){boolean exists;try{
            exists = minioClient.bucketExists(BucketExistsArgs.builder().bucket(name).build());if(!exists){
                minioClient.makeBucket(MakeBucketArgs.builder().bucket(name).build());
                exists =true;}}catch(Exception e){
            e.printStackTrace();
            exists =false;}return exists;}/**
     * @param bucketName 存储bucket名称
     * @return {@link Boolean }
     * @Description 创建存储bucket
     */publicBooleanmakeBucket(String bucketName){try{
            minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());}catch(Exception e){
            e.printStackTrace();returnfalse;}returntrue;}/**
     * @param bucketName 存储bucket名称
     * @return {@link Boolean }
     * @Description 删除存储bucket
     */publicBooleanremoveBucket(String bucketName){try{
            minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build());}catch(Exception e){
            e.printStackTrace();returnfalse;}returntrue;}/**
     * @param fileName 文件名称
     * @param time     时间
     * @return {@link Map }
     * @Description 获取上传临时签名
     */@SneakyThrowspublicMapgetPolicy(String fileName,ZonedDateTime time){PostPolicy postPolicy =newPostPolicy(configuration.getBucketName(), time);
        postPolicy.addEqualsCondition("key", fileName);try{Map<String,String> map = minioClient.getPresignedPostFormData(postPolicy);HashMap<String,String> map1 =newHashMap<>();
            map.forEach((k, v)->{
                map1.put(k.replaceAll("-",""), v);});
            map1.put("host", configuration.getUrl()+"/"+ configuration.getBucketName());return map1;}catch(ErrorResponseException e){
            e.printStackTrace();}catch(InsufficientDataException e){
            e.printStackTrace();}catch(InternalException e){
            e.printStackTrace();}catch(InvalidKeyException e){
            e.printStackTrace();}catch(InvalidResponseException e){
            e.printStackTrace();}catch(IOException e){
            e.printStackTrace();}catch(NoSuchAlgorithmException e){
            e.printStackTrace();}catch(ServerException e){
            e.printStackTrace();}catch(XmlParserException e){
            e.printStackTrace();}returnnull;}/**
     * @param objectName 对象名称
     * @param method     方法
     * @param time       时间
     * @param timeUnit   时间单位
     * @return {@link String }
     * @Description 获取上传文件的url
     */publicStringgetPolicyUrl(String objectName,Method method,int time,TimeUnit timeUnit){try{return minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder().method(method).bucket(configuration.getBucketName()).object(objectName).expiry(time, timeUnit).build());}catch(ErrorResponseException e){
            e.printStackTrace();}catch(InsufficientDataException e){
            e.printStackTrace();}catch(InternalException e){
            e.printStackTrace();}catch(InvalidKeyException e){
            e.printStackTrace();}catch(InvalidResponseException e){
            e.printStackTrace();}catch(IOException e){
            e.printStackTrace();}catch(NoSuchAlgorithmException e){
            e.printStackTrace();}catch(XmlParserException e){
            e.printStackTrace();}catch(ServerException e){
            e.printStackTrace();}returnnull;}/**
     * @param file     文件
     * @param fileName 文件名称
     * @Description 上传文件
     */publicvoidupload(MultipartFile file,String fileName){// 使用putObject上传一个文件到存储桶中。try{InputStream inputStream = file.getInputStream();
            minioClient.putObject(PutObjectArgs.builder().bucket(configuration.getBucketName()).object(fileName).stream(inputStream, file.getSize(),-1).contentType(file.getContentType()).build());}catch(ErrorResponseException e){
            e.printStackTrace();}catch(InsufficientDataException e){
            e.printStackTrace();}catch(InternalException e){
            e.printStackTrace();}catch(InvalidKeyException e){
            e.printStackTrace();}catch(InvalidResponseException e){
            e.printStackTrace();}catch(IOException e){
            e.printStackTrace();}catch(NoSuchAlgorithmException e){
            e.printStackTrace();}catch(ServerException e){
            e.printStackTrace();}catch(XmlParserException e){
            e.printStackTrace();}}/**
     * @param objectName 对象名称
     * @param time       时间
     * @param timeUnit   时间单位
     * @return {@link String }
     * @Description 根据filename获取文件访问地址
     */publicStringgetUrl(String objectName,int time,TimeUnit timeUnit){String url =null;try{
            url = minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder().method(Method.GET).bucket(configuration.getBucketName()).object(objectName).expiry(time, timeUnit).build());}catch(ErrorResponseException e){
            e.printStackTrace();}catch(InsufficientDataException e){
            e.printStackTrace();}catch(InternalException e){
            e.printStackTrace();}catch(InvalidKeyException e){
            e.printStackTrace();}catch(InvalidResponseException e){
            e.printStackTrace();}catch(IOException e){
            e.printStackTrace();}catch(NoSuchAlgorithmException e){
            e.printStackTrace();}catch(XmlParserException e){
            e.printStackTrace();}catch(ServerException e){
            e.printStackTrace();}return url;}/**
     * @param fileName
     * @return {@link ResponseEntity }<{@link byte[] }>
     * @Description description: 下载文件
     */publicResponseEntity<byte[]>download(String fileName){ResponseEntity<byte[]> responseEntity =null;InputStream in =null;ByteArrayOutputStream out =null;try{
            in = minioClient.getObject(GetObjectArgs.builder().bucket(configuration.getBucketName()).object(fileName).build());
            out =newByteArrayOutputStream();IOUtils.copy(in, out);//封装返回值byte[] bytes = out.toByteArray();HttpHeaders headers =newHttpHeaders();try{
                headers.add("Content-Disposition","attachment;filename="+URLEncoder.encode(fileName,"UTF-8"));}catch(UnsupportedEncodingException e){
                e.printStackTrace();}
            headers.setContentLength(bytes.length);
            headers.setContentType(MediaType.APPLICATION_OCTET_STREAM);
            headers.setAccessControlExposeHeaders(Arrays.asList("*"));
            responseEntity =newResponseEntity<byte[]>(bytes, headers,HttpStatus.SUCCESS);}catch(Exception e){
            e.printStackTrace();}finally{try{if(in !=null){try{
                        in.close();}catch(IOException e){
                        e.printStackTrace();}}if(out !=null){
                    out.close();}}catch(IOException e){
                e.printStackTrace();}}return responseEntity;}/**
     * @param objectFile 对象文件
     * @return {@link String }
     * @Description 根据文件名和桶获取文件路径
     */publicStringgetFileUrl(String objectFile){try{return minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder().method(Method.GET).bucket(configuration.getBucketName()).object(objectFile).build());}catch(Exception e){
            e.printStackTrace();}returnnull;}}

该代码是一个工具类，用于使用阿里云的对象存储服务(OSS)进行文件上传和下载。具体功能如下：

1.5.6 创建Ajax请求工具类

publicclassAjaxResultextendsHashMap<String,Object>{privatestaticfinallong serialVersionUID =1L;/** 状态码 */publicstaticfinalStringCODE_TAG="code";/** 返回内容 */publicstaticfinalStringMSG_TAG="msg";/** 数据对象 */publicstaticfinalStringDATA_TAG="data";/**
     * 初始化一个新创建的 AjaxResult 对象，使其表示一个空消息。
     */publicAjaxResult(){}/**
     * 初始化一个新创建的 AjaxResult 对象
     *
     * @param code 状态码
     * @param msg 返回内容
     */publicAjaxResult(int code,String msg){super.put(CODE_TAG, code);super.put(MSG_TAG, msg);}/**
     * 初始化一个新创建的 AjaxResult 对象
     *
     * @param code 状态码
     * @param msg 返回内容
     * @param data 数据对象
     */publicAjaxResult(int code,String msg,Object data){super.put(CODE_TAG, code);super.put(MSG_TAG, msg);if(data!=null){super.put(DATA_TAG, data);}}/**
     * 返回成功消息
     *
     * @return 成功消息
     */publicstaticAjaxResultsuccess(){returnAjaxResult.success("操作成功");}/**
     * 返回成功数据
     *
     * @return 成功消息
     */publicstaticAjaxResultsuccess(Object data){returnAjaxResult.success("操作成功", data);}/**
     * 返回成功消息
     *
     * @param msg 返回内容
     * @return 成功消息
     */publicstaticAjaxResultsuccess(String msg){returnAjaxResult.success(msg,null);}/**
     * 返回成功消息
     *
     * @param msg 返回内容
     * @param data 数据对象
     * @return 成功消息
     */publicstaticAjaxResultsuccess(String msg,Object data){returnnewAjaxResult(HttpStatus.SUCCESS, msg, data);}/**
     * 返回警告消息
     *
     * @param msg 返回内容
     * @return 警告消息
     */publicstaticAjaxResultwarn(String msg){returnAjaxResult.warn(msg,null);}/**
     * 返回警告消息
     *
     * @param msg 返回内容
     * @param data 数据对象
     * @return 警告消息
     */publicstaticAjaxResultwarn(String msg,Object data){returnnewAjaxResult(HttpStatus.WARN, msg, data);}/**
     * 返回错误消息
     *
     * @return 错误消息
     */publicstaticAjaxResulterror(){returnAjaxResult.error("操作失败");}/**
     * 返回错误消息
     *
     * @param msg 返回内容
     * @return 错误消息
     */publicstaticAjaxResulterror(String msg){returnAjaxResult.error(msg,null);}/**
     * 返回错误消息
     *
     * @param msg 返回内容
     * @param data 数据对象
     * @return 错误消息
     */publicstaticAjaxResulterror(String msg,Object data){returnnewAjaxResult(HttpStatus.ERROR, msg, data);}/**
     * 返回错误消息
     *
     * @param code 状态码
     * @param msg 返回内容
     * @return 错误消息
     */publicstaticAjaxResulterror(int code,String msg){returnnewAjaxResult(code, msg,null);}/**
     * 方便链式调用
     *
     * @param key 键
     * @param value 值
     * @return 数据对象
     */@OverridepublicAjaxResultput(String key,Object value){super.put(key, value);returnthis;}}

1.5.7 创建Minio文件操作接口层

importcom.xiaohui.utils.AjaxResult;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.http.ResponseEntity;importorg.springframework.web.bind.annotation.*;importorg.springframework.web.multipart.MultipartFile;importjava.util.HashMap;/**
 * @Description minio文件上传控制器
 */@CrossOrigin@RestController@RequestMapping("/api")publicclassMinioFileUploadController{@AutowiredprivateMinioUtils minioUtils;/**
     * @param file     文件
     * @param fileName 文件名称
     * @return {@link AjaxResult }
     * @Description 上传文件
     */@GetMapping("/upload")publicAjaxResultuploadFile(@RequestParam("file")MultipartFile file,String fileName){
        minioUtils.upload(file, fileName);returnAjaxResult.success("上传成功");}/**
     * @param fileName 文件名称
     * @return {@link ResponseEntity }
     * @Description dowload文件
     */@GetMapping("/dowload")publicResponseEntitydowloadFile(@RequestParam("fileName")String fileName){return minioUtils.download(fileName);}/**
     * @param fileName 文件名称
     * @return {@link AjaxResult }
     * @Description 得到文件url
     */@GetMapping("/getUrl")publicAjaxResultgetFileUrl(@RequestParam("fileName")String fileName){HashMap map=newHashMap();
        map.put("FileUrl",minioUtils.getFileUrl(fileName));returnAjaxResult.success(map);}}

标签： spring boot 后端 java

本文转载自: https://blog.csdn.net/u012060033/article/details/140084235
版权归原作者 爱吃牛肉的大老虎 所有，如有侵权，请联系我们删除。