zip4j实现多线程压缩

使用的jar包：zip4j_1.3.2.jar
基本功能：
针对ZIP压缩文件创建、添加、分卷、更新和移除文件
(读写有密码保护的Zip文件)
(支持AES 128/256算法加密)
(支持标准Zip算法加密)
(支持zip64格式)
(支持Store(仅打包，默认不压缩，不过可以手动设置大小)和Deflate压缩方法
(针对分块zip文件创建和抽出文件)
(支持编码)
(进度监控)
压缩方式(3种):
static final int COMP_STORE = 0;（仅打包，不压缩） （对应好压的存储）
static final int COMP_DEFLATE = 8;（默认） （对应好压的标准）
static final int COMP_AES_ENC = 99;

压缩级别有5种：（默认0不压缩）级别跟好压软件是对应的；
static final int DEFLATE_LEVEL_FASTEST = 1;
static final int DEFLATE_LEVEL_FAST = 3;
static final int DEFLATE_LEVEL_NORMAL = 5;
static final int DEFLATE_LEVEL_MAXIMUM = 7;
static final int DEFLATE_LEVEL_ULTRA = 9;
加密方式：
static final int ENC_NO_ENCRYPTION = -1;（默认,没有加密方法，如果采用此字段，会报错”没有提供加密算法”）
static final int ENC_METHOD_STANDARD = 0;
static final int ENC_METHOD_AES = 99;
AES Key Strength：
(默认-1，也就是ENC_NO_ENCRYPTION)
static final int AES_STRENGTH_128 = 0x01;
static final int AES_STRENGTH_192 = 0x02;
static final int AES_STRENGTH_256 = 0x03;

从构造方法可以默认情况：
compressionMethod = Zip4jConstants.COMP_DEFLATE;
encryptFiles = false;//不设密码
readHiddenFiles = true;//可见
encryptionMethod = Zip4jConstants.ENC_NO_ENCRYPTION;//加密方式不加密
aesKeyStrength = -1;//
includeRootFolder = true;//
timeZone = TimeZone.getDefault();//

*** 情景教学压缩操作类*/
public class CompressHandler extends Thread {private Logger logger = Logger.getLogger(CompressHandler.class);/*** 存储目录名和对应目录下的文件地址*/private Map<String, List<ResourceInfo>> resourceMap;/*** 压缩类中的配置文件*/private String configJson;/*** 配置文件map key为压缩包中的文件名,value为文件内容*/Map<String, String> configJsonMap;/*** 回调接口*/private ZipOperate zipOperate;/*** 加密标志*/private boolean encrypt = false;/*** 线程名称*/private String threadName = Thread.currentThread().getName();/*** 取消标志*/private boolean cancelFlag;public CompressHandler() {}public CompressHandler(Map<String, List<ResourceInfo>> resourceMap, Map<String, String> configJsonMap, ZipOperate zipOperate) {this(resourceMap, configJsonMap, zipOperate, false);}public CompressHandler(Map<String, List<ResourceInfo>> resourceMap, Map<String, String> configJsonMap, ZipOperate zipOperate, boolean encrypt) {this.resourceMap = resourceMap;this.configJsonMap = configJsonMap;this.zipOperate = zipOperate;this.encrypt = encrypt;}public CompressHandler(Map<String, List<ResourceInfo>> resourceMap, String configJson, ZipOperate zipOperate) {this(resourceMap, configJson, zipOperate, false);}public CompressHandler(Map<String, List<ResourceInfo>> resourceMap, String configJson, ZipOperate zipOperate, boolean encrypt) {this.resourceMap = resourceMap;this.configJson = configJson;this.zipOperate = zipOperate;this.encrypt = encrypt;}@Overridepublic void run() {if (zipOperate != null) {zipOperate.beforeCompress();}String fileName = UUID.randomUUID().toString().replace("-", "").concat(".zip");String tempDir = SuperdiamondConfig.getConfig(SuperdiamondConfig.SYSTEM_TMMP_FILE_PATH);File tempDirFile = new File(tempDir);if (!tempDirFile.exists()) {tempDirFile.mkdir();}String filePath = tempDir.concat("/").concat(fileName);//存储生成本地压缩包的文件List<File> encryptFileList = new ArrayList<>();try {ZipFile zipFile = new ZipFile(filePath);logger.info("线程" + threadName + "  开始压缩，压缩的文件名为:" + fileName);long startTime = System.currentTimeMillis();logger.info("线程" + threadName + "  开始时间为：" + startTime);ZipParameters parameters = new ZipParameters();//设置压缩方式和压缩级别
            parameters.setCompressionMethod(Zip4jConstants.COMP_DEFLATE);parameters.setCompressionLevel(Zip4jConstants.DEFLATE_LEVEL_NORMAL);//当开启压缩包密码加密时boolean dirEncrypt = false;if (encrypt || Boolean.parseBoolean(SuperdiamondConfig.getConfig(SuperdiamondConfig.ENABLE_ENCRYPT_ZIP))) {logger.info("线程" + threadName + "  该压缩包需要加密");addEncryptParameters(parameters);dirEncrypt = true;}for (String dir : resourceMap.keySet()) {logger.info("线程" + threadName + "  添加目录：" + dir);List<ResourceInfo> resourceInfoList = resourceMap.get(dir);for (ResourceInfo resourceInfo : resourceInfoList) {String resourceFileName = resourceInfo.getFileName();logger.info("线程" + threadName + "  添加文件：" + resourceFileName);/*** 20180921判断目录名是否为空字符串 true不创建目录 by lizhang10*/if(StringUtils.isNotEmpty(dir)){parameters.setFileNameInZip(dir + "/" + resourceFileName);}else{parameters.setFileNameInZip(resourceFileName);}parameters.setSourceExternalStream(true);InputStream inputStream = resourceInfo.getInputStream();if (inputStream == null) {//获取文件流String fileUrl = resourceInfo.getFileUrl();long startTime1 = System.currentTimeMillis();logger.info("线程" + threadName + "  开始获取文件流,地址:" + fileUrl + "  开始时间:" + startTime1);inputStream = getInputStream(fileUrl);long endTime1 = System.currentTimeMillis();logger.info("线程" + threadName + "  结束获取文件流,地址:" + fileUrl + "  结束时间:" + endTime1 + "  耗时毫秒: " + (endTime1 - startTime1));}//当压缩包没有加密时，则从文件属性中取是否进行加密if(!dirEncrypt && resourceInfo.isEncrypt()){//如果是zip的话,则对文件进行解压，然后再加密if(resourceFileName.endsWith(".zip")){long saveStartTime = System.currentTimeMillis();//网络文件路径String sourceFileName = tempDir.concat("/").concat(UUID.randomUUID().toString().concat(".zip"));logger.info("线程" + threadName + " 该文件["+resourceFileName+"]是zip且需要加密，开始存到本地,路径为:"+sourceFileName+"开始时间:" + saveStartTime);//加密文件路径String encryptFileName = tempDir.concat("/").concat(UUID.randomUUID().toString().concat(".zip"));File file = new File(sourceFileName);FileOutputStream outputStream = new FileOutputStream(file);byte[] buffer = new byte[8*1024];int len = 0;while ((len = inputStream.read(buffer)) != -1){outputStream.write(buffer,0,len);}outputStream.close();inputStream.close();long saveEndTime = System.currentTimeMillis();logger.info("线程" + threadName + " 该文件是zip，存到本地完成,结束时间:" + saveEndTime + "  耗时:"+(saveEndTime - saveStartTime));long extractStartTime = System.currentTimeMillis();logger.info("线程" + threadName + " ,开始进行解压加密,开始时间为:" + extractStartTime);ZipFile sourceZipFile = new ZipFile(file);String extractDir = tempDir.concat("/").concat(UUID.randomUUID().toString());sourceZipFile.extractAll(extractDir);long extractEndTime = System.currentTimeMillis();ZipFile encryptZipFile = new ZipFile(encryptFileName);ZipParameters parameters2 = new ZipParameters();//设置压缩方式和压缩级别
                            parameters2.setCompressionMethod(Zip4jConstants.COMP_DEFLATE);parameters2.setCompressionLevel(Zip4jConstants.DEFLATE_LEVEL_NORMAL);addEncryptParameters(parameters2);//添加获取文件的文件和目录File[] fileArray = new File(extractDir).listFiles();for (File file1 : fileArray) {if(file1.isDirectory()){encryptZipFile.addFolder(file1,parameters2);} else {encryptZipFile.addFile(file1,parameters2);}}if(!StringUtils.isEmpty(resourceInfo.getConfigJson())){parameters2.setFileNameInZip("config.json");parameters2.setSourceExternalStream(true);encryptZipFile.addStream(new ByteArrayInputStream(resourceInfo.getConfigJson().getBytes("utf8")),parameters2);}logger.info("线程" + threadName + " ,完成解压加密,结束时间为:" + extractEndTime + " 耗时: " + (extractEndTime-extractStartTime));//删除文件
                            sourceZipFile.getFile().delete();//删除目录下的文件deleteFolder(new File(extractDir));File encryptFile = encryptZipFile.getFile();inputStream = new FileInputStream(encryptFile);encryptFileList.add(encryptFile);}}//获取需要打包的文件流
                    zipFile.addStream(inputStream, parameters);inputStream.close();}}parameters.setSourceExternalStream(true);//如果configJsonMap不为空,且length不为0,则遍历加入到压缩包中if (configJsonMap != null && configJsonMap.size() > 0) {for (String resourceName : configJsonMap.keySet()) {logger.info("线程" + threadName + " 添加配置文件" + resourceName);parameters.setFileNameInZip(resourceName);String value = configJsonMap.get(resourceName);zipFile.addStream(new ByteArrayInputStream(value.getBytes("utf8")), parameters);}}if (!StringUtils.isEmpty(configJson)) {logger.info("线程" + threadName + "  添加文件config.json");parameters.setFileNameInZip("config.json");zipFile.addStream(new ByteArrayInputStream(configJson.getBytes("utf8")), parameters);}logger.info("线程" + threadName + "  压缩文件" + fileName + "完成");long endTime = System.currentTimeMillis();logger.info("线程" + threadName + "  结束时间为:" + endTime + "  耗时毫秒：" + (endTime - startTime));long startTime2 = System.currentTimeMillis();logger.info("线程" + threadName + "  开始将压缩包上传到文件服务.......开始时间:" + startTime2);FileInfo fileInfo = new CystrageUtil().uploadToRemoteServer(fileName, filePath, null);long endTime2 = System.currentTimeMillis();logger.info("线程" + threadName + "  上传完成.......结束时间:" + endTime2 + "耗时毫秒:  " + (endTime2 - startTime2));if (cancelFlag){throw new InterruptedException("线程" + threadName + "  取消压缩");}//如果传入了后续操作接口，则将文件服务返回的类传入if (zipOperate != null) {zipOperate.afterCompress(fileInfo, zipFile);zipFile.getFile().delete();}} catch (Exception e) {logger.error("线程" + threadName + "  文件压缩出错...........文件内容:" + configJson, e);if (zipOperate != null) {zipOperate.errorCompress();}//删除对应压缩包new File(filePath).delete();} finally {try {//关流
                inputStream.close();} catch (IOException e) {inputStream = null;}//删除本地生成的压缩文件//存储生成本地压缩包的文件for (File file : encryptFileList) {file.delete();}}}/*** 删除文件夹下的所有文件* @param sourceDir*/private void deleteFolder(File sourceDir) {if(sourceDir.isDirectory()){File[] files = sourceDir.listFiles();for (File file : files) {deleteFolder(file);}} else {sourceDir.delete();}sourceDir.delete();}private void addEncryptParameters(ZipParameters parameters) {String password = SuperdiamondConfig.getConfig(SuperdiamondConfig.ZIP_COMPRESS_PASSWORD);parameters.setEncryptFiles(true);parameters.setEncryptionMethod(Zip4jConstants.ENC_METHOD_AES);parameters.setAesKeyStrength(Zip4jConstants.AES_STRENGTH_256);parameters.setPassword(password.toCharArray());}/*** 获取输入流** @param fileUrl* @return*/InputStream inputStream;private InputStream getInputStream(String fileUrl) throws Exception {if(cancelFlag){throw new InterruptedException("线程" + threadName + "  取消压缩");}int retry = 1;while (retry <= 3) {try {int index = fileUrl.lastIndexOf("/");String prefix = fileUrl.substring(0, index + 1);String fileName = fileUrl.substring(index + 1);URL url = new URL(prefix + URLEncoder.encode(fileName, "utf8"));URLConnection connection = url.openConnection();connection.setDoInput(true);inputStream = connection.getInputStream();return inputStream;} catch (Exception e) {if (retry == 1) {logger.error("线程" + threadName + "  获取文件出错,文件地址:" + fileUrl, e);}logger.error("开始重试第" + retry + "次");//由于测试环境服务器承载能力比较差，当获取失败后，睡眠一段时间再重试if(Boolean.parseBoolean(SuperdiamondConfig.getConfig(SuperdiamondConfig.SYSTEM_TEST_ENVIRONMENT))){Thread.currentThread().sleep(Long.parseLong(SuperdiamondConfig.getConfig(SuperdiamondConfig.SYSTEM_SLEEP_TIME)));}if (retry == 3) {throw new Exception(e);}retry++;}}return null;}public void setCancelFlag(Boolean cancelFlag){this.cancelFlag = cancelFlag;}@Overridepublic void interrupt() {if (inputStream != null) {try {inputStream.close();} catch (IOException e) {inputStream = null;logger.info("线程" + threadName + "  关闭io流失败");}}super.interrupt();}public static class ResourceInfo {/*** 文件名称*/private String fileName;/*** 文件地址*/private String fileUrl;/*** 输入流*/private InputStream inputStream;/*** 是否要为当前文件添加config,json*/private String configJson;/*** 改文件是否加密*/private boolean encrypt;public InputStream getInputStream() {return inputStream;}public void setInputStream(InputStream inputStream) {this.inputStream = inputStream;}public String getFileName() {return fileName;}public void setFileName(String fileName) {this.fileName = fileName;}public String getFileUrl() {return fileUrl;}public void setFileUrl(String fileUrl) {this.fileUrl = fileUrl;}public boolean isEncrypt() {return encrypt;}public void setEncrypt(boolean encrypt) {this.encrypt = encrypt;}public String getConfigJson() {return configJson;}public void setConfigJson(String configJson) {this.configJson = configJson;}}
}

 

