最近在做一個需求：從其他系統的ftp目錄下載存儲圖片url的文件，然後讀取文件中的url地址，根據地址下載圖片後按天壓縮成一個包，平均一個地址文件中包含4000個地址左右，也就是說一個文件掃描後需要下載4000個左右的圖片，然後壓縮，下面把我的實現方式和優化過程記錄下來，如果大家有什麼更好的方式可以分享。
使用框架： SpringMVC
定時任務實現：繼承org.springframework.scheduling.quartz.QuartzJobBean;
ftp環境搭建就不說了，在其他博客記錄過，使用虛擬機中的CentOS搭建的FTP服務，創建FTP賬號及對應目錄，事先上傳需要下載的圖片地址文件。文件內容格式“圖片ID||圖片地址”。
方法一、最簡單的實現方法就是先下載存儲圖片url地址的文件，然後讀取文件遍歷圖片地址，調下載圖片的方法將圖片存儲到本地，最後壓縮下載的圖片，完成後刪除下載的圖片，只保留壓縮包。
public class PictureTransferJob extends QuartzJobBean { protected void executeInternal(JobExecutionContext arg0) throws JobExecutionException { //實際的FTP配置是讀取配置文件獲取的//FTP地址String hostName ="192.168.1.112"; //FTP端口int port = 2001; /FTP賬號String userName = "test1"; //ftp密碼String password = "test1"; //ftp文件存儲目錄String ftpDowload = "/"; //文件本地存儲路徑String path = this.getClass().getResource("/").getPath(); //圖片地址文件存儲目錄String addrPath=path.substring(1, path.indexOf("WEB-INF/classes"))+"picAddr"; //實際下載的圖片存儲目錄String picPath=path.substring(1, path.indexOf("WEB-INF/classes"))+"pic"; addrPath = addrPath.replace("%20"," "); picPath = picPath.replace("%20"," "); try { //創建存儲圖片地址的文件creatFile(addrPath); //創建存儲實際圖片的文件creatFile(picPath); String oldAddrPath = addrPath; String oldPicPath = picPath; //創建FTP連接FtpUtil2 ftpUtil2 = new FtpUtil2(hostName, port,userName, password, ftpDowload, true); //遍歷FTP目錄下的文件String[] files = ftpUtil2.ListAllFiles(); //本地數據庫會有一個表記錄下載過的文件，這裡會查詢數據庫和ftp列出的文件名比較，如果已經下載過的文件就不會下載，避免重複下載。 //下面省略比較的過程，循環files數組，在本地創建文件for(int i=0;i<files.length;i++){ creatFile(addrPath+File.separator+fileName); //ftpDowload是ftp服務器存儲文件的地址，addrPath是本地存儲文件的地址//這裡一個返回狀態判斷文件是否下載成功boolean downloadInvestorFlag = ftpUtil2.downloadFile(ftpDowload, addrPath); //文件下載成功後調讀取文件的方法，將需要下載的圖片地址存入容器boolean entityState = setPictureDetail(addrPath,picPath,fileNameDate); } } catch (Exception e) { e.printStackTrace(); //調記錄錯誤日誌的業務類用於發送下載文件出錯的短信} } //這裡開始讀圖片地址private boolean setPictureDetail(String addrPath,String picPath,String synDate) { System.out.println("----------進入setPictureDetail方法-----------"); BufferedReader br = null; try { br=new BufferedReader(new InputStreamReader(new FileInputStream(addrPath),"UTF-8")); String row; int count=0; //map中存儲每行讀取到的圖片名稱和URL地址Map<String, String> addrMap=new HashMap<String, String>(); while ((row=br.readLine())!=null) { try { count++; if (count==1) { continue; } String[] column = row.split("//|//|", -1); addrMap.put(column[0].trim(), column[1].trim()); } catch (Exception e) { e.printStackTrace(); } } System.out.println(new Date()); //這裡調用壓縮方法，壓縮方法中會調用執行下載圖片的方法zipPic(picPath,synDate,addrMap); System.out.println(new Date()); System.out.println("----------完成--------------"); return true; } catch (Exception e) { e.printStackTrace(); //調用記錄錯誤日誌的業務類return false; }finally { try { if (null != br) br.close(); } catch (IOException e) { e.printStackTrace(); } } } /** * 根據url地址下載圖片* @throws IOException */ private boolean downPic(String picPath,List<Entry<String, String>> addrList,List<File> picList)throws IOException{ InputStream is=null; FileOutputStream fos=null; URL url=null; String fileName=null; String picAddr=null; File pic=null; try { for(Map.Entry<String, String> addrEntry:addrList) { fileName=addrEntry.getKey(); picAddr=addrEntry.getValue(); //創建Url對象url=new URL(picAddr); is=url.openStream(); //URLConnection獲取到的流通過InputStream直接寫入字節數組會缺失數據，導致下載的圖片不完整，使用org.apache.commons.io.IOUtils.toByteArray(urlconnection.openstream())可以解決byte[] bytes=IOUtils.toByteArray(is);//new byte[is.available()];獲取的字節//流中數據讀入字節數組，讀入後，流中數據清空pic=new File(picPath+fileName+".jpg"); fos=new FileOutputStream(pic); fos.write(bytes); //將下載的圖片存入List，待圖片全部下載完成後傳入zip方法進行壓縮picList.add(pic); fos.flush(); fos.close(); is.close(); } return true; } catch (Exception e) { e.printStackTrace(); return false; } finally{ if (null!=fos) { fos.close(); } if (null!=is) { is.close(); } } } //這裡是壓縮文件的偽代碼private void zipPic(picPath,synDate,addrMap);{ //傳入需要壓縮的文件列表和壓縮文件名ZipUtil.zipByStream(picList,new File(picPath+synDate+".zip")); } /** * 創建文件* @param path */ private void creatFile(String path) { File file = new File(path); if(!file.exists()) { file.mkdirs(); } } }方法二、多線程下載、直接壓縮流
方法一雖然實現了基本功能，但是由於需要下載的圖片太多，以及壓縮本地圖片文件和刪除圖片也比較耗時，所以可以優化速度的地方有兩個。一個就是提高下載圖片的效率，一個就是提高壓縮的效率。
提高下載效率的方法可以使用多線程下載，提高壓縮效率的方法是可以不將圖片保存到本地而直接壓縮文件流。
多線程實現方式：首先我們保存了需要下載的文件的地址列表，我們要使用多線程下載就要保證不同線程下載的圖片不會重複，因此需要一個標誌來區分，這時就可以使用一個索引計數器，按每個線程下載一定量圖片分割，從0開始，每隔比如400個圖片就用一個線程下載，這樣就可以確定需要的線程個數，並且每個線程下載的圖片不會重複。
壓縮文件實現方式：因為生成壓縮文件的本質也是讀取需要壓縮的文件流，然後生成壓縮包，因此我們可以不創建下載的圖片文件，而直接使用容器存儲所有線程下載的圖片流數據，然後將流數據傳給壓縮工具類直接壓縮，這樣就省略了讀取圖片文件創建流，然後生成壓縮包，再刪除本地圖片文件的繁瑣過程。
下面列出改造的主要實現：
/** * 將下載的圖片按天壓縮* @throws IOException */ private boolean zipPic(String picPath,String synDate,Map<String, String> addrMap) throws IOException{ //這裡由於是多線程存儲圖片流，所以需要使用線程安全的map，因此使用ConcurrentHashMap Map<String,InputStream> pictureList=new ConcurrentHashMap<String,InputStream>(); //這裡定義每個線程下載的圖片個數int count=400; //存儲需要下載的圖片地址List<Entry<String, String>> addrList=new ArrayList<Entry<String, String>>(addrMap.entrySet()); //線程數，加一是因為要創建一個線程下載最後不足400個的圖片int nThreads=(addrList.size()/count)+1; //CountDownLatch countDownLatch = new CountDownLatch(nThreads); try { boolean downPic=false; //執行多線程下載圖片downPic=downPic(picPath,addrList,picList,pictureList,nThreads,count); if (downPic) { ZipUtil.zipByArray(picList,new File(picPath+synDate+".zip")); } return true; } catch (Exception e) { e.printStackTrace(); return false; } }下面是創建線程池
/** * 根據url地址下載圖片* @throws InterruptedException */ private boolean downPic(String picPath,List<Entry<String, String>> addrList,Map<String, byte[]> picList,Map<String, InputStream> pictureList,int nThreads,int count)throws IOException, InterruptedException{ ExecutorService threadPool=Executors.newFixedThreadPool(nThreads); // 創建兩個個計數器CountDownLatch begin=new CountDownLatch(0); CountDownLatch end=new CountDownLatch(nThreads); // 循環創建線程for (int i = 0; i < nThreads; i++) { List<Entry<String, String>>subAddrList=null; // 計算每個線程執行的數據if ((i + 1) == nThreads) { int startIndex = (i * count); int endIndex = addrList.size(); subAddrList = addrList.subList(startIndex, endIndex); } else { int startIndex = (i * count); int endIndex = (i + 1) * count; subAddrList = addrList.subList(startIndex, endIndex); } // 線程類PicDownload mythead = new PicDownload(picPath,subAddrList,picList,pictureList); // 這裡執行線程的方式是調用線程池裡的threadPool.execute(mythead)方法。 try { threadPool.execute(mythead); } catch (Exception e) { //記錄錯誤日誌return false; } } begin.countDown(); end.await(); // 執行完關閉線程池threadPool.shutdown(); //這裡一定要循環直到線程池中所有線程都結束才能往下走，測試時由於沒有這一步導致子線程下載圖片還沒完成，而主線程已經往下走了，導致壓縮包內沒有圖片//也可以使用CountDownLatch實現/*while (true) { if (threadPool.isTerminated()) { System.out.println("所有子線程已結束！"); break; } }*/ return true; }下面是線程實現
class PicDownload implements Runnable{ //下載圖片的地址列表List<Entry<String, String>> addrList; //裝載下載成功的圖片列表Map<String, byte[]> picList; Map<String, InputStream> pictureList; //圖片本地存儲路徑String picPath; CountDownLatch begin,end; public PicDownload(String picPath,List<Entry<String, String>> addrList,Map<String, InputStream> picList,CountDownLatch begin,CountDownLatch end){ this.addrList=addrList; this.picList=picList; this.picPath=picPath; this.begin=begin; this.end=end; } @Override public void run() { try { System.out.println(Thread.currentThread().getName()+"------"+Thread.currentThread().getId()); downPicture(addrList); //System.out.println(countDownLatch.getCount()); begin.await(); } catch (Exception e) { e.printStackTrace(); }finally{ end.countDown(); //countDownLatch.countDown(); } } public boolean downPicture(List<Entry<String, String>> addrList) throws Exception{ InputStream is=null; FileOutputStream fos=null; URL url=null; String fileName=null; String picAddr=null; File pic=null; try { for(Map.Entry<String, String> addrEntry:addrList) { fileName=addrEntry.getKey(); picAddr=addrEntry.getValue(); //創建Url對象url=new URL(picAddr); is=url.openStream(); //URLConnection獲取到的流通過InputStream直接寫入字節數組會缺失數據，導致下載的圖片不完整，使用org.apache.commons.io.IOUtils.toByteArray(urlconnection.openstream())可以解決//byte[] bytes=IOUtils.toByteArray(is);//new byte[is.available()];獲取的字節//流中數據讀入字節數組，讀入後，流中數據清空picList.put(fileName+".jpg", is); //這時候由於沒有把流寫入文件，一定不能關閉流，否則流中的數據就會丟失//is.close(); } return true; } catch (Exception e) { e.printStackTrace(); return false; } finally{ //不能關閉流/*if (null!=is) { is.close(); }*/ } } }上面使用流來壓縮遇到了另一個問題，在壓縮文件時會出現java.net.SocketException:Connection reset
分析了一下原因，應該是由於流InputStream和UrlConnection是連接狀態的，UrlConnection超時重置導致了獲取輸入流失敗。
嘗試設置URLConnection的超時時間，但是測試時發現圖片下載收到網速影響較大，這種方式很不穩定，不可取，最後只有放棄使用流，而改用字節數組傳給壓縮工具類，然後將字節數組轉為流壓縮。
/** *使用容器存儲下載的圖片字節數組*/ public boolean downPicture(List<Entry<String, String>> addrList) throws Exception{ InputStream is=null; FileOutputStream fos=null; URL url=null; String fileName=null; String picAddr=null; File pic=null; try { for(Map.Entry<String, String> addrEntry:addrList) { fileName=addrEntry.getKey(); picAddr=addrEntry.getValue(); //創建Url對象url=new URL(picAddr); //打開連接，創建java.net.URLConnection對象，該對像沒有關閉連接的方法，可以轉為它的子類HttpURLConnection調用disconnect方法關閉連接。 //java.net.URLConnection和java.net.HttpURLConnection都有設置超時時間的方法關閉連接//HttpURLConnection uc=(HttpURLConnection)url.openConnection(); is=uc.getInputStream(); //URLConnection獲取到的流通過InputStream直接寫入字節數組會缺失數據，導致下載的圖片不完整，使用org.apache.commons.io.IOUtils.toByteArray(urlconnection.openstream())可以解決byte[] bytes=IOUtils.toByteArray(is);//new byte[is.available()];獲取的字節//流中數據讀入字節數組，讀入後，流中數據清空//is.read(bytes); picList.put(fileName+".jpg",bytes); is.close(); } return true; } catch (Exception e) { e.printStackTrace(); return false; } finally{ if (null!=is) { is.close(); } } }總結：
實現過程中遇到的問題：
1、使用線程池時對於共享狀態，比如這裡的存儲下載的圖片字節數據容器是所有線程共享的，因此需要使用同步的容器，否則會導致存儲的數據出問題，因此使用了ConcurrentHashMap<String,byte[]>
2、這裡存在一個主線程和子線程的執行順序問題，因為主線程需要等待線程池中所有線程下載圖片結束後才能往下走去壓縮圖片，如果主線程不等待子線程結束就向下執行壓縮方法就會導致壓縮圖片缺少或者沒有壓縮圖片。因此可以使用CountDownLatch實現，或者在關閉線程池語句下面使用死循環檢查threadPool.isTerminated()才能繼續執行主線程去壓縮圖片。
3、由於直接將UrlConnection獲取到的輸入流直接傳給壓縮類進行壓縮，存在連接超時重置的情況，因此改用將下載的流存入字節數組，再傳給壓縮類壓縮，避免使用流出現意外情況。
4、在使用urlconnection.openStream()獲取輸入流後，轉換為字節數組下載的圖片是不完整的。 。使用org.apache.commons.io.IOUtils.toByteArray(urlconnection.openstream())可以解決，具體可以閱讀其源碼看實現。
下面是FTP工具類的實現：
import java.io.BufferedInputStream; import java.io.BufferedOutputStream; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPClientConfig; import org.apache.commons.net.ftp.FTPConnectionClosedException; import org.apache.commons.net.ftp.FTPReply; public class FtpUtil2 { private FTPClient ftpClient = null; // ftp服務器地址private String hostName; // ftp服務器默認端口public static int defaultport = 21; // 登錄名private String userName; // 登錄密碼private String password; // 需要訪問的遠程目錄private String remoteDir; /** * @param hostName * 主機地址* @param port * 端口號* @param userName * 用戶名* @param password * 密碼* @param remoteDir * 默認工作目錄* @param is_zhTimeZone * 是否是中文FTP Server端* @return * @return */ /** * 新增方法*/ public FtpUtil2() { PropConfig config = PropConfig.loadConfig("system.properties"); String hostName = config.getConfig("ftpAddress"); String port = config.getConfig("ftpPort"); String userName = config.getConfig("ftpUserName"); String password = config.getConfig("ftpPassword"); String remoteDir = config.getConfig("remoteFilePath"); boolean is_zhTimeZone= true; this.hostName = hostName; this.userName = userName; this.password = password; this.remoteDir = remoteDir == null ? "" : remoteDir; this.ftpClient = new FTPClient(); if (is_zhTimeZone) { this.ftpClient.configure(FtpUtil2.Config()); this.ftpClient.setControlEncoding("GBK"); } // 登錄this.login(); // 切換目錄this.changeDir(this.remoteDir); this.setFileType(FTPClient.BINARY_FILE_TYPE); ftpClient.setDefaultPort(Integer.parseInt(port)); } public FtpUtil2(String hostName, int port, String userName, String password, String remoteDir, boolean is_zhTimeZone) { this.hostName = hostName; this.userName = userName; this.password = password; defaultport=port; this.remoteDir = remoteDir == null ? "" : remoteDir; this.ftpClient = new FTPClient(); if (is_zhTimeZone) { this.ftpClient.configure(FtpUtil2.Config()); this.ftpClient.setControlEncoding("GBK"); } // 登錄this.login(); // 切換目錄this.changeDir(this.remoteDir); this.setFileType(FTPClient.ASCII_FILE_TYPE); ftpClient.setDefaultPort(port); } /** * 登錄FTP服務器*/ public boolean login() { boolean success = false; try { ftpClient.connect(this.hostName,defaultport); ftpClient.login(this.userName, this.password); int reply; reply = ftpClient.getReplyCode(); if (!FTPReply.isPositiveCompletion(reply)) { ftpClient.disconnect(); return success; } } catch (FTPConnectionClosedException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } success = true; System.out.println("連接到ftp服務器：" + this.hostName + " 成功..開始登錄"); return success; } private static FTPClientConfig Config() { FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_UNIX); conf.setRecentDateFormatStr("MM月dd日HH:mm"); // conf.setRecentDateFormatStr("(YYYY年)?MM月dd日( HH:mm)?"); return conf; } /** * 變更工作目錄* * @param remoteDir * */ public void changeDir(String remoteDir) { try { this.remoteDir = remoteDir; ftpClient.changeWorkingDirectory(remoteDir); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println("變更工作目錄為:" + remoteDir); } /** * 返回上一級目錄(父目錄) */ public void toParentDir() { try { ftpClient.changeToParentDirectory(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 列出當前工作目錄下所有文件*/ public String[] ListAllFiles() { String[] names = this.ListFiles("*"); return this.sort(names); } /** * 列出指定工作目錄下的匹配文件* * @param dir * exp: /cim/ * @param file_regEx * 通配符為* */ public String[] ListAllFiles(String dir, String file_regEx) { String[] names = this.ListFiles(dir + file_regEx); return this.sort(names); } /** * 列出匹配文件* * @param file_regEx * 匹配字符,通配符為* */ public String[] ListFiles(String file_regEx) { try { /** * FTPFile[] remoteFiles = ftpClient.listFiles(file_regEx); * //System.out.println(remoteFiles.length); String[] name = new * String[remoteFiles.length]; if(remoteFiles != null) { for(int * i=0;i<remoteFiles.length;i++) { if(remoteFiles[i] == null) * name[i] = ""; else * if(remoteFiles[i].getName()==null||remoteFiles * [i].getName().equals * (".")||remoteFiles[i].getName().equals("..")) { name[i] = ""; * } else name[i] = remoteFiles[i].getName(); * System.out.println(name[i]); } } */ ftpClient.enterLocalPassiveMode(); String[] name = ftpClient.listNames(file_regEx);; if (name == null) return new String[0]; return this.sort(name); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } return new String[0]; } public void Lists(String reg) { try { String[] a = ftpClient.listNames(reg); if (a != null) { for (String b : a) { System.out.println(b); } } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 設置傳輸文件的類型[文本文件或者二進製文件] * * @param fileType * --BINARY_FILE_TYPE,ASCII_FILE_TYPE */ public void setFileType(int fileType) { try { ftpClient.setFileType(fileType); } catch (IOException e) { e.printStackTrace(); } } /** * 上傳文件* * @param localFilePath * --本地文件路徑+文件名* @param newFileName * --新的文件名*/ public void uploadFile(String localFilePath, String newFileName) { // 上傳文件this.ftpClient.enterLocalPassiveMode();// 被動模式連接BufferedInputStream buffIn = null; try { buffIn = new BufferedInputStream(new FileInputStream(localFilePath)); boolean ifUpload = ftpClient.storeFile(newFileName, buffIn); if (!ifUpload) { System.out.println("上傳文件失敗。。。"); } else { System.out.println("上傳文件成功。。。"); } } catch (Exception e) { e.printStackTrace(); } finally { try { if (buffIn != null) buffIn.close(); } catch (Exception e) { e.printStackTrace(); } } } /** * 上傳文件2 * * @param file * --FileInputStream的文件* @param newFileName * --新的文件名*/ public void newUploadFile(FileInputStream file, String newFileName) { // 上傳文件this.ftpClient.enterLocalPassiveMode();// 被動模式連接BufferedInputStream buffIn = null; try { buffIn = new BufferedInputStream(file); boolean ifUpload = ftpClient.storeFile(newFileName, buffIn); if (!ifUpload) { System.out.println("上傳文件失敗。。。"); } else { System.out.println("上傳文件成功。。。"); } } catch (Exception e) { e.printStackTrace(); } finally { try { if (buffIn != null) buffIn.close(); } catch (Exception e) { e.printStackTrace(); } } } /** * 下載文件(單個) * * @param remoteFileName * --服務器上的文件名* @param localFileName * --本地文件名*/ public boolean downloadFile(String remoteFileName, String localFileName) { this.ftpClient.enterLocalPassiveMode();// 被動模式連接BufferedOutputStream buffOut = null; try { buffOut = new BufferedOutputStream(new FileOutputStream( localFileName)); boolean ifDownload = ftpClient .retrieveFile(remoteFileName, buffOut); if (!ifDownload) { System.out.println("下載文件失敗。。。"); return false; } else { System.out.println("下載文件成功。。。"); } } catch (Exception e) { e.printStackTrace(); return false; } finally { try { if (buffOut != null) buffOut.close(); } catch (Exception e) { e.printStackTrace(); } } return true; } /** * 關閉FTP連接*/ public void close() { try { if (ftpClient != null) { ftpClient.logout(); ftpClient.disconnect(); } } catch (Exception e) { e.printStackTrace(); } } /** * 冒泡排序字符串(從大到小) */ public String[] sort(String[] str_Array) { if (str_Array == null) { throw new NullPointerException("The str_Array can not be null!"); } String tmp = ""; for (int i = 0; i < str_Array.length; i++) { for (int j = 0; j < str_Array.length - i - 1; j++) { if (str_Array[j].compareTo(str_Array[j + 1]) < 0) { tmp = str_Array[j]; str_Array[j] = str_Array[j + 1]; str_Array[j + 1] = tmp; } } } return str_Array; } public static void main(String[] strs) { FtpUtil2 FtpUtil2 = new FtpUtil2("192.168.1.112", 20011, "test1", "test1", "/", true); FtpUtil2.downloadFile("test.txt", "d://test.txt"); } }下面是ZIP工具類：
import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.util.ArrayList; import java.util.Enumeration; import java.util.List; import java.util.Map; import java.util.zip.ZipEntry; import java.util.zip.ZipFile; import java.util.zip.ZipOutputStream; import org.apache.commons.io.IOUtils; import com.ibatis.common.logging.Log; import com.ibatis.common.logging.LogFactory; public class ZipUtil { private static final Log log = LogFactory.getLog(ZipUtil.class); /** * 壓縮文件* * @param srcfile File[] 需要壓縮的文件列表* @param zipfile File 壓縮後的文件*/ public static OutputStream zipFiles(List<File> srcfile, OutputStream outputStream) { byte[] buf = new byte[1024]; try { // Create the ZIP file ZipOutputStream out = new ZipOutputStream(outputStream); // Compress the files for (int i = 0; i < srcfile.size(); i++) { File file = srcfile.get(i); FileInputStream in = new FileInputStream(file); // Add ZIP entry to output stream. out.putNextEntry(new ZipEntry(file.getName())); // Transfer bytes from the file to the ZIP file int len; while ((len = in.read(buf)) > 0) { //System.out.println(len+"=============="); out.write(buf, 0, len); } // Complete the entry out.closeEntry(); in.close(); } // Complete the ZIP file out.close(); } catch (IOException e) { log.error("ZipUtil zipFiles exception:"+e); } return outputStream; } /** * 壓縮文件* * @param srcfile File[] 需要壓縮的文件列表* @param zipfile File 壓縮後的文件*/ public static void zipFiles(List<File> srcfile, File zipfile) { byte[] buf = new byte[1024]; try { // Create the ZIP file ZipOutputStream out = new ZipOutputStream(new FileOutputStream(zipfile)); // Compress the files for (int i = 0; i < srcfile.size(); i++) { File file = srcfile.get(i); FileInputStream in = new FileInputStream(file); // Add ZIP entry to output stream. out.putNextEntry(new ZipEntry(file.getName())); // Transfer bytes from the file to the ZIP file int len; while ((len = in.read(buf)) > 0) { out.write(buf, 0, len); } // Complete the entry out.closeEntry(); in.close(); } // Complete the ZIP file out.close(); } catch (IOException e) { log.error("ZipUtil zipFiles exception:"+e); } } /** * 壓縮文件* srcfile:key:文件名,value:文件對應的輸入流* @param srcfile * @param zipfile * @see */ public static void zipByStream(Map<String,InputStream> srcfile, File zipfile) { try { // Create the ZIP file ZipOutputStream out = new ZipOutputStream(new FileOutputStream(zipfile)); // Compress the files System.out.println(srcfile.entrySet().size()); for (Map.Entry<String, InputStream> fileEntry:srcfile.entrySet()) { InputStream in = fileEntry.getValue(); // Add ZIP entry to output stream. System.out.println(in.available()); out.putNextEntry(new ZipEntry(fileEntry.getKey())); // Transfer bytes from the file to the ZIP file byte[] bytes=IOUtils.toByteArray(in); out.write(bytes); out.closeEntry(); in.close(); } // Complete the ZIP file out.close(); } catch (IOException e) { log.error("ZipUtil zipFiles exception:"+e); System.out.println(e.getMessage()); } } /** * 壓縮文件* srcfile:key:文件名,value:文件對應的字節數組* @param srcfile * @param zipfile * @see */ public static void zipByArray(Map<String,byte[]> srcfile, File zipfile) { byte[] buf = new byte[1024]; try { // Create the ZIP file ZipOutputStream out = new ZipOutputStream(new FileOutputStream(zipfile)); // Compress the files System.out.println(srcfile.entrySet().size()); for (Map.Entry<String, byte[]> fileEntry:srcfile.entrySet()) { //InputStream in = fileEntry.getValue(); // Add ZIP entry to output stream. out.putNextEntry(new ZipEntry(fileEntry.getKey())); // Transfer bytes from the file to the ZIP file byte[] bytes=fileEntry.getValue();//IOUtils.toByteArray(in); out.write(bytes); out.closeEntry(); //in.close(); } // Complete the ZIP file out.close(); } catch (IOException e) { log.error("ZipUtil zipFiles exception:"+e); System.out.println(e.getMessage()); } } /** * 解壓縮* * @param zipfile File 需要解壓縮的文件* @param descDir String 解壓後的目標目錄*/ public static void unZipFiles(File zipfile, String descDir) { try { // Open the ZIP file ZipFile zf = new ZipFile(zipfile); for (Enumeration entries = zf.entries(); entries.hasMoreElements();) { // Get the entry name ZipEntry entry = ((ZipEntry) entries.nextElement()); String zipEntryName = entry.getName(); InputStream in = zf.getInputStream(entry); // System.out.println(zipEntryName); OutputStream out = new FileOutputStream(descDir + zipEntryName); byte[] buf1 = new byte[1024]; int len; while ((len = in.read(buf1)) > 0) { out.write(buf1, 0, len); } // Close the file and stream in.close(); out.close(); } } catch (IOException e) { log.error("ZipUtil unZipFiles exception:"+e); } } /** * Main * * @param args */ public static void main(String[] args) { List<File> srcfile=new ArrayList<File>(); srcfile.add(new File("d://1.jpg")); srcfile.add(new File("d://2.jpg")); srcfile.add(new File("d://3.jpg")); srcfile.add(new File("d://4.jpg")); File zipfile = new File("d://pic.zip"); ZipUtil.zipFiles(srcfile, zipfile); } }以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持武林網。