文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

【Java编程系列】Minio实现文件上传下载

2023-09-02 18:36

关注

热门系列:

【Java编程系列】Amazon S3实现文件上传下载


目录

热门系列:

1、前言

2、Minio实战代码

2.1 Minio环境部署

2.2 Minio的Sdk对接实现

2.2.1 Minio Maven依赖

2.2.2 minio配置与初始化

2.2.3 上传文件

2.2.4 下载文件

2.2.5 生成文件预签名url

2.2.6 文件永久性访问实现

2.2.7 删除文件

2.2.8 其他操作

3、总结


1、前言

        最近给一个租户做minio的独立存储部署,使用过程中,有了一点使用心得,做一个记录分享,希望可以帮到有需要的朋友~~~


2、Minio实战代码

2.1 Minio环境部署

        进入下载链接:https://dl.min.io/server/minio/release/ ,按需下载对应版本后,安装完毕即可。装载完成,启动minio后,可以直接打开对应的可视化界面,输入http://ip:9000/,如下图,表示部署安装成功啦(安装细节在本文展开,不清楚的童靴请搜索一下):

2.2 Minio的Sdk对接实现

2.2.1 Minio Maven依赖

        引入相关java sdk所需依赖:

    io.minio    minio    8.2.2


2.2.2 minio配置与初始化

        先设置minio的一些配置信息:

minio:  url: http://127.0.0.1:9000    #安装minio的服务器ip  bucket: news                  #创建的存储桶名称(可界面创建,亦可sdk代码创建)  accessKey: testkey            #minio登录账号  secretKey: testpassword       #minio登录密码

        通过配置类读取配置信息,为后续使用做准备:

package ***.***.***.***.configure;import lombok.Data;import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Configuration;@Data@Configuration@ConfigurationProperties(prefix = "minio")public class MinioProperties {private String accessKey;private String secretKey;private String url;private String bucket;}

        初始化minio客户端:

package ***.***.***.utils;import ***.***.***.MinioProperties;import io.minio.BucketExistsArgs;import io.minio.GetObjectArgs;import io.minio.MakeBucketArgs;import io.minio.MinioClient;import io.minio.PutObjectArgs;import io.minio.RemoveObjectArgs;import io.minio.errors.ErrorResponseException;import io.minio.errors.InsufficientDataException;import io.minio.errors.InternalException;import io.minio.errors.InvalidResponseException;import io.minio.errors.ServerException;import io.minio.errors.XmlParserException;import org.springframework.beans.factory.annotation.Autowired;import java.io.IOException;import java.io.InputStream;import java.security.InvalidKeyException;import java.security.NoSuchAlgorithmException;public class MinioClientUtil {@Autowiredprivate MinioProperties properties;private MinioClient client;    //初始化minio clientprivate void init() throws NoSuchAlgorithmException, InvalidKeyException, IOException,InvalidResponseException, InsufficientDataException, ServerException, ErrorResponseException,XmlParserException, InternalException {if (null != client) {return;}client = MinioClient.builder().endpoint(properties.getUrl()).credentials(properties.getAccessKey(), properties.getSecretKey()).build();makeBucket(properties.getBucket());}    //创建自定义的存储桶    //这里只做了简单的桶存在判断,这里还可以添加设置桶的策略等public void makeBucket(String bucket) throws IOException, InvalidKeyException, InvalidResponseException,InsufficientDataException, NoSuchAlgorithmException, ServerException, InternalException, XmlParserException,ErrorResponseException {boolean bucketExist = client.bucketExists(BucketExistsArgs.builder().bucket(bucket).build());if (!bucketExist) {client.makeBucket(MakeBucketArgs.builder().bucket(bucket).build());}}}

2.2.3 上传文件

import io.minio.BucketExistsArgs;import io.minio.GetObjectArgs;import io.minio.MakeBucketArgs;import io.minio.MinioClient;import io.minio.PutObjectArgs;import io.minio.RemoveObjectArgs;import io.minio.errors.ErrorResponseException;import io.minio.errors.InsufficientDataException;import io.minio.errors.InternalException;import io.minio.errors.InvalidResponseException;import io.minio.errors.ServerException;import io.minio.errors.XmlParserException;import org.springframework.beans.factory.annotation.Autowired;import java.io.IOException;import java.io.InputStream;import java.security.InvalidKeyException;import java.security.NoSuchAlgorithmException;public class MinioClientUtil {public void uploadFile(String bucket, String fileName, InputStream ins, long fileSize)throws IOException, InvalidKeyException, InvalidResponseException, InsufficientDataException,NoSuchAlgorithmException, ServerException, InternalException, XmlParserException,ErrorResponseException {init();makeBucket(bucket);PutObjectArgs.Builder putObjectArgsBuilder = PutObjectArgs.builder().bucket(bucket).object(fileName).stream(ins, fileSize, 5 * 1024 * 1024);client.putObject(putObjectArgsBuilder.build());}}


2.2.4 下载文件

import io.minio.BucketExistsArgs;import io.minio.GetObjectArgs;import io.minio.MakeBucketArgs;import io.minio.MinioClient;import io.minio.RemoveObjectArgs;import io.minio.errors.ErrorResponseException;import io.minio.errors.InsufficientDataException;import io.minio.errors.InternalException;import io.minio.errors.InvalidResponseException;import io.minio.errors.ServerException;import io.minio.errors.XmlParserException;import org.springframework.beans.factory.annotation.Autowired;import java.io.IOException;import java.io.InputStream;import java.security.InvalidKeyException;import java.security.NoSuchAlgorithmException;public class MinioClientUtil {public InputStream download(String bucket, String fileName)throws IOException, InvalidKeyException, InvalidResponseException, InsufficientDataException,NoSuchAlgorithmException, ServerException, InternalException, XmlParserException,ErrorResponseException {init();GetObjectArgs.Builder getObjectArgsBuilder = GetObjectArgs.builder().bucket(bucket).object(fileName);return client.getObject(getObjectArgsBuilder.build());}}


2.2.5 生成文件预签名url

import io.minio.BucketExistsArgs;import io.minio.GetObjectArgs;import io.minio.GetPresignedObjectUrlArgs;import io.minio.MakeBucketArgs;import io.minio.MinioClient;import io.minio.PutObjectArgs;import io.minio.RemoveObjectArgs;import io.minio.errors.ErrorResponseException;import io.minio.errors.InsufficientDataException;import io.minio.errors.InternalException;import io.minio.errors.InvalidResponseException;import io.minio.errors.ServerException;import io.minio.errors.XmlParserException;import io.minio.http.Method;import org.springframework.beans.factory.annotation.Autowired;import java.io.IOException;import java.io.InputStream;import java.security.InvalidKeyException;import java.security.NoSuchAlgorithmException;public class MinioClientUtil {private String getMinioURL(String bucket, String fileName) throws IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, ServerException, XmlParserException, InternalException, InsufficientDataException, ErrorResponseException {if (null == client) {init();}GetPresignedObjectUrlArgs build = GetPresignedObjectUrlArgs.builder().method(Method.GET).bucket(bucket).object(fileName).expiry(60 * 60 * 24)   //生成的预签名url可访问的有效时间,最大期限7天.build();return client.getPresignedObjectUrl(build);}}

2.2.6 文件永久性访问实现

        这里做永久访问有效实现,是为了应对一种场景。例如,我们的图片文件,需要直接通过url(非下载后)可显示或打开,在系统用户头像这里,就可能会要求如此实现。因此,我们需要保证我们生成的图片url只可以直接访问的。

        但是,通过上述预签名url的生成方式,有一个最大时效7天的限制,所以此方式暂不考虑。

        minio其实也提供了,文件直接通过ip端口或域名的方式访问的,即用url访问minio存储桶中的文件。要想能直接通过自己定义的 ip+端口+图片路径  来访问的话,需要将minio指定存储桶的访问策略调整一下,如下图所示:

 点击add,策略选Read Only就行了,就可以访问了。

        然后,通过 http://ip:9000/同名/文件路径及名称 的URL形式,就可以永久访问到这个图片文件啦~~

        这里有一个访问形式上的微调,可能有的系统,是使用域名访问的,这个时候域名的一些端口都是通过nginx指定统一了,那这个时候,对于minio如果需要使用域名访问,则需要把nginx再指定配置一下,就可以啦!

2.2.7 删除文件

import io.minio.BucketExistsArgs;import io.minio.GetObjectArgs;import io.minio.GetPresignedObjectUrlArgs;import io.minio.MakeBucketArgs;import io.minio.MinioClient;import io.minio.PutObjectArgs;import io.minio.RemoveObjectArgs;import io.minio.errors.ErrorResponseException;import io.minio.errors.InsufficientDataException;import io.minio.errors.InternalException;import io.minio.errors.InvalidResponseException;import io.minio.errors.ServerException;import io.minio.errors.XmlParserException;import io.minio.http.Method;import org.springframework.beans.factory.annotation.Autowired;import java.io.IOException;import java.io.InputStream;import java.security.InvalidKeyException;import java.security.NoSuchAlgorithmException;public class MinioClientUtil {public void delete(String bucket, String fileName) throws IOException, InvalidKeyException, InvalidResponseException,InsufficientDataException, NoSuchAlgorithmException, ServerException, InternalException, XmlParserException,ErrorResponseException {init();client.removeObject(RemoveObjectArgs.builder().bucket(bucket).object(fileName).build());}}

2.2.8 其他操作

        以上就为minio的主要操作sdk的实现了。另外有一个操作,这边就不一 一列举了。例如

获取桶对象、桶列表、存储文件列表等等,可以自行按需实践一番~~~


3、总结

       在使用minio的过程中,发现了几处需要注意的点:

        1、minio在同一路径下的文件,如果名称相同,则会被覆盖掉。所以,建议可以考虑加文件前加:yyyy-MM-dd/时间戳-文件名 的方式来实现区分存储

        2、minio对于存储文件的单个文件的大小,暂无明确大小上限,一个对象文件可以是任意大小,从几 kb 到最大 5T 不等

        最后,对于minio的加密处理方式,暂时还没有研究完,可能后续补充完善。

        对博文内容有疑问的地方,欢迎下方留言讨论,看到必回复大家~~~~

来源地址:https://blog.csdn.net/yy339452689/article/details/126410894

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     807人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     351人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     314人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     433人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     221人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