转载于:https://www.cnblogs.com/AnonymouL/p/9700368.html

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

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

相关文章

非三星手机无法登录三星账号_如何解决所有三星手机的烦恼

非三星手机无法登录三星账号_如何解决所有三星手机的烦恼

非三星手机无法登录三星账号Samsung is the biggest manufacturer of Android phones in the world, but that doesn’t mean these handsets are perfect out of the box. In fact, most of these phones have several annoyances initially—here’s how to fix many of thes…
阅读更多...
设置单元格填充方式_单元格的选择及设置单元格格式

设置单元格填充方式_单元格的选择及设置单元格格式

数据输入完毕&#xff0c;接下来可以设置字体、对齐方式、添加边框和底纹等方式设置单元格格式&#xff0c;从而美化工作表。要对单元格进行设置&#xff0c;首先要选中单元格。选择单元格选择单元格是指在工作表中确定活动单元格以便在单元格中进行输入、修改、设置和删除等操…
阅读更多...
Recover Binary Search Tree

Recover Binary Search Tree

Two elements of a binary search tree (BST) are swapped by mistake. Recover the tree without changing its structure. Note: A solution using O(n) space is pretty straight forward. Could you devise a constant space solution? 要求找到BST中放错位置的两个节点. …
阅读更多...
springboot三种过滤功能的使用与比较

