java上传rar文件_java实现上传zip/rar压缩文件,自动解压

在pom中添加解压jar依赖

4.0.0

org.springframework.boot

spring-boot-starter-parent

2.1.2.RELEASE

com.hf

uncompress

0.0.1-SNAPSHOT

uncompress

上传压缩文件(rar或者zip格式),解压

1.8

org.springframework.boot

spring-boot-starter-web

org.projectlombok

lombok

true

org.springframework.boot

spring-boot-starter-test

test

org.springframework.boot

spring-boot-starter-thymeleaf

net.lingala.zip4j

zip4j

1.3.2

com.github.junrar

junrar

0.7

org.springframework.boot

spring-boot-maven-plugin

解压zip/rar的工具类

package com.hf.uncompress.utils;

import com.github.junrar.Archive;

import com.github.junrar.rarfile.FileHeader;

import lombok.extern.slf4j.Slf4j;

import net.lingala.zip4j.core.ZipFile;

import java.io.File;

import java.io.FileOutputStream;

/**

* @Description: 解压rar/zip工具类

* @Date: 2019/1/22

* @Auther:

*/

@Slf4j

public class UnPackeUtil {

/**

* zip文件解压

*

* @param destPath 解压文件路径

* @param zipFile 压缩文件

* @param password 解压密码(如果有)

*/

public static void unPackZip(File zipFile, String password, String destPath) {

try {

ZipFile zip = new ZipFile(zipFile);

/*zip4j默认用GBK编码去解压,这里设置编码为GBK的*/

zip.setFileNameCharset("GBK");

log.info("begin unpack zip file....");

zip.extractAll(destPath);

// 如果解压需要密码

if (zip.isEncrypted()) {

zip.setPassword(password);

}

} catch (Exception e) {

log.error("unPack zip file to " + destPath + " fail ....", e.getMessage(), e);

}

}

/**

* rar文件解压(不支持有密码的压缩包)

*

* @param rarFile rar压缩包

* @param destPath 解压保存路径

*/

public static void unPackRar(File rarFile, String destPath) {

try (Archive archive = new Archive(rarFile)) {

if (null != archive) {

FileHeader fileHeader = archive.nextFileHeader();

File file = null;

while (null != fileHeader) {

// 防止文件名中文乱码问题的处理

String fileName = fileHeader.getFileNameW().isEmpty() ? fileHeader.getFileNameString() : fileHeader.getFileNameW();

if (fileHeader.isDirectory()) {

//是文件夹

file = new File(destPath + File.separator + fileName);

file.mkdirs();

} else {

//不是文件夹

file = new File(destPath + File.separator + fileName.trim());

if (!file.exists()) {

if (!file.getParentFile().exists()) {

// 相对路径可能多级，可能需要创建父目录.

file.getParentFile().mkdirs();

}

file.createNewFile();

}

FileOutputStream os = new FileOutputStream(file);

archive.extractFile(fileHeader, os);

os.close();

}

fileHeader = archive.nextFileHeader();

}

}

} catch (Exception e) {

log.error("unpack rar file fail....", e.getMessage(), e);

}

}

}

页面HTML

Title

上传压缩包:

解压路径:

解压密码(为空可不传):

controller代码:

package com.hf.uncompress.controller;

import com.hf.uncompress.Result.AjaxList;

import com.hf.uncompress.service.FileUploadService;

import com.hf.uncompress.vo.PackParam;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.*;

import org.springframework.web.multipart.MultipartFile;

/**

* @Description:

* @Date: 2019/1/22

* @Auther:

*/

@Controller

@RequestMapping("/user")

@Slf4j

public class FileUploadController {

@Autowired

private FileUploadService fileUploadService;

@GetMapping("/redirect")

public String redirectHtml() {

return "work";

}

@PostMapping("/upload/zip")

@ResponseBody

public String uploadZip(MultipartFile zipFile, @RequestBody PackParam packParam) {

AjaxListajaxList = fileUploadService.handlerUpload(zipFile, packParam);

return ajaxList.getData();

}

}

