Java的ftp上传下载工具

 

自己写的利用apache的net包写的ftp的上传、下载功能，可以上单个文件、文件夹，下载单个文件及文件夹整个目录，并且解决了文件、文件夹汉字问题，经过自己的正式测试。

        不讲废话了，直接上代码，愿给需要的朋友提供个帮助。

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.util.Properties;

import org.apache.commons.lang.StringUtils;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPClientConfig;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
import org.d6.utils.AppUtils;

/**
 * @author jjl
 * 
 */
public class FtpUtil {
	static String ftpUrl = null; // ftp 服务器路径
	static int ftpPort = 21; // ftp 服务器端口
	static String ftpUserName = null; // ftp 服务器用户名
	static String ftpPassword = null; // ftp 服务器密码
	static String encoding = null;
	static String serverLanguageCode = FTP.DEFAULT_CONTROL_ENCODING;
	static int timeout = 60000;
	// 配置文件路径
	static String configFile =  "ftp.properties";

	static FTPClient ftpClient = null;

	/**
	 * 创建FTPClient
	 * 
	 * @throws Exception
	 */
	private static void createFtpClient() throws Exception {
		if (ftpClient == null) {
			ftpClient = new FTPClient();
			setConnectConfig();
			connectFtp(ftpClient);
		}
	}

	/**
	 * 关闭FTPClient
	 * 
	 * @throws Exception
	 */
	private static void closeFtpClient() throws Exception {
		if (ftpClient != null) {
			ftpClient.logout();
			if (ftpClient.isConnected()) {
				ftpClient.disconnect();
			}
			ftpClient = null;
		}
	}

	/**
	 * ftp工具连接
	 * 
	 * @param ftpClient
	 * @return
	 * @throws Exception
	 */
	public static boolean connectFtp(FTPClient ftpClient) throws Exception {
		// 如果采用默认端口，可以使用ftp.connect(url)的方式直接连接FTP服务器
		ftpClient.connect(ftpUrl, ftpPort);
		
		getFtpConfig();

		// 返回登录情况
		boolean isConnect = ftpClient.login(ftpUserName, ftpPassword);

		ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
		// ftpClient.enterLocalPassiveMode();
		ftpClient.setFileTransferMode(FTPClient.STREAM_TRANSFER_MODE);
		ftpClient.setControlEncoding(encoding);
		
		// 设置连接时间
		ftpClient.setDataTimeout(timeout);
		// 返回代码
		int reply = ftpClient.getReplyCode();
		if (isConnect && FTPReply.isPositiveCompletion(reply)) {
			return true;
		}
		return false;
	}

	/**
	 * 上传文件
	 * 
	 * @param localPath
	 *            本地文件路径
	 * @param filename
	 *            本地文件名
	 * @param remotePath
	 *            服务器文件路径
	 * @return 成功返回true，否则返回false
	 * @throws Exception
	 */
	public static boolean uploadFile(File file, String remotePath)
			throws Exception {
		boolean success = false;

		try {
			// 创建FTPClient
			createFtpClient();

			// 判断是文件，还是文件目录
			if (file.isDirectory()) {
				success = uploadAll(file, remotePath + File.separator
						+ file.getName());
			} else {
				success = upload(file, remotePath);
			}

			// 关闭连接
			closeFtpClient();
		} catch (IOException e) {
			e.printStackTrace();
		}

		// 返回
		return success;
	}

	/**
	 * 上传文件
	 * 
	 * @param file
	 * @param remotePath
	 * @return
	 * @throws Exception
	 */
	private static boolean upload(File file, String remotePath)
			throws Exception {
		boolean success;
		// 文件
		FileInputStream inputStream = new FileInputStream(file);
		// 切换ftp工作目录
		changeWorkingDirectory(remotePath);

		// 上传文件
		success = ftpClient.storeFile(encodingGBKToISO8859(file.getName()),
				inputStream);

		inputStream.close();
		return success;
	}

	/**
	 * 上传文件
	 * 
	 * @param localPath
	 *            本地文件路径
	 * @param filename
	 *            本地文件名
	 * @param remotePath
	 *            服务器文件路径
	 * @return
	 * @throws Exception
	 */
	public static boolean uploadFile(String localPath, String filename,
			String remotePath) throws Exception {
		File file = new File(localPath + File.separator + filename);
		return uploadFile(file, remotePath);
	}

	/**
	 * 上传文件目录
	 * 
	 * @param file
	 * @param remotePath
	 * @return
	 * @throws Exception
	 */
	public static boolean uploadDirectory(String localPath, String remotePath)
			throws Exception {
		return uploadDirectory(new File(localPath), remotePath);
	}

