Apache FTP多线程文件上传、下载、修改文件名、删除

请参考上一篇章：Apache FTP文件上传、下载、修改文件名、删除

此处实现多线程对FTP文件的操作，FTPStatus来自上一篇文章，下附工具代码。

package com.scengine.wtms.utils.ftp;
 
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.SocketException;
 
import javax.servlet.http.HttpServletResponse;
 
import org.apache.commons.net.PrintCommandListener;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
 
import com.scengine.wtms.utils.Log;
 
public class ThreadFTPUtils  implements Runnable
{
	private UserInfo userInfo;
	
    private FTPClient ftpClient = new FTPClient();
	
	private FTPType ftpType;
	
	public FTPType getFtpType()
	{
		return ftpType;
	}
 
	public void setFtpType(FTPType ftpType)
	{
		this.ftpType = ftpType;
	}
 
	public static enum FTPType{
		
		UPLOAD(0),DOWNLOAD(1),RENAME(2),DELETE(3);
		
		private int type;
		
		public int getType()
		{
			return type;
		}
		public void setType(int type)
		{
			this.type = type;
		}
		FTPType(int type){
			this.type=type;
		}
	}
 
 
	/**
	 * 对象构造 设置将过程中使用到的命令输出到控制台
	 */
	public ThreadFTPUtils(String ip,int port,String username,String password,String local,String remote,FTPType ftpType)
	{
		userInfo=new UserInfo(ip, port, username, password, local, remote);
		this.ftpType=ftpType;
		this.ftpClient.addProtocolCommandListener(new PrintCommandListener(new PrintWriter(System.out)));
	}
 
	/**
	 * 
	 * java编程中用于连接到FTP服务器
	 * 
	 * @param hostname
	 *            主机名
	 * 
	 * @param port
	 *            端口
	 * 
	 * @param username
	 *            用户名
	 * 
	 * @param password
	 *            密码
	 * 
	 * @return 是否连接成功
	 * 
	 * @throws IOException
	 */
 
	public boolean connect(String hostname, int port, String username, String password) throws IOException
	{
 
		ftpClient.connect(hostname, port);
 
		if (FTPReply.isPositiveCompletion(ftpClient.getReplyCode()))
		{
 
			if (ftpClient.login(username, password))
			{
				return true;
			}
		}
		disconnect();
		return false;
	}
 
	/**
	 * 删除远程FTP文件
	 * 
	 * @param remote
	 *            远程文件路径
	 * @return
	 * @throws IOException
	 */
	public FTPStatus delete(String remote) throws IOException
	{
		ftpClient.enterLocalPassiveMode();
 
		ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
 
		FTPStatus result = null;
 
		FTPFile[] files = ftpClient.listFiles(remote);
		if (files.length == 1)
		{
			boolean status = ftpClient.deleteFile(remote);
			result = status ? FTPStatus.Delete_Remote_Success : FTPStatus.Delete_Remote_Faild;
		}
		else
		{
			result = FTPStatus.Not_Exist_File;
		}
		Log.getLogger(this.getClass()).info("FTP服务器文件删除标识："+result);
		return result;
	}
	
	/**
	 * 重命名远程FTP文件
	 * 
	 * @param name
	 *            新远程文件名称(路径-必须保证在同一路径下)
	 *            
	 * @param remote
	 *            远程文件路径
	 *            
	 * @return  是否成功
	 * 
	 * @throws IOException
	 */
	public FTPStatus rename(String name,String remote) throws IOException
	{
		ftpClient.enterLocalPassiveMode();
 
		ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
 
		FTPStatus result = null;
 
		FTPFile[] files = ftpClient.listFiles(remote);
		if (files.length == 1)
		{
			boolean status = ftpClient.rename(remote, name);
			result = status ? FTPStatus.Remote_Rename_Success : FTPStatus.Remote_Rename_Faild;
		}
		else
		{
			result = FTPStatus.Not_Exist_File;
		}
		Log.getLogger(this.getClass()).info("FTP服务器文件名更新标识："+result);
		return result;
	}
	
	/**
	 * 
	 * 从FTP服务器上下载文件
	 * 
	 * @param fileName
	 *            下载文件的名字(包括后缀名)
	 * 
	 * @param remote
	 *            远程文件路径
	 * 
	 * @param local
	 *            本地文件路径
	 * 
	 * @return 是否成功
	 * 
	 * @throws IOException
	 */
 
	public FTPStatus download(String fileName,String remote,HttpServletResponse response) throws IOException
	{
		// 开启输出流弹出文件保存路径选择窗口
		response.setContentType("application/octet-stream");
		
        response.setContentType("application/OCTET-STREAM;charset=UTF-8");
        
        response.setHeader("Content-Disposition", "attachment;filename=" +fileName);
 
		ftpClient.enterLocalPassiveMode();
 
		ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
		
		FTPStatus result;
		
		OutputStream out = response.getOutputStream();
		
		boolean status = ftpClient.retrieveFile(remote, out);
		
		result=status?FTPStatus.Download_From_Break_Success:FTPStatus.Download_From_Break_Faild;
		
		Log.getLogger(this.getClass()).info("FTP服务器文件下载标识："+result);
		
		out.close();
		
		return result;
	}
 
