本文主要是介绍Java FTPClient代码（二）支持多线程与连接复用，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
该版本主要增加了以下特性：1、对多线程并发的支持
2、连接复用
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.SocketException;import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPReply;
import org.apache.log4j.Logger;/*** FTP客户端* * @author summersun_ym* @version $Id: FTPClientTemplate.java 2010-11-22 上午12:54:47 $*/
public class FTPClientTemplate {//---------------------------------------------------------------------// Instance data//---------------------------------------------------------------------/** logger */protected final Logger log = Logger.getLogger(getClass());private ThreadLocal<FTPClient> ftpClientThreadLocal = new ThreadLocal<FTPClient>();private String host;private int port;private String username;private String password;private boolean binaryTransfer = true;private boolean passiveMode = true;private String encoding = "UTF-8";private int clientTimeout = 1000 * 30;public String getHost() {return host;}public void setHost(String host) {this.host = host;}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 boolean isBinaryTransfer() {return binaryTransfer;}public void setBinaryTransfer(boolean binaryTransfer) {this.binaryTransfer = binaryTransfer;}public boolean isPassiveMode() {return passiveMode;}public void setPassiveMode(boolean passiveMode) {this.passiveMode = passiveMode;}public String getEncoding() {return encoding;}public void setEncoding(String encoding) {this.encoding = encoding;}public int getClientTimeout() {return clientTimeout;}public void setClientTimeout(int clientTimeout) {this.clientTimeout = clientTimeout;}//---------------------------------------------------------------------// private method//---------------------------------------------------------------------/*** 返回一个FTPClient实例* * @throws FTPClientException*/private FTPClient getFTPClient() throws FTPClientException {if (ftpClientThreadLocal.get() != null && ftpClientThreadLocal.get().isConnected()) {return ftpClientThreadLocal.get();} else {FTPClient ftpClient = new FTPClient(); //构造一个FtpClient实例ftpClient.setControlEncoding(encoding); //设置字符集connect(ftpClient); //连接到ftp服务器//设置为passive模式if (passiveMode) {ftpClient.enterLocalPassiveMode();}setFileType(ftpClient); //设置文件传输类型try {ftpClient.setSoTimeout(clientTimeout);} catch (SocketException e) {throw new FTPClientException("Set timeout error.", e);}ftpClientThreadLocal.set(ftpClient);return ftpClient;}}/*** 设置文件传输类型* * @throws FTPClientException* @throws IOException*/private void setFileType(FTPClient ftpClient) throws FTPClientException {try {if (binaryTransfer) {ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);} else {ftpClient.setFileType(FTPClient.ASCII_FILE_TYPE);}} catch (IOException e) {throw new FTPClientException("Could not to set file type.", e);}}/*** 连接到ftp服务器* * @param ftpClient* @return 连接成功返回true，否则返回false* @throws FTPClientException*/private boolean connect(FTPClient ftpClient) throws FTPClientException {try {ftpClient.connect(host, port);// 连接后检测返回码来校验连接是否成功int reply = ftpClient.getReplyCode();if (FTPReply.isPositiveCompletion(reply)) {//登陆到ftp服务器if (ftpClient.login(username, password)) {setFileType(ftpClient);return true;}} else {ftpClient.disconnect();throw new FTPClientException("FTP server refused connection.");}} catch (IOException e) {if (ftpClient.isConnected()) {try {ftpClient.disconnect(); //断开连接} catch (IOException e1) {throw new FTPClientException("Could not disconnect from server.", e1);}}throw new FTPClientException("Could not connect to server.", e);}return false;}//---------------------------------------------------------------------// public method//---------------------------------------------------------------------/*** 断开ftp连接* * @throws FTPClientException*/public void disconnect() throws FTPClientException {try {FTPClient ftpClient = getFTPClient();ftpClient.logout();if (ftpClient.isConnected()) {ftpClient.disconnect();ftpClient = null;}} catch (IOException e) {throw new FTPClientException("Could not disconnect from server.", e);}}public boolean mkdir(String pathname) throws FTPClientException {return mkdir(pathname, null);}/*** 在ftp服务器端创建目录（不支持一次创建多级目录）* * 该方法执行完后将自动关闭当前连接* * @param pathname* @return* @throws FTPClientException*/public boolean mkdir(String pathname, String workingDirectory) throws FTPClientException {return mkdir(pathname, workingDirectory, true);}/*** 在ftp服务器端创建目录（不支持一次创建多级目录）* * @param pathname* @param autoClose 是否自动关闭当前连接* @return* @throws FTPClientException*/public boolean mkdir(String pathname, String workingDirectory, boolean autoClose) throws FTPClientException {try {getFTPClient().changeWorkingDirectory(workingDirectory);return getFTPClient().makeDirectory(pathname);} catch (IOException e) {throw new FTPClientException("Could not mkdir.", e);} finally {if (autoClose) {disconnect(); //断开连接}}}/*** 上传一个本地文件到远程指定文件* * @param remoteAbsoluteFile 远程文件名(包括完整路径)* @param localAbsoluteFile 本地文件名(包括完整路径)* @return 成功时，返回true，失败返回false* @throws FTPClientException*/public boolean put(String remoteAbsoluteFile, String localAbsoluteFile) throws FTPClientException {return put(remoteAbsoluteFile, localAbsoluteFile, true);}/*** 上传一个本地文件到远程指定文件* * @param remoteAbsoluteFile 远程文件名(包括完整路径)* @param localAbsoluteFile 本地文件名(包括完整路径)* @param autoClose 是否自动关闭当前连接* @return 成功时，返回true，失败返回false* @throws FTPClientException*/public boolean put(String remoteAbsoluteFile, String localAbsoluteFile, boolean autoClose) throws FTPClientException {InputStream input = null;try {// 处理传输input = new FileInputStream(localAbsoluteFile);getFTPClient().storeFile(remoteAbsoluteFile, input);log.debug("put " + localAbsoluteFile);return true;} catch (FileNotFoundException e) {throw new FTPClientException("local file not found.", e);} catch (IOException e) {throw new FTPClientException("Could not put file to server.", e);} finally {try {if (input != null) {input.close();}} catch (Exception e) {throw new FTPClientException("Couldn't close FileInputStream.", e);}if (autoClose) {disconnect(); //断开连接}}}/*** 下载一个远程文件到本地的指定文件* * @param remoteAbsoluteFile 远程文件名(包括完整路径)* @param localAbsoluteFile 本地文件名(包括完整路径)* @return 成功时，返回true，失败返回false* @throws FTPClientException*/public boolean get(String remoteAbsoluteFile, String localAbsoluteFile) throws FTPClientException {return get(remoteAbsoluteFile, localAbsoluteFile, true);}/*** 下载一个远程文件到本地的指定文件* * @param remoteAbsoluteFile 远程文件名(包括完整路径)* @param localAbsoluteFile 本地文件名(包括完整路径)* @param autoClose 是否自动关闭当前连接* * @return 成功时，返回true，失败返回false* @throws FTPClientException*/public boolean get(String remoteAbsoluteFile, String localAbsoluteFile, boolean autoClose) throws FTPClientException {OutputStream output = null;try {output = new FileOutputStream(localAbsoluteFile);return get(remoteAbsoluteFile, output, autoClose);} catch (FileNotFoundException e) {throw new FTPClientException("local file not found.", e);} finally {try {if (output != null) {output.close();}} catch (IOException e) {throw new FTPClientException("Couldn't close FileOutputStream.", e);}}}/*** 下载一个远程文件到指定的流 处理完后记得关闭流* * @param remoteAbsoluteFile* @param output* @return* @throws FTPClientException*/public boolean get(String remoteAbsoluteFile, OutputStream output) throws FTPClientException {return get(remoteAbsoluteFile, output, true);}/*** 下载一个远程文件到指定的流 处理完后记得关闭流* * @param remoteAbsoluteFile* @param output* @param delFile* @return* @throws FTPClientException*/public boolean get(String remoteAbsoluteFile, OutputStream output, boolean autoClose) throws FTPClientException {try {FTPClient ftpClient = getFTPClient();// 处理传输return ftpClient.retrieveFile(remoteAbsoluteFile, output);} catch (IOException e) {throw new FTPClientException("Couldn't get file from server.", e);} finally {if (autoClose) {disconnect(); //关闭链接}}}/*** 从ftp服务器上删除一个文件* 该方法将自动关闭当前连接* * @param delFile* @return* @throws FTPClientException*/public boolean delete(String delFile) throws FTPClientException {return delete(delFile, true);}/*** 从ftp服务器上删除一个文件* * @param delFile* @param autoClose 是否自动关闭当前连接* * @return* @throws FTPClientException*/public boolean delete(String delFile, boolean autoClose) throws FTPClientException {try {getFTPClient().deleteFile(delFile);return true;} catch (IOException e) {throw new FTPClientException("Couldn't delete file from server.", e);} finally {if (autoClose) {disconnect(); //关闭链接}}}/*** 批量删除* 该方法将自动关闭当前连接* * @param delFiles* @return* @throws FTPClientException*/public boolean delete(String[] delFiles) throws FTPClientException {return delete(delFiles, true);}/*** 批量删除* * @param delFiles* @param autoClose 是否自动关闭当前连接* * @return* @throws FTPClientException*/public boolean delete(String[] delFiles, boolean autoClose) throws FTPClientException {try {FTPClient ftpClient = getFTPClient();for (String s : delFiles) {ftpClient.deleteFile(s);}return true;} catch (IOException e) {throw new FTPClientException("Couldn't delete file from server.", e);} finally {if (autoClose) {disconnect(); //关闭链接}}}/*** 列出远程默认目录下所有的文件* * @return 远程默认目录下所有文件名的列表，目录不存在或者目录下没有文件时返回0长度的数组* @throws FTPClientException*/public String[] listNames() throws FTPClientException {return listNames(null, true);}public String[] listNames(boolean autoClose) throws FTPClientException {return listNames(null, autoClose);}/*** 列出远程目录下所有的文件* * @param remotePath 远程目录名* @param autoClose 是否自动关闭当前连接* * @return 远程目录下所有文件名的列表，目录不存在或者目录下没有文件时返回0长度的数组* @throws FTPClientException*/public String[] listNames(String remotePath, boolean autoClose) throws FTPClientException {try {String[] listNames = getFTPClient().listNames(remotePath);return listNames;} catch (IOException e) {throw new FTPClientException("列出远程目录下所有的文件时出现异常", e);} finally {if (autoClose) {disconnect(); //关闭链接}}}public static void main(String[] args) throws FTPClientException, InterruptedException {FTPClientTemplate ftp = new FTPClientTemplate();ftp.setHost("localhost");ftp.setPort(2121);ftp.setUsername("admin");ftp.setPassword("admin");ftp.setBinaryTransfer(false);ftp.setPassiveMode(false);ftp.setEncoding("utf-8");//boolean ret = ftp.put("/group/tbdev/query/user-upload/12345678910.txt", "D:/099_temp/query/12345.txt");//System.out.println(ret);ftp.mkdir("asd", "user-upload");//ftp.disconnect();//ftp.mkdir("user-upload1");//ftp.disconnect();//String[] aa = {"/group/tbdev/query/user-upload/123.txt", "/group/tbdev/query/user-upload/SMTrace.txt"};//ftp.delete(aa);}
}复用
这篇关于Java FTPClient代码（二）支持多线程与连接复用的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