service实现类代码

package com.hf.uncompress.service.impl;

import com.hf.uncompress.Result.AjaxList;

import com.hf.uncompress.enums.FileTypeEnum;

import com.hf.uncompress.service.FileUploadService;

import com.hf.uncompress.utils.UnPackeUtil;

import com.hf.uncompress.vo.PackParam;

import lombok.extern.slf4j.Slf4j;

import org.springframework.stereotype.Service;

import org.springframework.web.multipart.MultipartFile;

import java.io.File;

import java.io.IOException;

/**

* @Description:

* @Date: 2019/1/22

* @Auther:

*/

@Service

@Slf4j

public class FileUploadServiceImpl implements FileUploadService {

@Override

public AjaxListhandlerUpload(MultipartFile zipFile, PackParam packParam) {

if (null == zipFile) {

return AjaxList.createFail("请上传压缩文件!");

}

boolean isZipPack = true;

String fileContentType = zipFile.getContentType();

//将压缩包保存在指定路径

String packFilePath = packParam.getDestPath() + File.separator + zipFile.getName();

if (FileTypeEnum.FILE_TYPE_ZIP.type.equals(fileContentType)) {

//zip解压缩处理

packFilePath += FileTypeEnum.FILE_TYPE_ZIP.fileStufix;

} else if (FileTypeEnum.FILE_TYPE_RAR.type.equals(fileContentType)) {

//rar解压缩处理

packFilePath += FileTypeEnum.FILE_TYPE_RAR.fileStufix;

isZipPack = false;

} else {

return AjaxList.createFail("上传的压缩包格式不正确,仅支持rar和zip压缩文件!");

}

File file = new File(packFilePath);

try {

zipFile.transferTo(file);

} catch (IOException e) {

log.error("zip file save to " + packParam.getDestPath() + " error", e.getMessage(), e);

return AjaxList.createFail("保存压缩文件到:" + packParam.getDestPath() + " 失败!");

}

if (isZipPack) {

//zip压缩包

UnPackeUtil.unPackZip(file, packParam.getPassword(), packParam.getDestPath());

} else {

//rar压缩包

UnPackeUtil.unPackRar(file, packParam.getDestPath());

}

return AjaxList.createSuccess("解压成功");

}

}

使用到的枚举类:

package com.hf.uncompress.enums;

import lombok.AllArgsConstructor;

import lombok.NoArgsConstructor;

/**

* @Description: 压缩文件类型

* @Date: 2019/1/22

* @Auther:

*/

@AllArgsConstructor

@NoArgsConstructor

public enum FileTypeEnum {

FILE_TYPE_ZIP("application/zip", ".zip"),

FILE_TYPE_RAR("application/octet-stream", ".rar");

public String type;

public String fileStufix;

public static String getFileStufix(String type) {

for (FileTypeEnum orderTypeEnum : FileTypeEnum.values()) {

if (orderTypeEnum.type.equals(type)) {

return orderTypeEnum.fileStufix;

}

}

return null;

}

}

同一返回值定义:

package com.hf.uncompress.Result;

import lombok.AllArgsConstructor;

import lombok.Data;

import lombok.NoArgsConstructor;

/**

* @Description: 返回值处理

* @Date: 2019/1/22

* @Auther:

*/

@AllArgsConstructor

@NoArgsConstructor

@Data

public class AjaxList{

private boolean isSuccess;

private T data;

public static AjaxListcreateSuccess(T data) {

return new AjaxList(true, data);

}

public static AjaxListcreateFail(T data) {

return new AjaxList(false, data);

}

}

前端上传封装的vo

package com.hf.uncompress.vo;

import lombok.Data;

/**

* @Description: 上传压缩的参数

* @Date: 2019/1/23

* @Auther:

*/

@Data