	/**
	 * 
	 * 从FTP服务器上下载文件
	 * 
	 * @param remote
	 *            远程文件路径
	 * 
	 * @param local
	 *            本地文件路径
	 * 
	 * @return 是否成功
	 * 
	 * @throws IOException
	 */
 
	@SuppressWarnings("resource")
	public FTPStatus download(String remote, String local) throws IOException
	{
 
		ftpClient.enterLocalPassiveMode();
 
		ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
 
		FTPStatus result;
 
		File f = new File(local);
 
		FTPFile[] files = ftpClient.listFiles(remote);
 
		if (files.length != 1)
		{
			Log.getLogger(this.getClass()).info("远程文件不唯一");
			return FTPStatus.File_Not_Unique;
		}
 
		long lRemoteSize = files[0].getSize();
 
		if (f.exists())
		{
			OutputStream out = new FileOutputStream(f, true);
			Log.getLogger(this.getClass()).info("本地文件大小为:" + f.length());
 
			if (f.length() >= lRemoteSize)
			{
 
				Log.getLogger(this.getClass()).info("本地文件大小大于远程文件大小，下载中止");
				return FTPStatus.Remote_smaller_local;
 
			}
 
			ftpClient.setRestartOffset(f.length());
 
			boolean status = ftpClient.retrieveFile(remote, out);
			result=status?FTPStatus.Download_From_Break_Success:FTPStatus.Download_From_Break_Faild;
			out.close();
 
		} else
		{
			OutputStream out = new FileOutputStream(f);
			boolean status = ftpClient.retrieveFile(remote, out);
			result=status?FTPStatus.Download_From_Break_Success:FTPStatus.Download_From_Break_Faild;
			out.close();
		}
 
		return result;
 
	}
 
	/**
	 * 
	 * 上传文件到FTP服务器，支持断点续传
	 * 
	 * @param local
	 *            本地文件名称，绝对路径
	 * 
	 * @param remote
	 *            远程文件路径，使用/home/directory1/subdirectory/file.ext
	 *            按照Linux上的路径指定方式，支持多级目录嵌套，支持递归创建不存在的目录结构
	 * 
	 * @return 上传结果
	 * 
	 * @throws IOException
	 */
 
	@SuppressWarnings("resource")
	public FTPStatus upload(String local, String remote) throws IOException
	{
		// 设置PassiveMode传输
		ftpClient.enterLocalPassiveMode();
 
		// 设置以二进制流的方式传输
		ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
 
		FTPStatus result;
 
		// 对远程目录的处理
		String remoteFileName = remote;
 
		if (remote.contains("/"))
		{
 
			remoteFileName = remote.substring(remote.lastIndexOf("/") + 1);
 
			String directory = remote.substring(0, remote.lastIndexOf("/") + 1);
 
			if (!directory.equalsIgnoreCase("/") && !ftpClient.changeWorkingDirectory(directory))
			{
 
				// 如果远程目录不存在，则递归创建远程服务器目录
 
				int start = 0;
 
				int end = 0;
 
				if (directory.startsWith("/"))
				{
 
					start = 1;
 
				} else
				{
 
					start = 0;
 
				}
 
				end = directory.indexOf("/", start);
 
				while (true)
				{
 
					String subDirectory = remote.substring(start, end);
 
					if (!ftpClient.changeWorkingDirectory(subDirectory))
					{
 
						if (ftpClient.makeDirectory(subDirectory))
						{
 
							ftpClient.changeWorkingDirectory(subDirectory);
 
						} else
						{
 
							Log.getLogger(this.getClass()).info("创建目录失败");
 
							return FTPStatus.Create_Directory_Fail;
 
						}
 
					}
 
					start = end + 1;
 
					end = directory.indexOf("/", start);
 
					// 检查所有目录是否创建完毕
 
					if (end <= start)
					{
 
						break;
 
					}
 
				}
 
			}
 
		}
 
		// 检查远程是否存在文件
 
		FTPFile[] files = ftpClient.listFiles(remoteFileName);
 
		if (files.length == 1)
		{
 
			long remoteSize = files[0].getSize();
 
			File f = new File(local);
 
			long localSize = f.length();
 
			if (remoteSize == localSize)
			{
 
				return FTPStatus.File_Exits;
 
			} else if (remoteSize > localSize)
			{
 
				return FTPStatus.Remote_Bigger_Local;
 
			}
 
			// 尝试移动文件内读取指针,实现断点续传
 
			InputStream is = new FileInputStream(f);
 
			if (is.skip(remoteSize) == remoteSize)
			{
 
				ftpClient.setRestartOffset(remoteSize);
 
				if (ftpClient.storeFile(remote, is))
				{
 
					return FTPStatus.Upload_From_Break_Success;
 
				}
 
			}
 
			// 如果断点续传没有成功，则删除服务器上文件，重新上传
 
			if (!ftpClient.deleteFile(remoteFileName))
			{
 
				return FTPStatus.Delete_Remote_Faild;
 
			}
 
			is = new FileInputStream(f);
 
			if (ftpClient.storeFile(remote, is))
			{
 
				result = FTPStatus.Upload_New_File_Success;
 
			} else
			{
 
				result = FTPStatus.Upload_New_File_Failed;
 
			}
 
			is.close();
 
		} else
		{
 
			InputStream is = new FileInputStream(local);
 
			if (ftpClient.storeFile(remoteFileName, is))
			{
 
				result = FTPStatus.Upload_New_File_Success;
 
			} else
			{
 
				result = FTPStatus.Upload_New_File_Failed;
 
			}
 
			is.close();
		}
 
		return result;
 
	}
 
