Java 中调用 Apache API 实现图片文件的 压缩 与 解压 的 Demo 下载

package com.etc.clear.img.job; import java.io.BufferedInputStream; import java.io.BufferedOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.InputStream; import java.io.OutputStream; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Date; import java.util.Enumeration; import java.util.zip.CRC32; import java.util.zip.CheckedInputStream; import java.util.zip.CheckedOutputStream; import org.apache.tools.zip.ZipEntry; import org.apache.tools.zip.ZipFile; import org.apache.tools.zip.ZipOutputStream; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * 压缩服务器图片任务 * <p> * * @ClassName : UnzipImgJob * </p> * <p> * @Description : TODO * </p> * <p> * @Author : HuaZai * </p> * <p> * @ContactInformation : 1461522031@qq.com/huazai6789@aliyun.com * </p> * * @Date : 2018年1月3日 下午1:16:30 * * @Version : V1.0.0 * */ public class CompressImgJob implements Job { // 定义常量 private static final Logger log = LoggerFactory.getLogger(CompressImgJob.class); private static final String filePath = "D:/zipfile/"; // 需要压缩文件的根路径 private static final String fileName = "zip"; // 文件夹名 private static final String inputPath = "D:/zipfile/"; // 压缩完成后，保存保存的文件 private static final String UnZipPath = "D:/zipfile/"; // 解压完成后，保存保存的文件 /** * 压缩图片任务 */ @SuppressWarnings("static-access") @Override public void execute(JobExecutionContext context) throws JobExecutionException { log.info(" = = = = = = = = = 进入图片《压缩》阶段 ...." + context.getTrigger().getKey()); // 初始化压缩组件 //this.InitCompress(); // 初始化解压组件 this.unZipByFile(); } /** * 初始化压缩文件 * <p> * * @Title : InitCompress * </p> * <p> * @Description : TODO * </p> * <p> * @Author : HuaZai * </p> * * @Date : 2018年1月15日 下午2:21:31 */ public static void InitCompress() { try { log.info(" = = = = = = = = = 初始化压缩组件"); // 创建文件输出流 OutputStream oStream = new FileOutputStream(inputPath + getNextDate() + ".zip"); // 传出到输出流，使用CRC32，确保文件的一致性 CheckedOutputStream cStream = new CheckedOutputStream(oStream, new CRC32()); // 创建压缩文件的输出流 ZipOutputStream zStream = new ZipOutputStream(cStream); // 设置为 GBK 的编码格式 zStream.setEncoding("GBK"); // 需要压缩的文件夹 File file = new File(filePath + getNextDate()); // 调用压缩工具类 compressByZipFile(zStream, file); // 注意关闭流 zStream.close(); cStream.close(); oStream.close(); log.info(" = = = = = = = = = 文件压缩结束，请前往该目录进行查看：" + filePath + getNextDate()); } catch (Exception e) { e.printStackTrace(); } } /** * 使用递归获取指定文件夹下所有的子文件夹，并对其进行压缩 * <p> * * @throws Exception * * @Title : CompressByZipFile * </p> * <p> * @Description : TODO * </p> * <p> * @Author : HuaZai * </p> * * @Date : 2018年1月15日 上午11:25:42 */ public static void compressByZipFile(ZipOutputStream stream, File file) throws Exception { if (file.isDirectory()) { // 创建压缩文件的目录结构 stream.putNextEntry( new ZipEntry(file.getPath().substring(file.getPath().indexOf(fileName)) + File.separator)); // 使用递归实现文件的压缩 for (File dfiles : file.listFiles()) { compressByZipFile(stream, dfiles); } } else { // 正在压缩的文件名称 log.info(" = = = = = = = = = 当前正在压缩的文件名：" + file.getName()); // 创建压缩文件 stream.putNextEntry(new ZipEntry(file.getPath().substring(file.getPath().indexOf(fileName)))); // 以流的方式创建文件流 InputStream iStream = new FileInputStream(file.getPath()); // 创建流缓冲区 BufferedInputStream bStream = new BufferedInputStream(iStream); // 创建字节数组 byte[] bt = new byte[1024]; // 将流写入到压缩文件 while (bStream.read(bt) != -1) { stream.write(bt); } // 注意关闭流 bStream.close(); iStream.close(); } } /** * 调用 Apache API 解压文件夹 * <p> * * @Title : unZipByFile * </p> * <p> * @Description : TODO * </p> * <p> * @Author : HuaZai * </p> * * @Date : 2018年1月16日 上午10:10:17 */ @SuppressWarnings("unchecked") public static void unZipByFile() { try { // 构建压缩文件实例 ZipFile zFile = new ZipFile(filePath + getNextDate() + ".zip", "GBK"); // 获取压缩文件中的项 for (Enumeration<ZipEntry> enumeration = zFile.getEntries(); enumeration.hasMoreElements();) { // 获取元素 ZipEntry zipEntry = enumeration.nextElement(); if (!zipEntry.getName().endsWith(File.separator)) { // 排除空文件夹 log.info(" = = = = = = = = = 正在解压文件：" + zipEntry.getName()); // 创建解压文件夹目录 File file = new File(UnZipPath + zipEntry.getName().substring(0, zipEntry.getName().lastIndexOf(File.separator))); // 判断当前当前解压文件夹是否存在 if (!file.exists()) { // 不存在则创建 file.mkdirs(); } // 创建解压输出流 OutputStream oStream = new FileOutputStream(UnZipPath + zipEntry.getName()); // 构建输出缓存流 BufferedOutputStream bOutputStream = new BufferedOutputStream(oStream); // 将元素读取到输入流 InputStream iStream = zFile.getInputStream(zipEntry); // 构建输入缓存流，并写入元素输入流 BufferedInputStream bInputStream = new BufferedInputStream(iStream); // 为了保证元素的一致性，使用 CRC32 算法检查输入流 CheckedInputStream cInputStream = new CheckedInputStream(bInputStream, new CRC32()); // 读取文件 byte[] bt = new byte[1024]; while (cInputStream.read(bt) != -1) { bOutputStream.write(bt); } // 注意操作结束后，需要关闭所有流 cInputStream.close(); bInputStream.close(); iStream.close(); bOutputStream.close(); oStream.close(); } else { // 如果为空文件，则创建该文件夹 new File(UnZipPath + zipEntry.getName()).mkdirs(); } } log.info(" = = = = = = = = = 解压完成，请前往该目录进行查看：" + UnZipPath + getNextDate()); zFile.close(); } catch (Exception e) { e.printStackTrace(); } } /** * 获取指定日期 * <p> * * @Title : getNextDate * </p> * <p> * @Description : TODO * </p> * <p> * @Author : HuaZai * </p> * * @Date : 2018年1月16日 上午9:37:43 */ public static String getNextDate() { Calendar cd = Calendar.getInstance(); cd.add(Calendar.DATE, -30); // 获取后30天的日期 Date dt = cd.getTime(); SimpleDateFormat df = new SimpleDateFormat("yyyyMMdd");// 设置日期格式 String str = df.format(dt); log.info(" = = = = = = = = = 本次选择压缩的文件夹为：" + str); return str; } }