springboot三种过滤功能的使用与比较

若要实现对请求的过滤&#xff0c;有三种方式可供选择&#xff1a;filter、interceptort和aop。本文主要讨论三种拦截器的使用场景与使用方式。 下文中的举例功能是计算每个请求的从开始到结束的时间&#xff0c;例子来源是慕课网。 一、filter 特点&#xff1a;可以获取原始的…
阅读更多...
后缀的形容词_构词法（18）构成形容词的常见后缀 3

后缀的形容词_构词法（18）构成形容词的常见后缀 3

即时练习一、按要求改写下列单词。1. Japan →___________ adj. 日本(人)的2. Canton →_________ adj. 广东(人)的3. Vietnam →__________ adj. 越南(人)的4. Europe →__________ adj. 欧洲(人)的5. India → ________ adj. 印度(人)的6. Africa →_______ adj. 非洲(人)的7…
阅读更多...
CentOS 桌面启动无登录界面

CentOS 桌面启动无登录界面

最近VMWare下搞了2个CentOS 32bit虚拟机, 装了些软件之后&#xff0c;都遇到开机无法显示登录界面&#xff0c; 仅能看见桌面背景图的情况。 以下是我搜索很久汇总的方法。 尝试按 ctrl alt F3(快捷键可能有所不同), 由桌面模式进入命令行模式。 直接 startx 报错&#xf…
阅读更多...
批量删除推文_如何搜索（和删除）您的旧推文