	/**
	 * 上传文件目录
	 * 
	 * @param file
	 * @param remotePath
	 * @return
	 * @throws Exception
	 */
	public static boolean uploadDirectory(File file, String remotePath)
			throws Exception {
		boolean success = false;
		// 创建FTPClient
		createFtpClient();

		success = uploadAll(file, remotePath);

		// 关闭连接
		closeFtpClient();
		return success;
	}

	/**
	 * 上传
	 * 
	 * @param file
	 * @param remotePath
	 * @throws Exception
	 * @throws FileNotFoundException
	 * @throws IOException
	 */
	private static boolean uploadAll(File file, String remotePath)
			throws Exception {
		boolean success = false;
		// 得到文件列表
		File[] fileList = file.listFiles();
		for (File uploadFile : fileList) {
			// 循环子目录
			if (uploadFile.isDirectory()) {
				ftpClient.changeWorkingDirectory(remotePath);
				ftpClient.makeDirectory(uploadFile.getName());
				success = uploadAll(uploadFile, remotePath + File.separator
						+ uploadFile.getName());
			} else {
				// 上传文件
				success = upload(uploadFile, remotePath);
			}
		}
		return success;
	}

	/**
	 * 下载文件目录下所有文件
	 * 
	 * @param localPath
	 *            本地文件路径
	 * @param fileName
	 *            本地文件名
	 * @param remotePath
	 *            服务器路径
	 * @return 成功返回true，否则返回false
	 * @throws Exception
	 */
	public static boolean downloadDirectory(String localPath, String remotePath)
			throws Exception {
		boolean success = false;

		try {
			// 创建FTPClient
			createFtpClient();

			success = downloadAll(localPath, remotePath);

			// 关闭连接FTPClient
			closeFtpClient();
		} catch (IOException e) {
			e.printStackTrace();
		}

		return success;
	}

	/**
	 * 下载文件目录下的所有文件
	 * 
	 * @param localPath
	 * @param remotePath
	 * @param success
	 * @return
	 * @throws IOException
	 * @throws Exception
	 * @throws FileNotFoundException
	 */
	private static boolean downloadAll(String localPath, String remotePath)
			throws Exception {
		boolean success = false;

		// 切换ftp工作目录
		changeWorkingDirectory(remotePath);
		// 取出下载文件
		FTPFile[] ftpFiles = ftpClient.listFiles();
		for (FTPFile ftpFile : ftpFiles) {
			// 过滤文件名不正确的文件
			if (ftpFile.getName().equals(".") || ftpFile.getName().equals("..")) {
				continue;
			}
			if (ftpFile.isDirectory()) {
				// 创建目录
				File fileDir = new File(localPath + File.separator
						+ ftpFile.getName());
				if (!fileDir.exists()) {
					fileDir.mkdirs();
				}
				// 下载文件
				success = downloadAll(localPath + File.separator
						+ ftpFile.getName(), remotePath + File.separator
						+ ftpFile.getName());
			} else {
				// 切换ftp工作目录
				changeWorkingDirectory(remotePath);
				// 下载文件
				success = download(localPath, ftpFile);
			}
		}
		return success;
	}

	/**
	 * 切换ftp工作目录
	 * 
	 * @param remotePath
	 * @throws IOException
	 */
	private static void changeWorkingDirectory(String remotePath)
			throws IOException {
		// 转移到FTP服务器目录
		ftpClient.changeWorkingDirectory("/");
		if (StringUtils.isNotBlank(remotePath)) {
			ftpClient.changeWorkingDirectory(remotePath);
		}
	}

	/**
	 * @param localPath
	 * @param ftpFile
	 * @return
	 * @throws Exception
	 */
	private static boolean download(String localPath, FTPFile ftpFile)
			throws Exception {
		boolean success;
		// 文件目录不存在创建文件
		File fileDir = new File(localPath);
		if (!fileDir.exists()) {
			fileDir.mkdirs();
		}

		File localFile = new File(localPath + File.separator
				+ ftpFile.getName());

		OutputStream is = new FileOutputStream(localFile);
		// 下载文件
		success = ftpClient.retrieveFile(
				encodingGBKToISO8859(ftpFile.getName()), is);
		is.close();
		return success;
	}

	/**
	 * 下载文件
	 * 
	 * @param localPath
	 *            本地文件路径
	 * @param fileName
	 *            本地文件名
	 * @param remotePath
	 *            服务器路径
	 * @return 成功返回true，否则返回false
	 * @throws Exception
	 */
	public static boolean downloadFile(String localPath, String fileName,
			String remotePath) throws Exception {
		boolean success = false;

		try {
			// 创建FTPClient
			createFtpClient();

			// 转移到FTP服务器目录
			if (StringUtils.isNotBlank(remotePath)) {
				ftpClient.changeWorkingDirectory(remotePath);
			}

			// 取出下载文件
			FTPFile[] ftpFiles = ftpClient.listFiles();
			for (FTPFile ftpFile : ftpFiles) {
				String ftpFileName = ftpFile.getName();
				if (ftpFileName.equals(fileName)) {
					success = download(localPath, ftpFile);
					break;
				}
			}

			// 关闭连接FTPClient
			closeFtpClient();
		} catch (IOException e) {
			e.printStackTrace();
		}

		return success;
	}

