자바 다 중 스 레 드 사진 다운로드 및 압축 실현

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"); 
 } 
 
} 

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); 
 } 
}