zip、rar格式文件解压缩处理

雨点打透心脏的1/2处 2023-06-23 13:11 91阅读 0赞

文章目录

  • zip、rar格式文件解压缩处理
    • 核心pom依赖引入
    • 核心工具类FileUtil.java
    • 统一接口
    • rar格式解压缩处理
    • zip格式解压缩处理

zip、rar格式文件解压缩处理

在相关业务场景中，批量文件处理，需要预先进行解压缩及拷贝处理

核心pom依赖引入

  1. <!-- 导入zip解压包 -->
  2. <dependency>
  3.     <groupId>ant</groupId>
  4.     <artifactId>ant</artifactId>
  5.     <version>1.6.5</version>
  6. </dependency>
  7. <!-- 导入rar解压包 -->
  8. <dependency>
  9.     <groupId>com.github.junrar</groupId>
  10.     <artifactId>junrar</artifactId>
  11.     <version>4.0.0</version>
  12. </dependency>
  13. <dependency>
  14.     <groupId>com.github.jnr</groupId>
  15.     <artifactId>jnr-posix</artifactId>
  16.     <version>3.0.50</version>
  17. </dependency>

核心工具类FileUtil.java

  1. public static boolean unPackagedFile(String filename,String dir){
  2.     InfDecompress rarDecompress = null;
  3.     if(filename.endsWith(".rar")){
  4.         rarDecompress = new RarDecompress();   //需要用rar4格式的压缩包能被解析，高版本不行
  5.     }else if(filename.endsWith(".zip")){
  6.         rarDecompress = new ZipDecompress();
  7.     }else{
  8.         logger.error("不支持的解包扩展名格式");
  9.         return false;
  10.     }
  12.     if(!rarDecompress.decompressFile(filename,dir)){
  13.         logger.error(filename + "解压失败");
  14.         return false;
  15.     }
  16.     return true;
  17. }
  19. public static int copyFilesOfDir(String srcDirPath, String desDirPath) {
  20.     if (!srcDirPath.endsWith(File.separator)) {
  21.         srcDirPath = srcDirPath + File.separator;
  22.     }
  23.     if (!desDirPath.endsWith(File.separator)) {
  24.         desDirPath = desDirPath + File.separator;
  25.     }
  26.     File srcfile = new File(srcDirPath);
  27.     if (srcfile.exists()) {
  28.         String[] fileNames = srcfile.list();
  29.         //及时是个空目录 也要创建一个空的目标目录
  30.         if (fileNames != null) {
  31.             if (!new File(desDirPath).exists()) {
  32.                 if (!new File(desDirPath).mkdirs()) {
  33.                     logger.error("{failed to mkdirs " + desDirPath + "}");
  34.                     return -1;
  35.                 }
  36.             }
  37.         }
  38.         else {
  39.             return -1;
  40.         }
  41.         for (String fileName : fileNames) {
  42.             File fileToCopy = null;
  43.             if (srcDirPath.endsWith(File.separator)) {
  44.                 fileToCopy = new File(srcDirPath + fileName);
  45.             } else {
  46.                 fileToCopy = new File(srcDirPath + File.separator + fileName);
  47.             }
  48.             if (fileToCopy.isFile()) {
  49.                 //copy file
  50.                 FileInputStream inputStream = null;
  51.                 FileOutputStream outputStream = null;
  52.                 try {
  53.                     inputStream = new FileInputStream(fileToCopy);
  54.                     if (desDirPath.endsWith(File.separator)) {
  55.                         outputStream = new FileOutputStream(desDirPath + fileToCopy.getName());
  56.                     } else {
  57.                         outputStream = new FileOutputStream(desDirPath + File.separator + fileToCopy.getName());
  58.                     }
  59.                     byte[] buffer = new byte[10240];
  60.                     int len;
  61.                     while ((len = inputStream.read(buffer)) != -1) {
  62.                         outputStream.write(buffer, 0, len);
  63.                     }
  64.                     outputStream.flush();
  65.                     outputStream.close();
  66.                     inputStream.close();
  67.                 } catch (FileNotFoundException ex) {
  68.                     logger.error(ex.getMessage());
  69.                     return -1;
  70.                 } catch (IOException ex) {
  71.                     logger.error(ex.getMessage());
  72.                     return -1;
  73.                 } finally {
  75.                 }
  76.             } else {
  77.                 continue;
  78.             }
  80.         }
  82.     }
  83.     return 0;
  84. }
  86. public static int copyFile(String srcFileNm,String DesFileNm)
  87. {
  88.     InputStream input = null;
  89.     OutputStream output = null;
  90.     try{
  91.         File inFile = new File(srcFileNm);
  92.         File outFile = new File(DesFileNm);
  93.         /*if(!outFile.exists())
  94.             outFile.createNewFile();*/
  95.         input = new FileInputStream(inFile);
  96.         output = new FileOutputStream(outFile);
  97.         byte[] buf = new byte[1024];
  98.         int bytesRead;
  99.         while ((bytesRead = input.read(buf)) > 0) {
  100.             output.write(buf, 0, bytesRead);
  101.         }
  102.     }catch (Exception e){
  103.         logger.error("copyFileToDstdir 文件拷贝失败，src:" + srcFileNm + "  dst:" + DesFileNm + "errorMsg:" + e.getLocalizedMessage());
  104.         return -1;
  105.     }finally {
  106.         try{
  107.             if(input != null){
  108.                 input.close();
  109.             }
  110.             if(output != null){
  111.                 output.close();
  112.             }
  113.         }catch (IOException e){
  114.             logger.error(e.getMessage());
  115.         }
  116.     }
  118.     return 0;
  120. }
  122. public static int deleteDirRecursively(String absoluteDirPath)
  123. {
  124.     File dir=new File(absoluteDirPath);
  125.     if(!dir.isDirectory())
  126.     {
  127.         if(!dir.delete())
  128.         {
  129.             logger.error("delete file failed "+ dir.getAbsolutePath());
  130.             return -1;
  131.         }
  132.         return 0;
  133.     }
  134.     else
  135.     {
  136.         String[] fileList=dir.list();
  137.         for(String fileName:fileList)
  138.         {
  139.             String absolutePath=absoluteDirPath+File.separator+fileName;
  140.             if(deleteDirRecursively(absolutePath)<0)
  141.             {
  142.                 logger.error("delete file failed "+absolutePath);
  143.                 return -1;
  144.             }
  145.         }
  146.         if(fileList.length==0)
  147.         {
  148.             if(!dir.delete())
  149.             {
  150.                 logger.error(dir.getAbsolutePath()+" delele failed");
  151.                 return -1;
  152.             }
  153.         }
  154.     }
  155.     return 0;
  156. }
  158. /**
  159.      * 从fileName全路径中,获取文件名称
  160.      * @param fileName
  161.      * @return
  162.      */
  163. public static String getIndexOfFile(String fileName){
  164.    if(fileName == null){
  165.        return fileName;
  166.    }
  167.    if(fileName.lastIndexOf("\\") != -1){
  168.        return fileName.substring(fileName.lastIndexOf("\\")+1);
  169.    }
  170.    if(fileName.lastIndexOf("/") != -1){
  171.        return fileName.substring(fileName.lastIndexOf("/")+1);
  172.    }
  173.    return fileName;
  174. }

