`
_gougang
  • 浏览: 33579 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

java FTP 上传 下载 (中文 ) 文件

    博客分类:
  • java
阅读更多
最近需要做一个 上传zip文件到ftp服务器的功能。在网上找了一些资料终于成功了,包括
上传  下载  和 列出所有文件。 以及各种中文乱码的解决:以下是代码:具体的文件和所需jar包在附件中
package com.galen;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;

import org.apache.commons.io.FileUtils;
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;

public class FTPHandle {
	private String username;
	private String password;
	private String ip;
	private int port;
	private static Properties property = null;// 配置
	private String configFile;// 配置文件的路径名
	private FTPClient ftpClient = null;
	private String filedir = "";// FTP文件路径
	private final String[] FILE_TYPES = { "文件", "目录", "符号链接", "未知类型" };
	private static SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm");

	/**
	 * 设置参数
	 * @param configFile  --参数的配置文件
	 */
	private void setArg(String configFile) {
		property = new Properties();
		BufferedInputStream inBuff = null;
		try {
			inBuff = new BufferedInputStream(new FileInputStream(new File(
					System.getProperty("user.dir") + configFile)));
			property.load(inBuff);
			username = property.getProperty("username");
			password = property.getProperty("password");
			ip = property.getProperty("ip");
			port = Integer.parseInt(property.getProperty("port"));
			filedir = property.getProperty("filedir");
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				if (inBuff != null)
					inBuff.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

	/**
	 * 设置FTP客服端的配置--一般可以不设置
	 * @return
	 */
	private FTPClientConfig getFtpConfig() {
		FTPClientConfig ftpConfig = new FTPClientConfig(FTPClientConfig.SYST_UNIX);
		ftpConfig.setServerLanguageCode(FTP.DEFAULT_CONTROL_ENCODING);
		return ftpConfig;
	}

	/**
	 * 连接到服务器
	 */
	public void connectServer() {
		if (ftpClient == null) {
			int reply;
			try {
				setArg(configFile);
				ftpClient = new FTPClient();
				ftpClient.configure(getFtpConfig());
				ftpClient.connect(ip);
				ftpClient.login(username, password);
				ftpClient.setDefaultPort(port);
				ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);//此设置可以用来上传BINARY二进制文件 比如 XXX.zip 
				System.out.print(ftpClient.getReplyString());
				reply = ftpClient.getReplyCode();

				if (!FTPReply.isPositiveCompletion(reply)) {
					ftpClient.disconnect();
					System.err.println("FTP server refused connection.");
				}
			} catch (Exception e) {
				System.err.println("登录ftp服务器【" + ip + "】失败");
				e.printStackTrace();
			}
		}
	}

	/**
	 * 进入到服务器的某个目录下
	 * @param directory
	 */
	public void changeWorkingDirectory() {
		try {
			ftpClient.changeWorkingDirectory(filedir);
		} catch (IOException ioe) {
			ioe.printStackTrace();
		}
	}

	/**
	 * 上传文件
	 * 
	 * @param inputStream
	 *            --文件输入流
	 * @param newFileName
	 *            --新的文件名
	 */
	public void uploadFile(InputStream inputStream, String newFileName) {
		changeWorkingDirectory();// 进入文件夹
		// 上传文件
		BufferedInputStream buffIn = null;
		try {
			buffIn = new BufferedInputStream(inputStream);
			ftpClient.storeFile(newFileName, buffIn);

		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				if (buffIn != null)
					buffIn.close();
				inputStream.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

	public static void main(String[] args) throws Exception {
		InputStream is = new FileInputStream(new File(
				"d:\\temp\\CESQL071454545.txt"));
		FTPHandle fh = new FTPHandle();
		fh.setConfigFile("/ftpupload.properties");
		fh.connectServer();
		/* 上传文件 */
		//fh.uploadFile(is, new String("CESQL071454545.txt".getBytes("GBK"),"iso-8859-1"));
		/* 删除文件 */
		// fh.deleteFile("CESQL071454545.txt");
		/* 遍历文件 */
		List<Map> files = fh.listRemoteFiles("/bo");
		for (int i = 0; i < files.size(); i++) {
			Map file = files.get(i);
			System.out.print(file.get("filename"));
			System.out.print("\t\t" + file.get("filesize") + "\t\t");
			System.out.println(file.get("scsj"));
		}
		/* 下载文件 */
		fh.loadFile(new String("测试.zip".getBytes("GBK"), "ISO-8859-1"),
				"d:\\temp\\测试.zip");
		fh.closeConnect();

	}

	/**
	 * 列出服务器上文件和目录
	 * 
	 * @param regStr
	 *            --匹配的正则表达式
	 */
	@SuppressWarnings("unchecked")
	public List listRemoteFiles(String regStr) {
		List list = new ArrayList();
		try {
			ftpClient.setControlEncoding("GBK");
			FTPFile[] files = ftpClient.listFiles(regStr);
			if (files == null || files.length == 0) {
				System.out.println("There has not any file!");
				return null;
			} else {
				for (FTPFile file : files) {
					if (file != null) {
						Map map = new HashMap();
						String filename = new String(file.getName().getBytes(
								"GBK"), "iso-8859-1");
						int filenamelen = filename.length();
						if (filenamelen > 4) {
							String filetype = filename
									.substring(filenamelen - 3);
							if (true) {
								String name = file.getName();
								// name = name.substring(0,name.length()-4);
								map.put("filename", name);
								map.put("filesize", FileUtils
										.byteCountToDisplaySize(file.getSize()));
								map.put("scsj", dateFormat.format(file
										.getTimestamp().getTime()));
								list.add(map);
							}
						}
					}
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return list;
	}

	/**
	 * 下载文件
	 * 
	 * @param remoteFileName
	 *            --服务器上的文件名
	 * @param localFileName
	 *            --本地文件名
	 */
	public void loadFile(String remoteFileName, String localFileName) {
		// 下载文件
		BufferedOutputStream buffOut = null;
		try {
			buffOut = new BufferedOutputStream(new FileOutputStream(
					localFileName));
			ftpClient.setControlEncoding("GBK");
			ftpClient.retrieveFile(remoteFileName, buffOut);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				if (buffOut != null)
					buffOut.close();
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}

	/**
	 * 删除文件
	 */
	public void deleteFile(String filename) {
		try {
			ftpClient.deleteFile(filename);
		} catch (IOException ioe) {
			ioe.printStackTrace();
		}
	}

	/**
	 * 关闭连接
	 */
	public void closeConnect() {
		try {
			if (ftpClient != null) {
				ftpClient.logout();
				ftpClient.disconnect();
				System.out.println("Ftp have closed");
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public String getConfigFile() {
		return configFile;
	}

	public void setConfigFile(String configFile) {
		this.configFile = configFile;
	}

	public String[] getFILE_TYPES() {
		return FILE_TYPES;
	}

	public FTPClient getFtpClient() {
		return ftpClient;
	}

	public void setFtpClient(FTPClient ftpClient) {
		this.ftpClient = ftpClient;
	}

	public String getIp() {
		return ip;
	}

	public void setIp(String ip) {
		this.ip = ip;
	}

	public String getPassword() {
		return password;
	}

	public void setPassword(String password) {
		this.password = password;
	}

	public int getPort() {
		return port;
	}

	public void setPort(int port) {
		this.port = port;
	}

	public Properties getProperty() {
		return property;
	}

	public void setProperty(Properties property) {
		this.property = property;
	}

	public String getUsername() {
		return username;
	}

	public void setUsername(String username) {
		this.username = username;
	}

	public String getFiledir() {
		return filedir;
	}

	public void setFiledir(String filedir) {
		this.filedir = filedir;
	}
}



分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics