Java FTPClient代码（二）支持多线程与连接复用

2024-01-05 18:38
文章标签 java 代码 连接 多线程 支持 复用 ftpclient

本文主要是介绍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代码（二）支持多线程与连接复用的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/573778。

相关文章

SpringBoot中六种批量更新Mysql的方式效率对比分析

SpringBoot中六种批量更新Mysql的方式效率对比分析

《SpringBoot中六种批量更新Mysql的方式效率对比分析》文章比较了MySQL大数据量批量更新的多种方法,指出REPLACEINTO和ONDUPLICATEKEY效率最高但存在数据风险,MyB... 目录效率比较测试结构数据库初始化测试数据批量修改方案第一种 for第二种 case when第三种
阅读更多...
Java docx4j高效处理Word文档的实战指南

Java docx4j高效处理Word文档的实战指南

《Javadocx4j高效处理Word文档的实战指南》对于需要在Java应用程序中生成、修改或处理Word文档的开发者来说,docx4j是一个强大而专业的选择,下面我们就来看看docx4j的具体使用... 目录引言一、环境准备与基础配置1.1 Maven依赖配置1.2 初始化测试类二、增强版文档操作示例2.
阅读更多...
一文详解如何使用Java获取PDF页面信息

一文详解如何使用Java获取PDF页面信息

《一文详解如何使用Java获取PDF页面信息》了解PDF页面属性是我们在处理文档、内容提取、打印设置或页面重组等任务时不可或缺的一环,下面我们就来看看如何使用Java语言获取这些信息吧... 目录引言一、安装和引入PDF处理库引入依赖二、获取 PDF 页数三、获取页面尺寸（宽高）四、获取页面旋转角度五、判断
阅读更多...
Spring Boot中的路径变量示例详解

Spring Boot中的路径变量示例详解

《SpringBoot中的路径变量示例详解》SpringBoot中PathVariable通过@PathVariable注解实现URL参数与方法参数绑定,支持多参数接收、类型转换、可选参数、默认值及... 目录一. 基本用法与参数映射1.路径定义2.参数绑定&nhttp://www.chinasem.cnbs
阅读更多...
JAVA中安装多个JDK的方法

JAVA中安装多个JDK的方法

《JAVA中安装多个JDK的方法》文章介绍了在Windows系统上安装多个JDK版本的方法,包括下载、安装路径修改、环境变量配置（JAVA_HOME和Path）,并说明如何通过调整JAVA_HOME在... 首先去oracle官网下载好两个版本不同的jdk（需要登录Oracle账号，没有可以免费注册）下载完
阅读更多...
Spring StateMachine实现状态机使用示例详解

Spring StateMachine实现状态机使用示例详解

《SpringStateMachine实现状态机使用示例详解》本文介绍SpringStateMachine实现状态机的步骤,包括依赖导入、枚举定义、状态转移规则配置、上下文管理及服务调用示例,重点解... 目录什么是状态机使用示例什么是状态机状态机是计算机科学中的​​核心建模工具​​，用于描述对象在其生命
阅读更多...
Spring Boot 结合 WxJava 实现文章上传微信公众号草稿箱与群发

Spring Boot 结合 WxJava 实现文章上传微信公众号草稿箱与群发

《SpringBoot结合WxJava实现文章上传微信公众号草稿箱与群发》本文将详细介绍如何使用SpringBoot框架结合WxJava开发工具包,实现文章上传到微信公众号草稿箱以及群发功能,... 目录一、项目环境准备1.1 开发环境1.2 微信公众号准备二、Spring Boot 项目搭建2.1 创建
阅读更多...
Java中Integer128陷阱

Java中Integer128陷阱

《Java中Integer128陷阱》本文主要介绍了Java中Integer与int的区别及装箱拆箱机制,重点指出-128至127范围内的Integer值会复用缓存对象,导致==比较结果为true,下... 目录一、Integer和int的联系1.1 Integer和int的区别1.2 Integer和in
阅读更多...
SpringSecurity整合redission序列化问题小结(最新整理)

SpringSecurity整合redission序列化问题小结(最新整理)

《SpringSecurity整合redission序列化问题小结(最新整理)》文章详解SpringSecurity整合Redisson时的序列化问题,指出需排除官方Jackson依赖,通过自定义反序... 目录1. 前言2. Redission配置2.1 RedissonProperties2.2 Red
阅读更多...
IntelliJ IDEA2025创建SpringBoot项目的实现步骤

IntelliJ IDEA2025创建SpringBoot项目的实现步骤

《IntelliJIDEA2025创建SpringBoot项目的实现步骤》本文主要介绍了IntelliJIDEA2025创建SpringBoot项目的实现步骤,文中通过示例代码介绍的非常详细,对大家... 目录一、创建 Spring Boot 项目1. 新建项目2. 基础配置3. 选择依赖4. 生成项目5.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2