SpringBoot整合Minio实现文件上传、下载

SpringBoot整合Minio实现文件上传、下载：
**1，介绍高性能分布式存储文件服务Minio：Minio是

基于Go语言编写的对象存储服务

，

适合于存储大容量非结构化的数据

，例如

图片、音频、视频、日志文件、备份数据和容器/虚拟机镜像等

，而一个对象文件可以是任意大小，从几kb到最大5T不等。区别于分布式存储系统，minio的特色在于简单、轻量级，对开发者友好！！！，认为存储应该是一个开发问题而不是一个运维问题。**

Minio的高可用设计特性：

分布式设计

1、Minio将多个硬盘(可以分布在不同机器)组成一个分布式的对象存储系统
2、去中心化、分布式

数据保护

1、Minio采用纠删码(erasuer code)来保证集群多点或者单点故障和位衰减(bit rot)
2、最少需要4个节点来使Minio自动引入纠删码

高可用

分布式Minio存储系统允许集群N/2节点宕机，但是恢复数据则需要通过N/2+1节点来进行恢复。
例如：8个节点，宕机4个，则需要5个节点进行数据恢复

限制

分布式Minio单个租户最小需要4个节点(硬盘)，最大支持16个节点(硬盘)受限于纠删码(erasuer
code)，我们可以使用k8s来进行minio租户的管理。

一致性

Minio不论是分布式或者是单机，均遵从read-after-write来保证数据的一致性

安全

支持TLS证书

Minio纠删码

Minio使用纠删码(erasuer code) 进行校验来保护数据，
避免发生硬件故障或者某种原因导致数据丢失，即使丢失N/2 的硬盘都可以将数据恢复回来。
http://www.360doc.com/content/21/1004/21/25921839_998266807.shtml通过这个链接了解纠删码

Minio如何使用纠删码及优点

纠删码是一种数据丢失和损坏数据的一种算法，Minio使用Reed-Solomon
code拆分对象为N/2数据和N/2奇偶校验块。
例如：我有12块硬盘，存放了一个文件，Minio会给我分成6份数据和6个奇偶校验块，不管我是丢失了哪个硬盘，数据均可以得到恢复。
.
Minio可以针对某个对象进行单独恢复，而raid则需要针对卷来进行恢复，从而减少了恢复的时间周期。
Minio对每个对象进行编码，存储服务一经部署，存储硬盘一般不需要进行更换或者修复，Minio的纠删码设计目标是为了性能和硬件加速。

接下来单机版Docker部署Minio服务：

通过配置docker-compose.yml文件管理容器，通过docker-compose up -d 启动容器

docker-compose.yml文件
这里的9100是配置访问minio自带的web管理后台，9090是配置的服务器

version:"3.1"
services:
  minio:
    image: minio/minio:latest
    container_name: minio
    ports:-"9100:9000"-"9090:9090"
    volumes:-"./data:/data"
    environment:MINIO_ACCESS_KEY:"root"MINIO_SECRET_KEY:"12345678"
    command: server /data --console-address=":9000"--address=":9090"
    logging:
      driver:"json-file"
      options:
        max-size:"1m"

启动容器，访问web界面，如图所示
在这里插入图片描述

在这里插入图片描述
.
.

minio服务搭建完毕之后，接下来就是用Springboot整合Minio实现文件的上传、下载
项目练习源码gitee地址：https://gitee.com/xzq25_com/minio-test.git

项目目录结构：
在这里插入图片描述

拉取以上项目源码，简单总结一下需要干的事儿：

1，yml文件配置
2，minio配置类并注入容器进行管理
3，封装minio操作服务器的API的工具类，项目中封装了单文件上传、下载、删除、查看功能，桶的创建等
公司具体的存储业务，在次基础上根据公司业务来自行扩展
4，编写controller层，用postman进行简单的测试（测试类型：文本、文档、表格、音频、视频、图片）

yml配置

spring:
  # 配置文件上传大小限制
  servlet:
    multipart:
      max-file-size:200MB
      max-request-size:200MB
minio:
  server: http://120.76.159.196
  port:9090
  accessKey: root
  secretKey:12345678
  bucket: test
  urlprefix:/minio/

配置类截图如下：