public class PackParam {

/**

* 解压密码

*/

private String password;

/**

* 解压文件存储地址

*/

private String destPath;

}

在application.properties中定义其上传的阀域

#设置上传单个文件的大小限制

spring.servlet.multipart.max-file-size=500MB

# 上传文件总的最大值

spring.servlet.multipart.max-request-size=500MB

spring.thymeleaf.cache=false

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/452761.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

从MapReduce的执行来看如何优化MaxCompute（原ODPS） SQL

从MapReduce的执行来看如何优化MaxCompute（原ODPS） SQL

摘要： SQL基础有这些操作（按照执行顺序来排列）： from join(left join, right join, inner join, outer join ,semi join) where group by select sum distinct count order by 如果我们能理解mapreduce是怎么实现这些SQL中的基本操…
阅读更多...
套接字（socket）基本知识与工作原理

套接字（socket）基本知识与工作原理

套接字（socket）基本知识与工作原理 一、Socket相关概念 Socket通常也称作“套接字”，用于描述IP地址和端口，是一个通信链的句柄。（其实就是两个程序通信用的。） SOCKET用于在两个基于TCP/IP协议的应用程序之…
阅读更多...
python 多线程--重点知识

python 多线程--重点知识

1.全局变量global的用法 2.多线程共享全局变量-args参数 注意args参数类型为元组，逗号不能少！
阅读更多...
Flask WTForm表单的使用

Flask WTForm表单的使用

运行环境： python2.7 flask 0.11 flask-wtf 0.14.2 wtform能够通过一个类定义一些字段，这些字段会在前端生成标签，并且通过设置字段的验证规则，自动判断前端输入数据的格式。 一般用于用户登录，用户注册等信息录入。…
阅读更多...
Java与C#个人之比较

Java与C#个人之比较

网上这方面的比较文章已经有不少了，不过大都是要么从很高的角度说的，要么就是从底层说的，本人就以自己这几年的编程经历中的感受，来谈谈自己的体会。 相似性： Java和C#都是一门面向对象的语言，Java更多地…
阅读更多...
java利用子类求正方形_Java程序设计实验2011

java利用子类求正方形_Java程序设计实验2011

(2)掌握对象的声明和使用；(3)掌握构造方法的概念和使用；(4)掌握类及成员的访问控制符。2、实验任务(1)阅读下面的程序，在main()方法里添加语句完成如下的功能：①创建一个MyV alue类的对象myV alue。②为myV alue对象中的value域赋…
阅读更多...
当导用模块与包的import与from的问题（模块与包的调用）

当导用模块与包的import与from的问题（模块与包的调用）

当在views.py里写impor models会不会报错呢？ 1、Python里面的py文件都是每一行的代码。2、Python解释器去找一个模块的时候，只去sys.path的路径里找3、django项目启动（django项目的启动文件是manage.py）启动项目是将manage.py的路…
阅读更多...
ack和seq

ack和seq