统一接口

  1. public interface InfDecompress {
  2.     boolean decompressFile(String fn,String dest);
  3. }

rar格式解压缩处理

  1. import com.github.junrar.Archive;
  2. import com.github.junrar.rarfile.FileHeader;
  3. import org.slf4j.Logger;
  4. import org.slf4j.LoggerFactory;
  6. import java.io.*;
  8. public class RarDecompress implements InfDecompress{
  9.     private static Logger logger = LoggerFactory.getLogger(RarDecompress.class);
  11.     @Override
  12.     public boolean decompressFile(String fn,String dest) {
  13.         Archive a = null;
  15.         try {
  16.             File inFile = new File(fn);
  17.             a = new Archive(new FileInputStream(inFile));
  18.             if(a!=null){
  19.                 FileHeader fh = a.nextFileHeader();
  20.                 while(fh != null){
  21.                     if(fh.isDirectory()){
  22.                         File fol = new File(dest + File.separator + fh.getFileNameString());
  23.                         fol.mkdirs();
  24.                     }else{
  25.                         String unpackFile = dest + File.separator + fh.getFileNameString().trim();
  26.                         File out = new File(unpackFile);
  27.                         if(!out.exists()){
  28.                             if (!out.getParentFile().exists()) {// 相对路径可能多级，可能需要创建父目录.
  29.                                 out.getParentFile().mkdirs();
  30.                             }
  31.                             out.createNewFile();
  32.                         }
  33.                         FileOutputStream os = new FileOutputStream(out);
  34.                         a.extractFile(fh, os);
  35.                         os.close();
  36.                         if(unpackFile.endsWith(".rar") || unpackFile.endsWith(".zip")){  //子文件下还有被压缩的文件
  37.                             UnPackage.unPackagedFile(unpackFile,unpackFile.substring(0,unpackFile.lastIndexOf(File.separator)));
  38.                         }
  39.                     }
  40.                     fh = a.nextFileHeader();
  41.                 }
  42.             }else {
  43.                 logger.error("Rar decompressFile异常");
  44.                 return false;
  45.             }
  46.             a.close();
  47.             return true;
  48.         }catch (Exception e){
  49.             logger.error("解压" + fn + "文件失败" + e.getLocalizedMessage());
  50.         }
  51.         return false;
  52.     }
  53. }