/**
 * @Author xiaozq
 * @Date 2022/11/17 9:54
 * <p>@Description: 注意：这里不能用@Data,需手动写gitter，setter
 * reason：与@ConfigurationProperties一起用的时候，配置文件的值不能赋值给对应类属性，属性值均为null</p>
 */@Configuration@ConfigurationProperties(prefix ="minio")publicclassMinioConfig{privateString server;privateint port;privateString accessKey;privateString secretKey;// 桶名privateString bucket;// 统一前缀privateString urlPrefix;/**
     * 创建minio连接对象
     * @return
     */@BeanpublicMinioClientminioClient(){returnMinioClient.builder().endpoint(server,port,false).credentials(accessKey,secretKey).build();}publicvoidsetServer(String server){this.server = server;}publicvoidsetPort(int port){this.port = port;}publicvoidsetAccessKey(String accessKey){this.accessKey = accessKey;}publicvoidsetSecretKey(String secretKey){this.secretKey = secretKey;}publicvoidsetBucket(String bucket){this.bucket = bucket;}publicvoidsetUrlPrefix(String urlPrefix){this.urlPrefix = urlPrefix;}publicStringgetUrlPrefix(){return urlPrefix;}publicStringgetServer(){return server;}publicintgetPort(){return port;}publicStringgetAccessKey(){return accessKey;}publicStringgetSecretKey(){return secretKey;}publicStringgetBucket(){return bucket;}}

自定义封装操作minio的api工具类

***@Author xiaozq
 *@Date2022/8/510:42*<p>@Description:</p>*/@ComponentpublicclassMinioTemplate{@AutowiredprivateMinioClient minioClient;@Value("${minio.bucket}")publicString bucketName;@Value("${minio.urlprefix}")publicString urlprefix;/**
     * 判断bucket是否存在，不存在则创建
     * @param name
     */publicvoidexistBucket(String name){try{boolean exist = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());if(!exist){
                minioClient.makeBucket(MakeBucketArgs.builder().bucket(name).build());}}catch(Exception e){
            e.printStackTrace();}}/**
     * 创建存储bucket
     * @param bucketName 存储bucket名称
     * @return Boolean
     */publicBooleanmakeBucket(String bucketName){try{
            minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());}catch(Exception e){
            e.printStackTrace();returnfalse;}returntrue;}/**
     * 删除存储bucket
     * @param bucketName 存储bucket名称
     * @return Boolean
     */publicBooleanremoveBucket(String bucketName){try{
            minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build());}catch(Exception e){
            e.printStackTrace();returnfalse;}returntrue;}/**
     * 文件上传
     * @param file
     * @return
     */publicMap<String,String>upload(MultipartFile file){String filename =FileUtils.extractUploadFilename(file);try{InputStream inputStream = file.getInputStream();// 上传到minio服务器
            minioClient.putObject(PutObjectArgs.builder().bucket(this.bucketName).object(filename).stream(inputStream,-1L,10485760L).build());}catch(Exception e){
            e.printStackTrace();}// 返回地址Map<String,String> resultMap =newHashMap<>();
        resultMap.put("url",filename);return  resultMap;}/**
     * 文件下载
     * @param fileName 文件名
     * @param delete   是否删除
     * @throws IOException
     */publicvoidfileDownload(@RequestParam(name ="fileName")String fileName,@RequestParam(defaultValue ="false")Boolean delete,HttpServletResponse response){InputStream inputStream   =null;OutputStream outputStream =null;try{if(StringUtils.isBlank(fileName)){
                response.setHeader("Content-type","text/html;charset=UTF-8");String data ="文件下载失败";OutputStream ps = response.getOutputStream();
                ps.write(data.getBytes("UTF-8"));return;}

            outputStream = response.getOutputStream();// 获取文件对象
            inputStream =minioClient.getObject(GetObjectArgs.builder().bucket(this.bucketName).object(fileName).build());byte buf[]=newbyte[1024];int length =0;
            response.reset();
            response.setHeader("Content-Disposition","attachment;filename="+URLEncoder.encode(fileName.substring(fileName.lastIndexOf("/")+1),"UTF-8"));
            response.setContentType("application/octet-stream");
            response.setCharacterEncoding("UTF-8");// 输出文件while((length = inputStream.read(buf))>0){
                outputStream.write(buf,0, length);}
            inputStream.close();// 判断：下载后是否同时删除minio上的存储文件if(BooleanUtils.isTrue(delete)){
                minioClient.removeObject(RemoveObjectArgs.builder().bucket(this.bucketName).object(fileName).build());}}catch(Throwable ex){
            response.setHeader("Content-type","text/html;charset=UTF-8");String data ="文件下载失败";try{OutputStream ps = response.getOutputStream();
                ps.write(data.getBytes("UTF-8"));}catch(IOException e){
                e.printStackTrace();}}finally{try{
            outputStream.close();if(inputStream !=null){
                    inputStream.close();}}catch(IOException e){
                e.printStackTrace();}}}/**
     * 查看文件对象
     * @param bucketName 存储bucket名称
     * @return 存储bucket内文件对象信息
     */publicList<ObjectItem>listObjects(String bucketName){Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).build());List<ObjectItem> objectItems =newArrayList<>();try{for(Result<Item> result : results){Item item = result.get();ObjectItem objectItem =newObjectItem();
                objectItem.setObjectName(item.objectName());
                objectItem.setSize(item.size());

                objectItems.add(objectItem);}}catch(Exception e){
            e.printStackTrace();returnnull;}return objectItems;}/**
     * 批量删除文件对象
     * @param bucketName 存储bucket名称
     * @param objects 对象名称集合
     */publicMap<String,String>removeObjects(String bucketName,List<String> objects){Map<String,String> resultMap =newHashMap<>();List<DeleteObject> dos = objects.stream().map(e ->newDeleteObject(e)).collect(Collectors.toList());try{
             minioClient.removeObjects(RemoveObjectsArgs.builder().bucket(bucketName).objects(dos).build());
            resultMap.put("mes","删除成功");}catch(Exception e){
            e.printStackTrace();
            resultMap.put("mes","网络异常，删除失败");}return resultMap;}}

