Java多线程编程总结

package com.ftp; import java.io.File; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.OutputStream; import java.net.SocketException; import java.util.ArrayList; import java.util.List; import java.util.Properties; import java.util.StringTokenizer; import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPReply; import org.apache.log4j.Logger; import com.ftp.thread.FTPThread; import com.log.Log; import com.sun.org.apache.bcel.internal.generic.NEW; import com.util.PropetyUtil; /** * FTP客户端 * * @author 王明进 * @version $Id: ClientFTP.java 2011-5-01 上午11:00:47 $ */ public class ClientFTP { // ---------------------------------------------------------------- // Instance data // ---------------------------------------------------------------- /** logger */ protected final Logger log = Log.getLog(getClass()); private Properties pro = new PropetyUtil().getPro(); // 处理后的 private List<String> listAfter; public ClientFTP(List<String> listAfter, List<String> recordeList , FTPClient ftpClient) { super(); this.listAfter = listAfter; this.ftpClient = ftpClient; this.recordeList = recordeList; } public List<String> getListAfter() { return listAfter; } private List<String> recordeList ; public void setListAfter(List<String> listAfter) { this.listAfter = listAfter; } public FTPClient getFtpClient() { return ftpClient; } public void setFtpClient(FTPClient ftpClient) { this.ftpClient = ftpClient; } public ClientFTP() { super(); // TODO Auto-generated constructor stub } /*// 处理前的 private List<String> listBefor = new ArrayList<String>();*/ private FTPClient ftpClient = new FTPClient(); /* *//** * 设置文件传输类型 * * @throws Exception * @throws IOException */ /* * private void setFileType(FTPClient ftpClient) throws Exception { try { if * (Boolean.parseBoolean(pro.getProperty("binaryTransfer"))) { * ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); } else { * ftpClient.setFileType(FTPClient.ASCII_FILE_TYPE); } } catch (IOException * e) { throw new Exception("Could not to set file type.", e); } } */ /** * 连接到ftp服务器 * * @param ftpClient * @return 连接成功返回true，否则返回false * @throws Exception */ public boolean connect() { return getFTPClient(); } /* * private Boolean connectServer() { * * try { ftpClient.connect(pro.getProperty("host"), * Integer.parseInt(pro.getProperty("port"))); * * ftpClient.setConnectTimeout(Integer.parseInt(pro * .getProperty("clientTimeout"))); * * // 连接后检测返回码来校验连接是否成功 int reply = ftpClient.getReplyCode(); * * if (FTPReply.isPositiveCompletion(reply)) { // 登陆到ftp服务器 if * (ftpClient.login(pro.getProperty("username"), * pro.getProperty("password"))) { try { if * (Boolean.parseBoolean(pro.getProperty("binaryTransfer"))) { * ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); } else { * ftpClient.setFileType(FTPClient.ASCII_FILE_TYPE); } } catch (IOException * e) { log.debug("Could not to set file type.", e); * * return false; //throw new Exception("Could not to set file type.", e); } * return true; } } else { return false; } } catch (IOException e) { if * (ftpClient.isConnected()) { try { ftpClient.disconnect(); // 断开连接 } catch * (IOException e1) { log.debug("Could not disconnectfrom server.", e1); * return false; // throw new Exception("Could not disconnectfrom server.", * // e1); } } } * * return false; } */ /** * 返回一个FTPClient实例 * * @throws Exception */ private boolean getFTPClient() { // 构造一个FtpClient例 ftpClient.setControlEncoding(pro.getProperty("encoding")); // 设置字符集 // 连接ftp服务器 try { ftpClient.connect(pro.getProperty("host"), Integer.parseInt(pro.getProperty("port"))); ftpClient.setConnectTimeout(Integer.parseInt(pro .getProperty("clientTimeout"))); // 连接后检测返回码来校验连接是否成功 int reply = ftpClient.getReplyCode(); if (FTPReply.isPositiveCompletion(reply)) { // 登陆到ftp服务器 if (ftpClient.login(pro.getProperty("username"), pro.getProperty("password"))) { try { if (Boolean.parseBoolean(pro .getProperty("binaryTransfer"))) { ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); } else { ftpClient.setFileType(FTPClient.ASCII_FILE_TYPE); } } catch (IOException e) { log.debug("Could not to set file type.", e); return false; // throw new Exception("Could not to set file type.", // e); } } else { ftpClient.disconnect(); return false; } } else { return false; } // 设置为passive模式 if (Boolean.parseBoolean(pro.getProperty("passiveMode"))) { ftpClient.enterLocalPassiveMode(); } // 设置文件传输类型 if (Boolean.parseBoolean(pro.getProperty("binaryTransfer"))) { ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); } else { ftpClient.setFileType(FTPClient.ASCII_FILE_TYPE); } ftpClient.setSoTimeout(Integer.parseInt(pro .getProperty("clientTimeout"))); } catch (SocketException e) { log.debug("Set timeout error.", e); return false; } catch (IOException e1) { log.debug("Could not connect server.", e1); return false; } return true; } /** * 断开ftp连接 * * @throws Exception */ public void disconnect() throws Exception { ftpClient.logout(); if (ftpClient.isConnected()) { ftpClient.disconnect(); ftpClient = new FTPClient(); } } /** * 在本地创建目录 * * @throws Exception */ public boolean createDir(){ return mkdir(pro.getProperty("localAbsoluteile")); } private boolean mkdir(String localAbsoluteile) { StringTokenizer st = new StringTokenizer(localAbsoluteile, "/"); String path1 = st.nextToken() + "/"; String path2 = path1; while (st.hasMoreTokens()) { try { path1 = st.nextToken() + "/"; path2 += path1; File inbox = new File(path2); if (!inbox.exists()) inbox.mkdir(); } catch (Exception e) { log.debug("创建目录失败", e); return false; // throw new Exception("创建目录失败", e); } } return true; } /** * 下载一个远程文件到指定的流 处理完后记得关闭流 * * @param remoteAbsoluteFile * @param output * @return * @throws Exception */ @SuppressWarnings("unused") private void get(String remoteAbsoluteFile, OutputStream output) throws Exception { get(remoteAbsoluteFile, output, true); } /** * 下载一个远程文件到指定的流 处理完后记得关闭流 * * @param remoteAbsoluteFile * @param output * @param delFile * @return * @throws Exception */ private void get(String remoteAbsoluteFile, OutputStream output, boolean autoClose) throws Exception { try { // 处理传输 ftpClient.retrieveFile(remoteAbsoluteFile, output); //output.flush(); } catch (IOException e) { log.debug("Couldn't get file from serve.", e); disconnect(); } } /** * 下载一个远程文件到本地的指定文件 * * @param remoteAbsoluteFile * 远程文件名(包括完整路径) * @param localAbsoluteFile * 本地文件名(包括完整路径) * @param autoClose * 是否自动关闭当前连接 * * @return 成功时，返回true，失败返回false * @throws Exception */ public boolean downFile() { return get(pro.getProperty("remoteAbsoluteFile"), pro.getProperty("localAbsoluteile"), Boolean.parseBoolean(pro.getProperty("autoClose")), pro.getProperty("extName")); } private boolean get(String remoteAbsoluteFile, String localAbsoluteile, boolean autoClose, String extN