ACK (Acknowledgement），即确认字符，在数据通信中，接收站发给发送站的一种传输类控制字符。表示发来的数据已确认接收无误。 seq是序列号，这是为了连接以后传送数据用的，ack是对收到的数据包的确认&#xff…
阅读更多...
MySQL中的information_schema

MySQL中的information_schema

0.引言 近日在学习网络安全的sql注入时，用到mysql中的information_schema数据库，其思路是利用information_schema中的SCHEMA获取数据库中的table名称。现在对相关数据库进行总结，方便以后复习使用。 2.information_schema数据库 informati…
阅读更多...
linux配置防火墙，开启端口

linux配置防火墙，开启端口

linux配置防火墙，开启端口 Centos7,配置防火墙，开启端口　　1.查看已开放的端口(默认不开放任何端口)　　　　firewall-cmd --list-ports　　2.开启80端口　　　　firewall-cmd --zonepublic(作用域) --add-port80/tcp(端口和访问类型) --permanent(永久…
阅读更多...
使用Intel编译器系列合集

使用Intel编译器系列合集

好的帖子：http://topic.csdn.net/u/20080327/16/071b45df-3795-4bf1-9c4d-da4eb5aaa739.html参考手册：http://software.intel.com/sites/products/documentation/studio/composer/en-us/2011Update/compiler_c/index.htm 说明：本系列文章为个…
阅读更多...
【前端】这可能是你看过最全的css居中解决方案了~

【前端】这可能是你看过最全的css居中解决方案了~

1.水平居中&#xff1a;行内元素解决方案 适用元素&#xff1a;文字&#xff0c;链接&#xff0c;及其其它inline或者inline-*类型元素&#xff08;inline-block&#xff0c;inline-table&#xff0c;inline-flex&#xff09; html部分代码:<div>文字元素</div><…
阅读更多...
java手机一款三国游戏_JAVA热游—富甲三国之雄霸天下原创心得

java手机一款三国游戏_JAVA热游—富甲三国之雄霸天下原创心得

因为工作忙碌的关系&#xff0c;很长时间都没有来关注手机游戏论坛&#xff0c;这款富甲三国.雄霸天下&#xff0c;我也是前天才拿到手。游戏比想象中的简单&#xff0c;个人仅用了两个小时时间&#xff0c;就将三个人物全部通关。游戏的开始画面制作得比较精美&#xff0c;而且…
阅读更多...
Python多线程--互斥锁、死锁

Python多线程--互斥锁、死锁

1、互斥锁 为解决资源抢夺问题&#xff0c;使用mutex Threading.Lock()创建锁&#xff0c;使用mutex.acquire()锁定&#xff0c;使用mutex.release()释放锁。 代码一&#xff1a; import threading import time# 定义一个全局变量 g_num 0def test1(num):global g_num# 上锁…
阅读更多...
acc dr cr

acc dr cr

阅读更多...
freemind 要下载java_Freemind

freemind 要下载java_Freemind

动手编辑先按Ctrln&#xff0c;新建一个文件。这时出现了一个根节点。用光标单击它&#xff0c;改成“我学FreeMind”&#xff0c;然后在节点之外任一地方点击鼠标(或按Enter)完成编辑。然后&#xff0c;按Insert键&#xff0c;输入“下载安装”&#xff0c;按Enter键&#xff…
阅读更多...
本地连不上远程mysql数据库(2)

本地连不上远程mysql数据库(2)

Host is not allowed to connect to this MySQL server解决方法 今天在ubuntu上面装完MySQL&#xff0c;却发现在本地登录可以&#xff0c;但是远程登录却报错Host is not allowed to connect to this MySQL server,找了半天试了网上的一些方法都没有解决&#xff0c;最终在一篇…
阅读更多...
理解EnterCriticalSection 临界区

理解EnterCriticalSection 临界区

通俗解释就像上厕所&#xff1a; 门锁了&#xff0c;就等着&#xff0c;等到别人出来了&#xff0c;进去锁上&#xff0c;然后该干什么干什么&#xff0c;干完了&#xff0c;把门打开 门没锁&#xff0c;就进去&#xff0c;锁上&#xff0c;然后该干什么干什么&#xff0c;干…
阅读更多...
Python多线程--UDP聊天器

Python多线程--UDP聊天器

import socket import threadingdef recv_msg(udp_socket):"""接收数据并显示"""# 接收数据while True:recv_data udp_socket.recvfrom(1024)print(recv_data)def send_msg(udp_socket, dest_ip, dest_port):"""发送数据"&…
阅读更多...
mvc:default-servlet-handler/作用

mvc:default-servlet-handler/作用

<mvc:default-servlet-handler/>使用默认的servlet来相应静态文件&#xff0c;因为在web.xml中使用了DispatcherServlet截获所有的请求url&#xff0c;而引入<scprit type"text/javascript" src"js/jquery-1.11.0.mim.js"/>的时候&#xff0c;…
阅读更多...
最新文章

Copyright @ 2022~2023