(总目录)springboot - 实现zip文件上传并对zip文件解压, 包含上传oss

2023-09-22 10:56:53

全文目录,一步到位

1.本文概述

1.1 本文简介

本文会包含

  • java 文件校验
  • 文件上传
  • 文件压缩
  • zip文件的解压
  • oss的文件上传
  • oss前端上传

2. 功能实现

文章像齿轮一样, 部分位置需要自己组装满足不同业务需求
需要哪个就加哪个 注意类型和位置即可 注释都是很全的
如果在使用中 遇到问题 欢迎评论区指正

2.1 统一文件校验

===> 传送门: MultipartFile 统一文件校验

2.2 普通(多)文件上传[服务器]

支持单/多文件同时上传 部分service方法 这个都随意 满足springboot标准即可

2.2.1 controller层

    /**
     * 普通文件上传
     * @param
     * @return
     */
    @ApiOperation("==> 普通文件上传 <===")
    @RequestMapping(value = "/fileUpload", method = RequestMethod.POST)
    public ResultResponse fileUpload(MultipartFile[] file, PageVo pageVo) {

        log.info("===> 普通文件上传 <===");

        ResultResponse result = ossAddService.fileUpload(file, pageVo.getSearchName());
        log.info("返回用户信息:{}", result);
        return result;
    }

2.2.2 service层

 ResultResponse fileUpload(MultipartFile[] file, String searchName);

2.2.3 业务impl实现类

 	@SneakyThrows
    @Override
    public ResultResponse fileUpload(MultipartFile[] file, String searchName) {

        //文件上传功能
        String str = FileIOUtils.fileUpload(file, searchName, false);

        return ResultResponse.ok().setData(str);
    }

2.2.4 FileIOUtils工具包代码

注意: 有报错的位置 注释掉即可 , 自己的业务代码

  • throw异常位置 换成 RuntimeException(“我是异常”) 即可
  • ZipUtil.unzip() 解压的方法 根据后缀名 是zip进行解压
    后面有介绍->2.3 不需要可以直接注释
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.compress.utils.IOUtils;
import org.springframework.web.multipart.MultipartFile;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.Objects;
import java.util.UUID;

/**
 * 文件上传工具类
 *
 * @author pzy
 * @version 0.1.0
 * @description TODO
 */
@Slf4j
public class FileIOUtils {

    /**
     * 文件上传
     *
     * @param file             上传文件
     * @param uploadPath       上传文件路径
     * @param isRandomFileName 是否是随机的文件名 true:是  false:否
     * @return
     */
    @SneakyThrows
    public static String fileUpload(MultipartFile[] file, String uploadPath, boolean isRandomFileName) {
        //上传目录地址
        log.debug(uploadPath);

        //(最新修改)如果目录不存在，自动创建文件夹(修复)
        if (!FileIOUtils.createFile(1, new File(uploadPath), false)) {
            log.error("-------> 自动创建文件或文件夹失败!!! <--------");
        }

        //之后可以 优化  根据配置文件自动配置 mkdir-
        String suffix = null;
        String fileName = null;

        //  HashMap hashMap = new HashMap();

        FileOutputStream fileOutputStream = null;
        try {
            //遍历文件数组执行上传(多文件上传需要)
            for (MultipartFile multipartFile : file) {
                if (multipartFile != null) {
                    log.debug("开始上传文件.......");
                    //调用上传方法
                    suffix = Objects.requireNonNull(multipartFile.getOriginalFilename()).substring(multipartFile.getOriginalFilename().lastIndexOf(".")); //后缀名

                    //文件名 是随机 就uuid 不是随机就是原名
                    fileName = (isRandomFileName ? UUID.randomUUID() + suffix : multipartFile.getOriginalFilename());

                    fileOutputStream = new FileOutputStream(uploadPath + "/" + fileName);
                    IOUtils.copy(multipartFile.getInputStream(), fileOutputStream);
                    //file[i].transferTo(new File(uploadDir+"/"+fileName));
                    log.debug("上传" + uploadPath + "/" + fileName + "文件成功！");

                    /*不是随机文件上传 并且是 zip 解压*/
                    if (!isRandomFileName && Objects.equals(suffix, ".zip")) {
                        //解压文件夹
                        ZipUtil.unzip(uploadPath + "/" + fileName, uploadPath);
                    }


                }
            }
            log.debug("上传结束！所有文件上传文件至：" + uploadPath);
            System.out.printf("文件名->%s\n", fileName);

            return fileName;
        } catch (Exception e) {
            //打印错误堆栈信息
            e.printStackTrace();
            log.error("上传文件失败,请检查后重试!!！");

            throw new ThirdServiceException(ResponseEnum.T160004);
        } finally {
            if (fileOutputStream != null) {
                fileOutputStream.close();
            }
        }
    }