批量删除推文_如何搜索（和删除）您的旧推文

批量删除推文“The internet never forgets” is an aphorism that isn’t entirely true, but it’s worth thinking about whenever you post to social media. If you think your Twitter profile needs a bit of a scrub, here’s how to search and delete those old twee…
阅读更多...
[USACO13JAN] Cow Lineup (单调队列,尺取法)

[USACO13JAN] Cow Lineup (单调队列,尺取法)

题目链接 Solution 尺取法板子,算是复习一波. 题中说最多删除 \(k\) 种,那么其实就是找一个颜色种类最多为 \(k1\) 的区间; 统计一下其中最多的颜色出现次数. 然后直接尺取法,然后每次对于 \(col[r]\) 进行统计,时间复杂度 \(O(n)\) . Code #include<bits/stdc.h> using …
阅读更多...
智能记忆功能nest_如何设置和安装Nest Protect智能烟雾报警器

智能记忆功能nest_如何设置和安装Nest Protect智能烟雾报警器

智能记忆功能nestIf you want to add a bit more convenience and safety to your home’s smoke alarm setup, the Nest Protect comes with a handful of great features to make that a reality. Here’s how to set it up and what all you can do with it. 如果您想为您的…
阅读更多...
网格自适应_ANSYS 非线性自适应（NLAD）网格划分及应用举例