	/**
	 * 删除一个文件
	 * 
	 * @throws Exception
	 */
	public static boolean deleteFile(String filename) throws Exception {
		boolean flag = true;
		try {
			// 创建FTPClient
			createFtpClient();
			// 删除文件
			flag = ftpClient.deleteFile(filename);
		} catch (IOException ioe) {
			ioe.printStackTrace();
		} finally {
			// 关闭连接FTPClient
			closeFtpClient();
		}

		return flag;
	}

	/**
	 * 删除目录
	 * 
	 * @throws Exception
	 */
	public static void deleteDirectory(String pathname) throws Exception {
		try {
			// 创建FTPClient
			createFtpClient();
			File file = new File(pathname);
			if (!file.isDirectory()) {
				deleteFile(pathname);
			}
			ftpClient.removeDirectory(pathname);
		} catch (IOException ioe) {
			ioe.printStackTrace();
		} finally {
			// 关闭连接FTPClient
			closeFtpClient();
		}
	}

	/**
	 * 设置参数
	 * 
	 * @param configFile
	 *            --参数的配置文件
	 */
	private static void setConnectConfig() {
		Properties property = new Properties();
		BufferedInputStream bis = null;
		try {
			// 读取配置文件
			File file = new File(configFile);
			bis = new BufferedInputStream(new FileInputStream(file));
			property.load(bis);

			// 设置文件信息
			ftpUserName = property.getProperty("ftp.userName");
			ftpPassword = property.getProperty("ftp.password");
			ftpUrl = property.getProperty("ftp.url");
			ftpPort = Integer.parseInt(property.getProperty("ftp.port"));
			encoding = property.getProperty("ftp.encoding");
			serverLanguageCode = property.getProperty("ftp.serverLanguageCode");

			// 关闭文件
			if (bis != null){
				bis.close();
			}
		} catch (FileNotFoundException e1) {
			System.out.println("配置文件 " + configFile + " 不存在！");
		} catch (IOException e) {
			System.out.println("配置文件 " + configFile + " 无法读取！");
		}
	}

	/**
	 * 重命名文件
	 * 
	 * @param oldName
	 *            原文件名
	 * @param newName
	 *            新文件名
	 * @throws Exception
	 */
	public static void renameFile(String oldName, String newName)
			throws Exception {
		try {
			// 创建FTPClient
			createFtpClient();

			// 重命名
			ftpClient.rename(oldName, newName);
		} catch (IOException ioe) {
			ioe.printStackTrace();
		} finally {
			// 关闭连接FTPClient
			closeFtpClient();
		}
	}

	/**
	 * 设置FTP客服端的配置
	 * 
	 * @return ftpConfig
	 */
	private static FTPClientConfig getFtpConfig() {
		// FTPClientConfig.SYST_UNIX
		FTPClientConfig ftpConfig = new FTPClientConfig(FTPClientConfig.SYST_NT);
		ftpConfig.setServerLanguageCode(serverLanguageCode);
		return ftpConfig;
	}

	/**
	 * 将ISO-8859-1编码转为 GBK
	 * 
	 * @param obj
	 * @return ""
	 * @throws Exception
	 */
	private static String encodingToGBK(Object obj) throws Exception {
		if (obj != null) {
			return new String(obj.toString().getBytes("iso-8859-1"), encoding);
		}
		return null;
	}

	/**
	 * 将 GBK编码转为ISO-8859-1
	 * 
	 * @param obj
	 * @return ""
	 * @throws Exception
	 */
	private static String encodingGBKToISO8859(Object obj) throws Exception {
		if (obj != null) {
			return new String(obj.toString().getBytes(encoding), "iso-8859-1");
		}
		return null;
	}

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		boolean success = false;
		try {
			java.text.SimpleDateFormat dateFormat = new java.text.SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
//			success = FtpUtil.uploadFile("D:\\ftp", "中文的.docx", "temp");
//			System.out.println(success);
			//
			// success = FtpUtil.uploadFile(new File("D:\\ftp\\abc.txt"),
			// "temp");
			// System.out.println(success);

			// success = FtpUtil.uploadDirectory("D:\\ftp", "temp");
			// System.out.println(success);

			System.out.println(dateFormat.format(new java.util.Date()));
			success = FtpUtil.downloadFile("d:\\", "test.zip",
					"temp");
			System.out.println(dateFormat.format(new java.util.Date()));
			System.out.println(success);

			// success = FtpUtil.downloadDirectory("d:\\ftp\\a2", "temp");
			// System.out.println(success);
		} catch (Exception e) {
			System.out.println(e.getMessage());
		}

	}

}