zip格式解压缩处理

  1. import org.apache.tools.zip.ZipEntry;
  2. import org.apache.tools.zip.ZipFile;
  3. import org.slf4j.Logger;
  4. import org.slf4j.LoggerFactory;
  6. import java.io.File;
  7. import java.io.FileOutputStream;
  8. import java.io.InputStream;
  9. import java.io.OutputStream;
  10. import java.util.Enumeration;
  12. public class ZipDecompress implements InfDecompress{
  13.     private static Logger logger = LoggerFactory.getLogger(ZipDecompress.class);
  15.     @Override
  16.     public boolean decompressFile(String fn,String dest) {
  17.         try {
  18.             ZipFile zip = new ZipFile(fn,"gbk");
  19.             for (Enumeration entries = zip.getEntries(); entries.hasMoreElements(); ) {
  20.                 ZipEntry entry = (ZipEntry) entries.nextElement();
  21.                 String zipEntryName = entry.getName();
  22.                 String unpackFile = dest + File.separator + zipEntryName.trim();
  23.                 InputStream in = zip.getInputStream(entry);
  24.                 OutputStream out = new FileOutputStream(dest + File.separator + zipEntryName);
  25.                 if (new File(zipEntryName).isDirectory()) {
  26.                     continue;
  27.                 }
  28.                 byte[] buf1 = new byte[1024];
  29.                 int len;
  30.                 while ((len = in.read(buf1)) > 0) {
  31.                     out.write(buf1, 0, len);
  32.                 }
  33.                 in.close();
  34.                 out.close();
  35.                 if(unpackFile.endsWith(".rar") || unpackFile.endsWith(".zip")){  //子文件下还有被压缩的文件
  36.                     UnPackage.unPackagedFile(unpackFile,unpackFile.substring(0,unpackFile.lastIndexOf(File.separator)));
  37.                 }
  38.             }
  39.             zip.close();
  40.         }catch (Exception e){
  41.             logger.error("Zip decompressFile异常");
  42.             return false;
  43.         }
  45.         return true;
  46.     }
  47. }

学习Java的同学注意了！！！
学习过程中遇到什么问题或者想获取学习资源的话，欢迎加入Java学习交流群，群号码：543120397 我们一起学Java！

发表评论

表情：
评论列表 （有 0 条评论，91人围观）

还没有评论，来说两句吧...

相关阅读

    相关 DXT纹理压缩格式解析

    我们知道游戏中对于3D物体表面细节的表现最重要的还是靠贴图来实现的，那么越是高分辨率越是真彩色的贴图自然表现力也是越强，

    傷城~傷城~/ 0 赞/ 413 阅读