网格自适应_ANSYS 非线性自适应（NLAD）网格划分及应用举例

文章来源&#xff1a;安世亚太官方订阅号&#xff08;搜索&#xff1a;Peraglobal&#xff09;在复杂的结构设计分析中&#xff0c;通常很难确定在高应力区域中是否生成适当的细化网格。在做非线性大应变分析仿真时&#xff0c;可能由于单元变形过大&#xff0c;导致网格畸变&a…
阅读更多...
js继承优化

js继承优化

在看《js设计模式》中&#xff0c;作者提到了js中的两种继承方式&#xff1a;类继承 或 原型继承&#xff0c;或许是本人才疏学浅&#xff0c;竟发现一些问题。 一、类继承 思路&#xff1a;作者的思路是使用基于类来继承&#xff0c;并且做了一个extend函数&#xff0c;在第一…
阅读更多...
python---[列表]lsit

python---[列表]lsit

内置数据结构&#xff08;变量类型&#xff09; -list -set -dict -tuple -list&#xff08;列表&#xff09; -一组又顺序的数据组合 -创建列表 -空列表 list1 []　　　　　　　　print(type(list1))　　　　　　　　print(list1)　　　　　　　　list2 [100]　　　　　　　…
阅读更多...
唤醒计算机运行此任务_如何停止Windows 8唤醒计算机以运行维护

