使用Java 代码实现，压缩东西到.tar.gz文件里面，或者使用代码解压.tar.gz文件
目录
- 1 问题
- 2 实现（工具类）
1 问题
使用Java 代码实现，压缩东西到.tar.gz文件里面，或者使用代码解压.tar.gz文件
2 实现（工具类）
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.compress.archivers.tar.TarArchiveEntry;
import org.apache.commons.compress.archivers.tar.TarArchiveOutputStream;
import org.apache.commons.compress.utils.IOUtils;
import org.apache.tools.tar.TarEntry;
import org.apache.tools.tar.TarInputStream;
import java.io.*;
import java.nio.file.Files;
import java.nio.file.StandardCopyOption;
import java.util.ArrayList;
import java.util.List;
import java.util.zip.GZIPInputStream;
import java.util.zip.GZIPOutputStream;
/**
* 把一个目录下的所有文件和文件夹打成.tar.gz包（从当前的目录开始）
* @time 16:15
* @discription
**/
@Slf4j
public class TarUtil {
// private static void main(String[] args) throws IOException {
/**
* 把多个文件夹打成.tar.gz包（从当前的目录开始）
* @param sourceFolder 需要打成.tar.gz包的目录列表（包含目录和目录下的所有文件和文件夹）
* @param tarGzPath 打成的tar包生成的目标目录 例： D:/tmp 最终打包会在 D:/tmp目录下生成 test.tar.gz包
* @param tarGzFileName 打tar.gz包的名，例如：ide-sdk.tar.gz
*/
public static void fileListToTar(List sourceFolder, String tarGzPath, String tarGzFileName) {
TarArchiveOutputStream tarOs = null;
try {
// 遍历每一个文件的绝对路径
for(String folder : sourceFolder){
if(folder.contains("../")){
throw new FileNotFoundException("压缩的目录不存在。。。");
}
File sourceFile = new File(folder);
if (!sourceFile.exists()) {
throw new FileNotFoundException("压缩的目录不存在。。。");
}
}
// 压缩包流
tarOs = createTar(tarGzPath,tarGzFileName,tarOs);
// 遍历每一个文件的绝对路径
for(String folder : sourceFolder){
addFileListToTarGZ(folder, tarOs);
}
} catch (IOException e) {
log.info(e.getMessage());
} finally {
try {
tarOs.close();
} catch (IOException e) {
log.info(e.getMessage());
}
}
}
/**
* 把文件复制到.tar.gz包中
* @param sourceFile 需要复制的文件路径
* @param tarArchive tar包流
* @throws IOException 异常
*/
private static void addFileListToTarGZ(String sourceFile, TarArchiveOutputStream tarArchive)
throws IOException {
// 原文件绝对路径
if(sourceFile.contains("../")){
throw new FileNotFoundException("文件不存在。。。");
}
File file = new File(sourceFile);
String parent = file.getParent();
// String entryName = parent +File.separator+ file.getName();
String entryName = file.getName();
// 添加 tar ArchiveEntry
tarArchive.putArchiveEntry(new TarArchiveEntry(file, entryName));
if (file.isFile()) {
FileInputStream fis = new FileInputStream(file);
BufferedInputStream bis = new BufferedInputStream(fis);
// 写入文件
IOUtils.copy(bis, tarArchive);
tarArchive.closeArchiveEntry();
bis.close();
}
}
/**
* 把一个目录下的所有文件和文件夹打成.tar.gz包（从当前的目录开始）
* Method ：createTarFile
*
Description : 打包文件 .tar.gz
*
* @param sourceFolder 需要打成.tar.gz包的目录（包含目录和目录下的所有文件和文件夹）例：E:/aarm/test
* @param tarGzPath 打成的tar包生成的目标目录 例： D:/tmp 最终打包会在 D:/tmp目录下生成 test.tar.gz包
* @param tarGzFileName 打tar.gz包的名，例如：ide-sdk.tar.gz
*/
public static void fileToTar(String sourceFolder, String tarGzPath, String tarGzFileName) {
TarArchiveOutputStream tarOs = null;
try {
File sourceFile = new File(sourceFolder);
if (!sourceFile.exists()) {
throw new FileNotFoundException("压缩的目录不存在。。。");
}
tarOs = createTar(tarGzPath,tarGzFileName,tarOs);
String fileDir = sourceFolder.split(File.separator)[sourceFolder.split(File.separator).length-1];
String tarDir = tarGzFileName.split("\\.")[0];
String name = fileDir+"_"+tarDir;
addFilesToTarGZ(sourceFile, "", tarOs,name);
} catch (IOException e) {
log.info(e.getMessage());
} finally {
try {
tarOs.close();
} catch (IOException e) {
log.info(e.getMessage());
}
}
}
/**
* 把文件复制到.tar.gz包中
* @param file 需要复制的文件
* @param parent 父目录
* @param tarArchive tar包流
* @param tarDir 旧文件最后一级目录_包名目录
* @throws IOException 异常
*/
private static void addFilesToTarGZ(File file, String parent, TarArchiveOutputStream tarArchive,String tarDir)
throws IOException {
// 将最外层的文件夹名，默认为包名
if(parent.startsWith(tarDir.split("_")[0]+ File.separator)) {
parent = parent.replace(parent, tarDir.split("_")[1]+File.separator);
}
String entryName = parent + file.getName();
if(!parent.equals("")) {
// 添加 tar ArchiveEntry
tarArchive.putArchiveEntry(new TarArchiveEntry(file, entryName));
}
if (file.isFile()) { // 确认是否为file对象
FileInputStream fis = new FileInputStream(file);
BufferedInputStream bis = new BufferedInputStream(fis);
// 写入文件
IOUtils.copy(bis, tarArchive);
tarArchive.closeArchiveEntry();
bis.close();
} else if (file.isDirectory()) { // 检查一个对象是否为文件夹
// 因为是个文件夹，无需写入内容，关闭即可
if(!parent.equals("")) {
tarArchive.closeArchiveEntry();
}
File[] files = file.listFiles();
if (files != null) {
// 读取文件夹下所有文件
for (File f : files) {
// 递归
addFilesToTarGZ(new File(f.getAbsolutePath()), entryName + File.separator, tarArchive,tarDir);
}
}
}
}
/**
* 创建tar包的流
* @param tarGzPath 需要复制的文件路径
* @param tarGzFileName 文件名称
* @param tarOs tar包流
* @throws IOException 异常
*/
private static TarArchiveOutputStream createTar(String tarGzPath, String tarGzFileName,TarArchiveOutputStream tarOs) throws IOException {
// 原文件绝对路径
if(tarGzPath.contains("../")){
throw new FileNotFoundException("文件不存在。。。");
}
File tarGzFile = new File(tarGzPath);
if (!tarGzFile.exists()) {
tarGzFile.mkdirs();
}
// 创建一个 FileOutputStream 到输出文件（.tar.gz）
File tarFile = new File(tarGzFile + "/" + tarGzFileName);
// File tarFile = new File(tarGzFile + tarGzFileName);
FileOutputStream fos = new FileOutputStream(tarFile);
// 创建一个 GZIPOutputStream，用来包装 FileOutputStream 对象
GZIPOutputStream gos = new GZIPOutputStream(new BufferedOutputStream(fos));
// 创建一个 TarArchiveOutputStream，用来包装 GZIPOutputStream 对象
tarOs = new TarArchiveOutputStream(gos);
// 若不设置此模式，当文件名超过 100 个字节时会抛出异常，异常大致如下：
// is too long ( > 100 bytes)
// 具体可参考官方文档：http://commons.apache.org/proper/commons-compress/tar.html#Long_File_Names
tarOs.setLongFileMode(TarArchiveOutputStream.LONGFILE_POSIX);
return tarOs;
}
/**
* 解压.tar.gz文件
* @param sourceFile 需解压文件
* @param outputDir 输出目录
* @throws IOException
*/
public static void tartoFile(String sourceFile,String outputDir) throws IOException{
if(sourceFile.contains("../")){
throw new FileNotFoundException("文件不存在。。。");
}
TarInputStream tarIn = null;
// tar包的绝对路径
File file = new File(sourceFile);
try{
tarIn = new TarInputStream(new GZIPInputStream(new BufferedInputStream(
new FileInputStream(file))),1024 * 2);
//创建输出目录
createDirectory(outputDir,null);
TarEntry entry = null;
while( (entry = tarIn.getNextEntry()) != null ){
if(entry.isDirectory()){//是目录
entry.getName();
//创建空目录
System.out.println("解压之后是目录");
createDirectory(outputDir,entry.getName());
}else{//是文件
File tmpFile = new File(outputDir + "/" + entry.getName());
createDirectory(tmpFile.getPath() + "/",null);//创建输出目录
OutputStream out = null;
try{
out = new FileOutputStream(tmpFile);
int length = 0;
// 一次读取 2kb
byte[] b = new byte[2048];
while((length = tarIn.read(b)) != -1){
out.write(b, 0, length);
}
}catch(IOException ex){
throw ex;
}finally{
if(out!=null)
out.close();
}
}
}
}catch(IOException ex){
throw new IOException("解压归档文件出现异常",ex);
} finally{
try{
if(tarIn != null){
tarIn.close();
}
}catch(IOException ex){
throw new IOException("关闭tarFile出现异常",ex);
}
}
}
/**
* 构建目录
* @param outputDir
* @param subDir
*/
private static void createDirectory(String outputDir,String subDir){
File file = new File(outputDir);
if(!(subDir == null || subDir.trim().equals(""))){//子目录不为空
file = new File(outputDir + "/" + subDir);
}
if(!file.exists()){
if(!file.getParentFile().exists())
file.getParentFile().mkdirs();
file.mkdirs();
}
}
//文件拷贝，目标文件存在时会拷贝失败
public static void copyFile(File file, File fileTo){
try {
Files.copy(file.toPath(),fileTo.toPath());
} catch (IOException e) {
log.info(e.getMessage());
}
}
/**
*
*
Method ：copyDirectory
*
Description : 复制文件夹
* 将源文件的外层目录也拷贝入新目录下
* @param sourcePathString
* @param targetPathString
*/
public static void copyDirectory(String sourcePathString,String targetPathString){
if(!new File(sourcePathString).canRead()){
System.out.println("源文件夹" + sourcePathString + "不可读，无法复制！");
}else{
// yin 本地测试，上传记得更改为一个斜杠
String endDir = sourcePathString.split(File.separator)[sourcePathString.split(File.separator).length-1];
//将源文件的外层目录也拷贝入新目录下
targetPathString = targetPathString+File.separator+endDir;
(new File(targetPathString)).mkdirs();
System.out.println("开始复制文件夹" + sourcePathString + "到" + targetPathString);
File[] files = new File(sourcePathString).listFiles();
for (File file : files) {
if (file.isFile()) {
copyFileForce(new File(sourcePathString + File.separator + file.getName()), new File(targetPathString + File.separator + file.getName()));
} else if (file.isDirectory()) {
copyDirectory(sourcePathString + File.separator + file.getName(), targetPathString);
}
}
System.out.println("复制文件夹" + sourcePathString + "到" + targetPathString + "结束");
}
}
//文件拷贝，强制覆盖目标文件
public static void copyFileForce(File file, File fileTo){
try {
Files.copy(file.toPath(),fileTo.toPath(), StandardCopyOption.REPLACE_EXISTING.REPLACE_EXISTING);
} catch (IOException e) {
log.info(e.getMessage());
}
}
//解压.tar.gz文件
public static void unTarGz(String sourceFile,String outputDir) throws IOException{
TarInputStream tarIn = null;
File file = new File(sourceFile);
try{
tarIn = new TarInputStream(new GZIPInputStream(
new BufferedInputStream(new FileInputStream(file))),
1024 * 2);
createDirectory(outputDir,null);//创建输出目录
TarEntry entry = null;
while( (entry = tarIn.getNextEntry()) != null ){
if(entry.isDirectory()){//是目录
entry.getName();
createDirectory(outputDir,entry.getName());//创建空目录
}else{//是文件
File tmpFile = new File(outputDir + "/" + entry.getName());
createDirectory(tmpFile.getParent() + "/",null);//创建输出目录
OutputStream out = null;
try{
out = new FileOutputStream(tmpFile);
int length = 0;
byte[] b = new byte[2048];
while((length = tarIn.read(b)) != -1){
out.write(b, 0, length);
}
}catch(IOException ex){
throw ex;
}finally{
if(out!=null)
out.close();
}
}
}
}catch(IOException ex){
throw new IOException("解压归档文件出现异常",ex);
} finally{
try{
if(tarIn != null){
tarIn.close();
}
}catch(IOException ex){
throw new IOException("关闭tarFile出现异常",ex);
}
}
}
}
本文来自网络，不代表协通编程立场，如若转载，请注明出处：https://net2asp.com/9d776a3287.html
相关推荐
-
【MySQL】不允许你还不了解创建计算字段
🎬 博客主页：博主链接 🎥 本文由 M malloc 原创，首发于 CSDN🙉 🎄 学习专栏推荐：LeetCode刷…
-
配置 Prometheus 通过 query-exporter 自定义 SQL 抓取云上MySQL 监控指标
现今，数据构建和管理方式通常分为自建模式（IaaS）和托管模式（PaaS）。在 Prometheus 监控架构中，对于自建模式，我们通常可以选择使用 node-exporter 和…
-
ClickHouse与Elasticsearch比较总结
目录 背景 分布式架构 存储架构 写入链路设计 Elasticsearch 再谈Schemaless 查询架构 计算引擎 数据扫描 再谈高并发 性能测试 日志分析场景 access…
-
《MySQL高级篇》十、数据库其他调优策略
文章目录 1.数据库调优的措施 1.1调优的目标 1.2 如何定位调优问题 1.3 调优的维度和步骤 第1步：选择适合的DBMS 第2步:优化表设计 第3步:优化逻辑查询 第4步:…
-
python报错：Note: you may need to restart the kernel to use updated packages终极解决办法
python执行：pip install 库名 报错：Note: you may need to restart the kernel to use updated package…
-
【Python】Python项目打包发布（四）（基于Nuitka打包PySide6项目)
Python项目打包发布汇总 【Python】Python项目打包发布（一）（基于Pyinstaller打包多目录项目） 【Python】Python项目打包发布（二）（基于Pyi…
-
【2023华为od-C卷-第三题-孙悟空吃蟠桃】100%通过率（JS&Java&Python&C++）
本题已有网友报告代码100%通过率 本题视频讲解：视频讲解 OJ &答疑服务 购买任意专栏，即可添加博主vx:utheyi，获取答疑/辅导服务 OJ权限获取可以在购买专栏后…
-
anaconda详细介绍、安装及使用（python）
anaconda详细介绍、安装及使用 1 介绍 1.1 简介 1.2 特点 1.3 版本下载 2 Anaconda管理Python包命令 3 安装 3.1 windows安装 4 …
-
【2023华为od-C卷-第三题-找数字】100%通过率（JavaScript&Java&python&C++）
题目描述 小扇和小船今天又玩起来了数字游戏 小船给小扇一个正整数 n ( 1 ≤ n ≤ 1 0 9 ) n(1\le n\le 10^9) n(1≤
-
华为OD机试 – 攀登者1（Java & JS & Python & C & C++）
题目描述 攀登者喜欢寻找各种地图，并且尝试攀登到最高的山峰。 地图表示为一维数组，数组的索引代表水平位置，数组的元素代表相对海拔高度。其中数组元素0代表地面。 例如：[0,1,2,…