	/**
	 * 
	 * 断开与远程服务器的连接
	 * 
	 * @throws IOException
	 */
 
	public void disconnect() throws IOException
	{
 
		if (ftpClient.isConnected())
		{
			ftpClient.disconnect();
		}
 
	}
 
 
	@Override
	public void run()
	{
		boolean status=false;
		// 建立FTP连接
		try
		{
			ftpClient.connect(userInfo.getIp(), userInfo.getPort());
 
			if (FTPReply.isPositiveCompletion(ftpClient.getReplyCode()))
			{
 
				if (ftpClient.login(userInfo.getUsername(), userInfo.getPassword()))
				{
					status=true;
				}
			}else{
				try
				{
					disconnect();
				} catch (IOException e)
				{
					
					e.printStackTrace();
				}
			}
		} catch (SocketException e1)
		{
			
			e1.printStackTrace();
		} catch (IOException e1)
		{
			e1.printStackTrace();
		}
		// FTP连接成功后执行相应的操作
		if(status){
			FTPStatus result=null;
			if(this.ftpType==FTPType.UPLOAD)
			{
				try
				{
					result=this.upload(userInfo.getLocal(), userInfo.getRemote());// 上传文件
				} catch (IOException e)
				{
					Log.getLogger(ThreadFTPUtils.class).info("FTP上传文件异常：" + e.getMessage());
				}
			}else if(this.ftpType==FTPType.DOWNLOAD)
			{
				try
				{
					result=this.download(userInfo.getRemote(), userInfo.getLocal());// 下载文件
				} catch (IOException e)
				{
					Log.getLogger(ThreadFTPUtils.class).info("FTP下载文件异常：" + e.getMessage());
				}
			}else if(this.ftpType==FTPType.RENAME)
			{
				try
				{
					result=this.rename(userInfo.getLocal(), userInfo.getRemote());// 修改名称
				} catch (IOException e)
				{
					Log.getLogger(ThreadFTPUtils.class).info("FTP修改文件名称异常：" + e.getMessage());
				}			
			}else if(this.ftpType==FTPType.DELETE)
			{
				try
				{
					result=this.delete(userInfo.getRemote());                    // 删除文件
				} catch (IOException e)
				{
					Log.getLogger(ThreadFTPUtils.class).info("FTP删除文件异常：" + e.getMessage());
				}
			}
			try
			{
				disconnect();
			} catch (IOException e)
			{
				
				Log.getLogger(ThreadFTPUtils.class).info("FTP连接释放异常：" + e.getMessage());
			}
			Log.getLogger(this.getClass()).info("FTP操作状态码:"+result);
		}
		
	}
	
	public static void main(String[] args)
	{
		ThreadFTPUtils myFtp = new ThreadFTPUtils("192.168.1.200", 21, "duser", "HTPDuserXP32","C:\\Users\\Administrator\\Desktop\\swing.drawer.jar","/jars/boonya.jar",FTPType.UPLOAD);
		Thread thread=new Thread(myFtp);
		thread.start();
 
	}
 
}
 
class UserInfo{
	
	private String ip;	    //FTP服务器的IP地址
	
	private int port;	    //FTP服务器端口
	
	private String username;//登录用户名
	
	private String password;//登录密码
	
	private String local;   //本地文件或文件名
	
	private String remote;  //远程文件或路径
	
	public String getIp()
	{
		return ip;
	}
 
	public void setIp(String ip)
	{
		this.ip = ip;
	}
 
	public int getPort()
	{
		return port;
	}
 
	public void setPort(int port)
	{
		this.port = port;
	}
 
	public String getUsername()
	{
		return username;
	}
 
	public void setUsername(String username)
	{
		this.username = username;
	}
 
	public String getPassword()
	{
		return password;
	}
 
	public void setPassword(String password)
	{
		this.password = password;
	}
 
	public String getLocal()
	{
		return local;
	}
 
	public void setLocal(String local)
	{
		this.local = local;
	}
 
	public String getRemote()
	{
		return remote;
	}
 
	public void setRemote(String remote)
	{
		this.remote = remote;
	}
 
	public UserInfo()
	{
		
	}
 
	public UserInfo(String ip, int port, String username, String password, String local, String remote)
	{
		this.ip = ip;
		this.port = port;
		this.username = username;
		this.password = password;
		this.local = local;
		this.remote = remote;
	}
	
}