唤醒计算机运行此任务_如何停止Windows 8唤醒计算机以运行维护

唤醒计算机运行此任务Windows 8 comes with a new hybrid boot system, this means that your PC is never really off. It also means that Windows has the permission to wake your PC as it needs. Here’s how to stop it from waking up your PC to do maintenance tasks…
阅读更多...
转整型_SPI转can芯片CSM300详解、Linux驱动移植调试笔记

转整型_SPI转can芯片CSM300详解、Linux驱动移植调试笔记

一口君最近移植了一款SPI转CAN的芯片CSM300A&#xff0c;在这里和大家做个分享。一、CSM300概述CSM300(A)系列是一款可以支持 SPI / UART 接口的CAN模块。1. 简介CSM300(A)系列隔离 SPI / UART 转 CAN 模块是集成微处理器、 CAN 收发器、 DC-DC 隔离电源、 信号隔离于一体的通信…
阅读更多...
matlab练习程序（二值图像连通区域标记法，一步法）

matlab练习程序（二值图像连通区域标记法，一步法）

这个只需要遍历一次图像就能够完全标记了。我主要参考了WIKI和这位兄弟的博客&#xff0c;这两个把原理基本上该介绍的都介绍过了&#xff0c;我也不多说什么了。一步法代码相比两步法真是清晰又好看&#xff0c;似乎真的比两步法要好很多。 代码如下&#xff1a; clear all; c…
阅读更多...
pc微信不支持flash_在出售PC之前，如何取消对Flash内容的授权

pc微信不支持flash_在出售PC之前，如何取消对Flash内容的授权

pc微信不支持flashWhen it comes to selling your old digital equipment you usually should wipe it of all digital traces with something like DBAN, however if you can’t there are some precautions you should take–here’s one related to Flash content you may h…
阅读更多...
博客在线——Wireshark基本用法

博客在线——Wireshark基本用法

http://blog.jobbole.com/ http://blog.jobbole.com/70907/转载于:https://www.cnblogs.com/zhongbokun/p/9709326.html
阅读更多...
绘制三维散点图_SPSS统计作图教程：三维散点图

绘制三维散点图_SPSS统计作图教程：三维散点图

作者&#xff1a;豆沙包&#xff1b;审稿&#xff1a;张耀文1、问题与数据最大携氧能力是身体健康的一项重要指标&#xff0c;但检测该指标成本较高。研究者想根据性别、年龄、体重、运动后心率等指标建立预测最大携氧能力的模型&#xff0c;招募了100名研究对象&#xff0c;测…
阅读更多...
【Python】插入sqlite数据库

【Python】插入sqlite数据库

import sqlite3 from datetime import datetimeconn sqlite3.connect(data.db) print("Opened database successfully")for i in range(100):time datetime.now()conn.execute("INSERT INTO test(time,url,imgPath) VALUES (?,?,?)", (time, "ww…
阅读更多...
java数组转list(Arrays .asList)

java数组转list(Arrays .asList)

习惯性的错误代码&#xff1a; Integer[] intArr {1,2,3}; List<Integer> lst Arrays .asList(intArr); lst.add(4); 报UnsupportedOperationException异常&#xff0c;原因是Arrays .asList() 返回的固定大小的列表&#xff0c;无法进行add、remove等操作&#xff1b;…
阅读更多...
最新文章

Copyright @ 2022~2023