欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识！
您现在的位置是： 首页

Java的ftp上传下载工具 博客分类： java

程序员文章站 2024-03-19 16:16:16
...

 

自己写的利用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());
		}

	}

}
 

 

上一篇： 详解JRE和JDK的区别 博客分类： Java JDKJava应用服务器企业应用浏览器 

下一篇： 分布式id生成策略，我和面试官扯了一个半小时

推荐阅读