    /**
     * 判断文件是否存在，不存在就创建
     *
     * @param file
     */
    public static boolean createFile(int type, File file, Boolean flag) {
        if (type == 1) {
            if (!file.exists()) {
                return file.mkdirs();
            }
        }
//其他就是0 文件及目录创建(存在bug)
        if (file.exists()) {
            log.debug("文件及相关路径存在!!!");
        } else {
            log.info("文件不存在 ,创建文件以及文件夹 ...");
            //getParentFile() 获取上级目录(包含文件名时无法直接创建目录的)
            if (!file.getParentFile().exists()) {
                log.info("文件及其路径不存在, 创建路径文件!!!");
                //创建层级目录
                if (!file.getParentFile().mkdirs()) {
                    return false;
                }
            }
            if (flag) {
                try {
                    //上层目录创建文件
                    log.info("文件夹创建开启,在上层目录下创建文件夹");
                    if (file.createNewFile()) {
                        return false;
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return true;
    }

    /**
     * 文件删除回收
     *
     * @param path
     */
    public static boolean fileGCDelete(String path) {
        boolean flag = false;
        File file1 = new File(path);
        if (file1.exists()) {
            flag = file1.delete();
            try {
                do {
                    if (!flag) {
                        System.gc();    //回收资源
                        flag = file1.delete();
                    }
                } while (!flag);
            } catch (Exception e) {
                e.printStackTrace();
            }
            log.debug("路径存在" + flag);
        }
        return flag;
    }
}

2.3 zip文件的解压

文件压缩工具包 使用java.util.zip包

import lombok.extern.slf4j.Slf4j;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;

/**
 * 解压文件工具类
 *
 * @author pzy
 * @version 0.1.0
 * @description TODO
 */
@Slf4j
public class ZipUtil {
    /**
     * 解压核心功能
     * @param zipFilePath 文件目标路径
     * @param destDir 文件解压后路径
     * @throws IOException
     */
    public static void unzip(String zipFilePath, String destDir) throws IOException {

        log.info("===>开启文件解压: {}",zipFilePath);
        File dir = new File(destDir);
        if (!dir.exists()) {
            boolean mkdirs = dir.mkdirs();
            if (!mkdirs) {
                log.error("多级文件夹创建失败===>{}",destDir);
            }
        }
        //windows下中文默认gbk 正常使用utf-8
        try (ZipInputStream zipIn = new ZipInputStream(new FileInputStream(zipFilePath), StandardCharsets.UTF_8)) {
            ZipEntry entry = zipIn.getNextEntry();
            while (entry != null) {
                String filePath = destDir + File.separator + entry.getName();
                if (!entry.isDirectory()) {
                    extractFile(zipIn, filePath);
                } else {
                    File dirToCreate = new File(filePath);
                    boolean mkdirs = dirToCreate.mkdirs();
                    if (!mkdirs) {
                        log.error("多级文件夹创建失败===>{}",filePath);
                    }

                }
                zipIn.closeEntry();
                entry = zipIn.getNextEntry();
            }
        }
    }

    /**
     * 提取文件
     * @param zipIn ZipInputStream
     * @param filePath 文件路径
     * @throws IOException
     */
    private static void extractFile(ZipInputStream zipIn, String filePath) throws IOException {
        try (FileOutputStream fos = new FileOutputStream(filePath)) {
            byte[] buffer = new byte[1024];
            int bytesRead;
            while ((bytesRead = zipIn.read(buffer)) != -1) {
                fos.write(buffer, 0, bytesRead);
            }
        }
    }
}

2.4 图片文件的压缩

===> 传送门: Thumbnails之上传图片后压缩处理

2.5 oss文件后端上传

===> 传送门1: oss存储对象 文件(视频)上传, 获取回调中的url, 官网地址

===> 传送门2: 后端oss存储(完整版) 及 解决删除本地文件显示被占用问题

2.6 oss文件前端上传

===> 传送门: oss前端文件上传, 优势及后端如何配合

2.7 后端工具测试

⇒ 传送门: Postman,ApiPost, Idea httpclient tools,ApiFox 替代swagger,零侵入 接口文档生成
在这里插入图片描述

3. 本文异常总结

3.1 异常总结

3.1.1 文件解压的时候报错解决

java.lang.IllegalArgumentException: MALFORMED 解决方法

  • 加charset(utf-8) 不行windows换gbk

3.1.2 读取文件 报 无权限访问

两种方法

  • 增加文件夹权限
  • 看看文件路径 是否正确 找没找到想读取的文件

3.2 oss上传异常

===> 传送门: oss报错修改指南

4. 文章总结与预告

4.1 本文总结

注意文件夹路径对应, 解压文件路径, 包括文件路径斜线问题 \\ 和 /
流用完记得关闭 判断是否为空 避免空指针

4.2 下文预告

无预告, 终篇


作者pingzhuyan 感谢观看

更多推荐

基于springboot会员制医疗预约服务管理信息系统springboot017

大家好✌！我是CZ淡陌。一名专注以理论为基础实战为主的技术博主，将再这里为大家分享优质的实战项目，本人在Java毕业设计领域有多年的经验，陆续会更新更多优质的Java实战项目，希望你能有所收获，少走一些弯路，向着优秀程序员前行！🍅更多优质项目👇🏻👇🏻可点击下方获取🍅文章底部或评论区获取🍅Java项目精品实

CodeTON Round 6 (Div. 1 + Div. 2, Rated, Prizes!)

A.MEXanizedArrayAC代码:#include<iostream>#include<algorithm>#include<cstring>usingnamespacestd;constintN=210;inta[N];intn,k,x;voidsolve(){cin>>n>>k>>x;if(x<k-1){c

vue-cli-service build 不同环境的配置

目录🤜背景🤜vue-cli-service介绍🤜环境变量和模式🤜配置不同模式🤜index.html使用环境变量🤜验证🤜参考资料🤜背景在项目部署时，我们需要在测试环境和生产环境使用不同的变量。vue-cli提供了vue-cli-servicebuild打包命令，然而vue-cli-servicebuild

如何安装 Wnmp 并结合内网穿透实现外网访问内网Wnmp 服务

文章目录前言1.Wnmp下载安装2.Wnmp设置3.安装cpolar内网穿透3.1注册账号3.2下载cpolar客户端3.3登录cpolarwebui管理界面3.4创建公网地址4.固定公网地址访问前言WNMP是Windows系统下的绿色Nginx+Mysql+PHP环境集成套件包，安装完成后即可得到一个Nginx+My

APP广告变现策略：如何实现盈利与用户体验的平衡？

如何把握流量变现和用户体验的平衡呢？这是许多APP开发者在商业化进程中都会关心并迫切需要解决的问题。以下是总结的一些方法和策略。一、深入了解用户需求在开发产品或进行商业决策时，我们要始终以用户需求为出发点。通过市场调研、用户调研和数据分析等方式，我们可以深入了解用户的需求和习惯，并以此为基础进行产品设计和优化。二、优化

文案内容千篇一律，软文推广如何加深用户印象

随着互联网技术的发展，企业营销的方式逐渐转向软文推广，但是现在软文推广的内容同质化越来越严重，企业应该如何让自己的软文推广保持差异性，在用户心中留下独特的印象呢？下面就让媒介盒子告诉你。一、&nbsp;找出产品独特卖点市场上同一类型的产品，缺点各有各的不同，但优点大同小异，因此我们需要找出产品独特卖点，将其表现出来，在

能进大厂？阿里云ACE认证到底有多香！

中国云计算火爆的当下，阿里云一枝独秀，市场占有率比排名后5名的总和还要多。在全球的云计算市场上，阿里云也是排名第三，超过谷歌云。这足以说明了市场对于阿里云产品解决方案的需求之大。而阿里云云计算架构师ACE认证是针对云架构师，解决方案架构师，云运维专家等技术人员的阿里云高级别技术认证。该认证体系已被阿里巴巴集团、交付伙伴

安卓恶意应用识别（三）（批量反编译与属性值提取）

前言上篇说到对安卓APK反编译，本篇实现批量反编译和批量特征提取及计算，主要就是通过python代码与cmd进行批量化交互，我在写文章之前，尝试批量下载了安卓apk（大约10来个），发现现在这个应用软件不是一般的大啊，无奈电脑内存不太够，现仅将已下载10个apk作为示例展示。1.批量反编译思路是这样：第一步：调用cmd

一文熟悉Latex论文排版

相信计算机专业或者写过专业论文的同学都知道，使用Office或者WPS来控制论文的格式有多么复杂和繁琐，甚至有时候花在改论文格式上的时间甚至超过了写论文的时间，因此我们急需要使用一种更加专业实用的排版工具来满足我们的论文排版需求，因此，Latex应运而生！1.LaTex概述LaTex是一个专业的排版工具，LaTex在世

窜货采买第三方怎么选择

窜货溯源服务听起来并不难，无非就是买货，但是否能买到货，同时在买到之后能否顺利完成溯源工作，也是非常有学问的，很多品牌会选择第三方服务商进行采买合作，这样可以规避品牌自己操作时的不合规性，因为自查如果不严谨的话，是容易造成“假数据”的，所以类似窜货采买这种涉及较多面的治理动作，与第三方合作会更加正确。要看第三方是否有相

RabbitMQ —— 延迟队列

前言前面荔枝梳理了有关死信队列的知识，延伸过来我们可以借助死信队列来理解延时队列。在实际需求中我们总是不可避免地需要一些定时任务，为了避免大量的计时操作消耗性能，我们常常采用的是延时队列来存储相应的消息，这时候死信队列的特点就出现了，死信队列使用的一个前提就是消息的TTL过期。在这篇文章中，荔枝会梳理延迟队列的相关知识

热文推荐
  1. 九、【漏洞复现】Struts 2 远程代码执行漏洞s2-046（CVE-2017-5638）

    九、【漏洞复现】Struts2远程代码执行漏洞s2-046（CVE-2017-5638）9.1、漏洞原理Struts2是一个基于MVC设计模式的Web应用框架，本质上相当于一个Servlet,在MVC设计模式中，Struts2作为控制器来建立模型与视图进行数据交互。攻击者通过发送恶意构造的HTTP数据包利用该漏洞（通过

  2. vue 把echarts封装成一个方法 并且从后端读取数据 +转换数据格式 =动态echarts 联动echarts表

    1.把echarts在methods封装成一个方法mounted在中调用折线图和柱状图mounted调用下边两个方法mounted(){//最早获取DOM元素的生命周期函数挂载完毕console.log('mounted-id',document.getElementById('charts'))this.line()

  3. Comparator 接口使用方法，结合java8新特性及源码分析

    目录1Comparator介绍1.1函数式声明1.2简单的小案例2.Comparator中的方法2.1compare抽象方法例子2.2comparing方法源码参考解释详细解释<?superT,?extendsU>讲解comparing代码样例例子comparing中的方法源码分析<T,UextendsComparab

  4. 安防视频/视频汇聚平台EasyCVR使用onvif探测添加设备通道详细步骤来啦！

    视频云存储/安防监控EasyCVR视频汇聚平台基于云边端智能协同，支持海量视频的轻量化接入与汇聚、转码与处理、全网智能分发、视频集中存储等。音视频流媒体视频平台EasyCVR拓展性强，视频能力丰富，具体可实现视频监控直播、视频轮播、视频录像、云存储、回放与检索、智能告警、服务器集群、语音对讲、云台控制、电子地图、H.2

  5. Nginx

    概念nginx什么是nginxnginx是一个高性能的HTTP和正、反向代理的服务器nginx可以干什么可以作为web服务器，可以实现反向代理，可以实现基于反向代理的负载均衡，可以作为静态资源服务器(类似于七牛云)什么时候使用nginx后台搭建集群的时候，访问量较大，使用使用nginx作为静态资源的web服务器-部署前

  6. vue3 自定义Hooks

    文章目录前言一、Hooks是什么？二、图片转换Base641.Hooks2.使用三、监听元素宽高（自定义指令+Hooks）1.Hooks2.使用总结前言本文主要记录了vue3学习中自定义Hooks和vue2中Mixins的使用与案例。一、Hooks是什么？Hooks用来处理复用代码逻辑的一些封装，Hooks与Mixin

  7. Python+selenium自动化生成测试报告

    批量执行完用例后，生成的测试报告是文本形式的，不够直观，为了更好的展示测试报告，最好是生成HTML格式的。unittest里面是不能生成html格式报告的，需要导入一个第三方的模块：HTMLTestRunner一、导入HTMLTestRunner1.这个模块下载不能通过pip安装了，只能下载后手动导入，下载地址：htt

  8. 使用Java中SSM技术写项目具体操作流程

    确定需求和技术选型首先需要明确项目的功能需求，以及选择合适的技术框架和库。在SSM框架中，Spring框架负责管理Java对象，提供依赖注入和面向切面编程的功能；SpringMVC框架负责处理请求和响应，实现MVC架构；MyBatis框架负责ORM（对象关系映射），简化数据库操作。创建SpringMVC工程使用Mave

  9. 算法与设计分析--分治算法的设计与分析

    某不知名学校的第二次算法实验报告，一共四道题全部来自力扣第一题​​​​​​169.多数元素题目描述：给定一个大小为n的数组，找到其中的多数元素。多数元素是指在数组中出现次数大于⌊n/2⌋的元素。你可以假设数组是非空的，并且给定的数组总是存在多数元素。示例1:输入:[3,2,3]输出:3示例2:输入:[2,2,1,1,1