上传文件名替换工具类：

publicclassFileUtils{/**
     * 编码文件名
     * 日期路径 + UUID
     * 示例：fileName=2022/11/18/统计报表1668758006562.txt
     */publicstaticfinalStringextractUploadFilename(MultipartFile file){String fileName = file.getOriginalFilename();// 注意，这里需要加上 \\ 将 特殊字符 . 转意 \\. ,否则异常String[] fileArray = fileName.split("\\.");
        fileName =datePath()+"/"+ fileArray[0]+System.currentTimeMillis()+"."+fileArray[1];return fileName;}/**
     * 日期路径 即年/月/日 如2018/08/08
     */publicstaticfinalStringdatePath(){Date now =newDate();returnDateFormatUtils.format(now,"yyyy/MM/dd");}}

controller层测试

@RestControllerpublicclassMinioController{@AutowiredprivateMinioTemplate minioTemplate;@Value("${minio.server}")privateString server;@Value("${minio.port}")privateInteger port;@Value("${minio.bucket}")privateString bucket;/**
     * 单文件上传
     * @param file 文件
     * @return
     */@PostMapping("/uploadone")publicObjectuploadOne(MultipartFile file){return minioTemplate.upload(file);}/**
     *  单文件下载
     * @param fileName 文件
     * @param delete 下载完后是否删除, 请谨慎传参
     */@GetMapping("/download")publicvoiddownload(@RequestParam(value ="fileName")String fileName,@RequestParam(defaultValue ="false")Boolean delete,HttpServletResponse response){
        minioTemplate.fileDownload(fileName,delete,response);}/**
     * 查看存储的文件列表
     * @param bucket 桶
     * @return
     */@GetMapping("/list")publicObjectfileList(@RequestParam(value ="bucket")String bucket){return minioTemplate.listObjects(bucket);}/**
     * 删除文件
     * @param bucket 桶
     * @param list 文件名列表
     * @return
     */@DeleteMapping("/remove")publicObjectfileremove(@RequestParamString bucket,@RequestParamList<String> list){return minioTemplate.removeObjects(bucket,list);}}

接下来就是用postman测试，非常便利：测试存储文档、表格、日志、视频、音频、图片等上传、下载
在这里插入图片描述
.

好啦，Minio的入门学习就到此结束啦，希望能给你带来帮助…

标签：文件存储 minio

本文转载自: https://blog.csdn.net/qq_45399396/article/details/127927057
版权归原作者 【JAVA】玩家 所有，如有侵权，请联系我们删除。

SpringBoot整合Minio实现文件上传、下载

发表评论

“SpringBoot整合Minio实现文件上传、下载”的评论:

关于作者

overfit同步小助手

相关阅读

文章导航