sun.net.ftp.FtpClient

package classTest;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.List;

import sun.net.TelnetInputStream;
import sun.net.TelnetOutputStream;
import sun.net.ftp.FtpClient;

public class FtpOperation {
	private FtpClient client = new FtpClient();
	
	/**
	 * 登录FTP，并返回登录是否成功的Boolean值
	 * @param host
	 * @param port
	 * @param user
	 * @param password
	 * @return
	 */
	public boolean login(String host, int port, String user, String password) {
		boolean flag = true;
		try {
			client.openServer(host, port);
			client.login(user, password);
		} catch (IOException e) {
			e.printStackTrace();
			flag = false;
		}
		return flag;
	}
	/**
	 * 关闭FTP连接
	 */
	public void close() {
		if(client.serverIsOpen()) {
			try {
				client.closeServer();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
	
	/**
	 * 在父级节点创建子节点目录，如果父级节点为根节点parent可以为空或“/”
	 * @param parent
	 * @param path
	 * @return
	 */
	public boolean makeDir(String parent, String path) {
		boolean flag = true;
		flag = cdAssignPath(parent);
		if(flag) {
			try {
				//创建已经存在的目录会报错
				client.sendServer("MKD " + path + "\r\n");
			}catch (Exception e) {
				e.printStackTrace();
				flag = false;
			}
		}
		return flag;
	}
	
	/**
	 * 上传文件
	 * @param path保存FTP位置
	 * @param file要上传的文件
	 * @param remoteName在FTP保存时的名字
	 */
	public void upload(String path, File file, String remoteName) {
		TelnetOutputStream write = null;
		FileInputStream read = null;
		byte[] by = new byte[1024];
		try {
			if(cdAssignPath(path)) {
				read = new FileInputStream(file);
				write = client.put(remoteName);
				while(read.read(by) != -1) {
					write.write(by);
				}
			}
		}catch (Exception e) {
			e.printStackTrace();
		} finally {
			if (read != null) {
				try {
					read.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
			if (write != null) {
				try {
					write.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
	}
	
	/**
	 * 下载文件
	 * @param remotePath
	 * @param remoteName
	 * @param localPath
	 * @param localName
	 */
	public void download(String remotePath, String remoteName, String localPath, String localName) {
		byte[] by = new byte[1024];
		if(cdAssignPath(remotePath)) {
			try {
				TelnetInputStream read = client.get(remoteName);
				File file = new File(localPath);
				if(!file.exists()) {
					file.mkdirs();
				}
				FileOutputStream write = new FileOutputStream(new File(localPath + "/" + localName));
				while(read.read(by) > 0) {
					write.write(by);
				}
				read.close();
				write.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
	
	/**
	 * 获取指定路径下的文件列表
	 * @param path
	 * @return
	 */
	public List<String> ls(String path) {
		List<String> list = new ArrayList<String>();
		if(cdAssignPath(path)) {
			String line = "";
			BufferedReader ls;
			try {
				ls = new BufferedReader(new InputStreamReader(client.list()));
				while((line = ls.readLine()) != null) {
					//文件列表显示格式：-rw-r--r-- 1 ftp ftp              4 Jul 02 17:23 zqz.txt
					String[] array = line.split(" ");
					list.add(array[array.length -1]);
				}
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		System.out.println(list);
		return list;
	}
	/**
	 * 切换当前目录当根目录
	 */
	private void cdRoot() {
		try {
			while(!"/".equals(client.pwd())) {
				client.cdUp();
			}
			System.out.println(client.pwd());
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	/**
	 * 切换当前目录到指定路径，该路径必须从根路径开始
	 * @param path
	 * @return
	 */
	public boolean cdAssignPath(String path) {
		boolean flag = true;
		cdRoot();
		try {
			client.cd(path);
			System.out.println(client.pwd());
		} catch (IOException e) {
			e.printStackTrace();
			flag = false;
		}
		return flag;
	}
}