public class FtpUtils {
private static Logger logger = Logger.getLogger(FtpUtils.class);
public static FTPClient getConnection(FtpConfig ftpConfig) {
return getConnection(ftpConfig.getHost(), ftpConfig.getPort(), ftpConfig.getUserName(), ftpConfig.getPassword(), ftpConfig.getTimes());
}
/**
* 带重试次数进行ftp连接的建立
*
* @param host 连接主机域名或IP
* @param port 连接端口
* @param userName ftp用户名
* @param password ftp密码
* @param times 重试次数
* @return
*/
public static FTPClient getConnection(String host, int port, String userName, String password, int times) {
FTPClient ftp = new FTPClient();
if (times <= 0) {
times = 1;
}
while ((times--) > 0) {
boolean isConnected = true;
try {
ftp.connect(host, port);
ftp.login(userName, password);// 登录
int reply = ftp.getReplyCode();
//如果登录不成功(连接不上, 刚继续发起连接)
if (!FTPReply.isPositiveCompletion(reply)) {
isConnected = false;
ftp.disconnect();
Thread.sleep(2000);
continue;
}
ftp.setFileType(FTPClient.BINARY_FILE_TYPE);
break;
} catch (InterruptedException e) {
isConnected = false;
logger.error(String.format("ftp server:%s:%s 连接线程异常", host, port), e);
} catch (Exception e) {
isConnected = false;
logger.error(String.format("ftp server:%s:%s 连接失败", host, port), e);
}
//连接不成功先释放连接后再重新连接
if (!isConnected) {
try {
ftp.disconnect();
Thread.sleep(2000); //等待2秒再进行重连
} catch (IOException e) {
logger.error(String.format("释放ftp server失败:%s:%s 连接失败", host, port), e);
} catch (Exception e) {
logger.error(String.format("ftp server:%s:%s 连接线程异常", host, port), e);
}
}
}
return ftp;
}
/**
* 将inputStream 上传到服务器
*
* @param ftp
* @param path
* @param fileName
* @param file
* @return success 成功 fail失败
*/
public static String upload2FtpServer(FTPClient ftp, String path, String fileName, File file) {
String uploadResult = "success";
try {
InputStream is = new FileInputStream(file);
uploadResult = upload2FtpServer(ftp, path, fileName, is);
} catch (Exception e) {
logger.error("上传文件失败", e);
uploadResult = e.getMessage();
}
return uploadResult;
}
/**
* 将inputStream 上传到服务器
*
* @param ftpClient
* @param ftpPath
* @param fileName
* @param is
* @return 1 表示成功 0表示失败 2表示ftp断开连接
*/
public static String upload2FtpServer(FTPClient ftpClient, String ftpPath, String fileName, InputStream is) {
if (null == is || StringUtils.isEmpty(ftpPath) || StringUtils.isEmpty(fileName)) {
logger.warn("上传信息不完整");
return "fail";
}
String uploadResult = "success";
try {
if (!ftpClient.isConnected()) { //ftp 连接已断开
return "fail";
}
if (!ftpPath.contains("/")) {
if (!ftpClient.changeWorkingDirectory(ftpPath)) {
ftpClient.makeDirectory(ftpPath);
ftpClient.changeWorkingDirectory(ftpPath);
}
} else {
for (String path : ftpPath.split("/")) {
if (!ftpClient.changeWorkingDirectory(path)) {
ftpClient.makeDirectory(path);
ftpClient.changeWorkingDirectory(path);
}
}
;
}
//设置成被动模式
ftpClient.enterLocalPassiveMode();
if (ftpClient.storeFile(fileName, is)) {
uploadResult = "success";
} else {
uploadResult = "fail";
}
is.close();
} catch (IOException e) {
logger.error(e.getMessage(), e);
uploadResult = e.getMessage();
}
return uploadResult;
}
public static void deleteFile(FTPClient ftpClient, String ftpPath, String fileName) throws Exception {
if (StringUtils.isEmpty(ftpPath) || StringUtils.isEmpty(fileName)) {
return;
}
if (!ftpClient.isConnected()) { //ftp 连接已断开
return;
}
if (!ftpPath.contains("/")) {
if (ftpClient.changeWorkingDirectory(ftpPath)) {
ftpClient.deleteFile(fileName);
}
} else {
for (String path : ftpPath.split("/")) {
if (!ftpClient.changeWorkingDirectory(path)) {
return;
}
}
;
ftpClient.deleteFile(fileName);
}
}
public static void moveFile(FTPClient ftpClient, String from, String to) {
if (StringUtils.isEmpty(from) || StringUtils.isEmpty(to) || null == ftpClient) {
return;
}
if (!ftpClient.isConnected()) { //ftp 连接已断开
return;
}
try {
ftpClient.rename(from, to);
} catch (IOException e) {
e.printStackTrace();
logger.error("FTP移动文件出错", e);
}
}
/**
* 释放ftp连接
*
* @param ftpClient
*/
public static void releaseConnect(FTPClient ftpClient) {
if (null != ftpClient) {
try {
ftpClient.quit();
ftpClient.disconnect();
} catch (IOException e) {
logger.error("释放ftp连接失败", e);
}
}
}
public static boolean deleteFiles(String... paths) {
boolean res = false;
try {
FTPClient ftpClient = conFTPClient();
String ftpPath = PropertiesUtil.getProperties().getProperty("ftp.file.path2");
if (!ftpClient.isConnected()) { //ftp 连接已断开
return false;
}
for (String path : paths) {
String dirStr = new String(path.getBytes("UTF-8"), "iso-8859-1");
res = ftpClient.deleteFile(ftpPath+dirStr);
if (!res) {
break;
}
}
releaseConnect(ftpClient);
} catch (IOException e) {
e.printStackTrace();
}
return res;
}
public static boolean makeDir(String... paths) {
boolean res = false;
try {
FTPClient ftpClient = conFTPClient();
String ftpPath = PropertiesUtil.getProperties().getProperty("ftp.file.path2");
for (String path : paths) {
String dirStr = new String(path.getBytes("UTF-8"), "iso-8859-1");
res = ftpClient.makeDirectory(ftpPath + dirStr);
if (!res) {
for (String delPath : paths) {
String delDirStr = new String(delPath.getBytes("UTF-8"), "iso-8859-1");
deleteDir(ftpPath + delDirStr);
}
break;
}
}
releaseConnect(ftpClient);
} catch (IOException e) {
e.printStackTrace();
}
return res;
}
public static void deleteDir(String... paths) {
try {
FTPClient ftpClient = conFTPClient();
String ftpPath = PropertiesUtil.getProperties().getProperty("ftp.file.path2");
for (String path : paths) {
String dirStr = new String(path.getBytes("UTF-8"), "iso-8859-1");
ftpClient.removeDirectory(ftpPath + dirStr);
}
releaseConnect(ftpClient);
} catch (IOException e) {
e.printStackTrace();
}
}
public static FTPClient conFTPClient() throws IOException {
FTPClient ftpClient = new FTPClient();
String ftpIp = PropertiesUtil.getProperties().getProperty("ftp.ip2");
String ftpPort = PropertiesUtil.getProperties().getProperty("ftp.port2");
String ftpUser = PropertiesUtil.getProperties().getProperty("ftp.user2");
String ftpPwd = PropertiesUtil.getProperties().getProperty("ftp.pwd2");
ftpClient.connect(ftpIp, Integer.parseInt(ftpPort));
ftpClient.login(ftpUser, ftpPwd);
ftpClient.enterLocalPassiveMode();
ftpClient.setControlEncoding("UTF-8");
return ftpClient;
}
/**
* 上传
*
* @param file
* @param dir
* @param newName
* @return
*/
public static boolean upload(MultipartFile file, String dir, String newName) {
boolean res = false;
FTPClient ftpClient = null;
try {
ftpClient = conFTPClient();
} catch (IOException e) {
e.printStackTrace();
}
try {
String ftpPath = PropertiesUtil.getProperties().getProperty("ftp.file.path2");
FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_NT);
conf.setServerLanguageCode("zh");
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
String dirStr = new String(dir.getBytes("UTF-8"), "iso-8859-1");
String path = ftpPath + dirStr;
// 如果不存在就创建，如果存在则返回false
ftpClient.makeDirectory(path);
// 设置上传目录
ftpClient.changeWorkingDirectory(path);
System.out.println(path);
FTPFile[] fs = ftpClient.listFiles();
if (fs != null && fs.length > 0) {
for (FTPFile f : fs) {
if (f.getName().equals(newName)) {
ftpClient.deleteFile(f.getName());
break;
}
}
}
OutputStream os = ftpClient.appendFileStream(newName);
byte[] bytes = new byte[1024];
InputStream is = file.getInputStream();
int c;
// 暂未考虑中途终止的情况
while ((c = is.read(bytes)) != -1) {
os.write(bytes, 0, c);
}
os.flush();
is.close();
os.close();
res = true;
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
ftpClient.disconnect();
} catch (IOException e) {
//e.printStackTrace();
System.out.println(e.getStackTrace());
res = false;
}
}
return res;
}
public static boolean uploadFile(String dir, String newName, File file) {
boolean res = false;
try {
FTPClient ftpClient = conFTPClient();
String ftpPath = PropertiesUtil.getProperties().getProperty("ftp.file.path2");
FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_NT);
conf.setServerLanguageCode("zh");
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
String dirStr = new String(dir.getBytes("UTF-8"), "iso-8859-1");
String newName2 = new String(newName.getBytes("UTF-8"), "iso-8859-1");
String path = ftpPath + dirStr;
// 如果不存在就创建，如果存在则返回false
ftpClient.makeDirectory(path);
// 设置上传目录
ftpClient.changeWorkingDirectory(path);
FTPFile[] fs = ftpClient.listFiles();
if (fs != null && fs.length > 0) {
for (FTPFile f : fs) {
if (f.getName().equals(newName)) {
ftpClient.deleteFile(f.getName());
break;
}
}
}
System.out.println(path);
OutputStream os = ftpClient.appendFileStream(newName2);
byte[] bytes = new byte[1024];
InputStream is = new FileInputStream(file);
int c;
// 暂未考虑中途终止的情况
while ((c = is.read(bytes)) != -1) {
os.write(bytes, 0, c);
}
os.flush();
is.close();
os.close();
res = true;
releaseConnect(ftpClient);
} catch (Exception e) {
logger.error("上传文件失败", e);
e.printStackTrace();
}
return res;
}
}
<div class="iteye-blog-content-contain" style="font-size: 20px"></div>
public class FtpConfig{
private String host;
private int port;
private String userName;
private String password;
private int times;
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 int getTimes() {
return times;
}
public void setTimes(int times) {
this.times = times;
}
}
分享到：
相关推荐
"FTP上传控件"是专为实现文件上传功能而设计的，它简化了FTP客户端的实现过程，开发者无需深入了解FTP协议的细节，就能在应用中实现文件上传功能。"FTP上传控件"的关键特性包括支持超大文件上传和断点续传。 超大...
总的来说，使用Java实现FTP上传和下载涉及网络通信、文件操作和错误处理等多个方面的知识。通过"ftpLoadDown.jar"库，我们可以简化这个过程，使得开发者可以专注于业务逻辑，而无需关心底层的FTP协议细节。在实际...
Labview FTP上传文件是利用Labview（Laboratory Virtual Instrument Engineering Workbench）这一强大的图形化编程环境，通过FTP（File Transfer Protocol）协议实现文件的远程传输。FTP是一种标准网络协议，用于在...
**VB API FTP上传下载源代码详解** 在信息技术领域，FTP（File Transfer Protocol）是一种用于在网络上进行文件传输的标准协议。在VB（Visual Basic）环境中，我们可以使用API（Application Programming Interface...
在"Go实现FTP上传资源"这个主题中，我们需要关注以下几个关键知识点： 1. **FTP协议基础**：FTP协议由两部分组成，即控制连接和数据连接。控制连接用于发送命令和接收响应，数据连接则用于实际的文件传输。FTP支持...
BoschNetConn可能是你的项目或库的名字，它可能封装了这些libcurl的FTP上传操作，提供了一种更方便的方式来处理网络连接。如果你正在使用这个库，你应该查阅其文档以了解如何具体使用它的API来上传文件。 总之，C++...
在这个"FTP上传与下载程序PB"的案例中，我们将会探讨如何使用PowerBuilder来实现FTP功能，包括文件的上传和下载，以及可能涉及的自动升级机制。 首先，理解FTP的基本概念至关重要。FTP允许用户在两台计算机之间交换...
这个FTP上传实例提供了可视化的进度反馈，使得用户能够清晰地看到文件上传的进度，提高了用户体验。 FTP上传的核心原理是通过FTP客户端连接到FTP服务器，然后将本地文件分块发送到服务器。在这个过程中，通过跟踪已...
**FTP上传文件：** 要实现FTP文件上传，我们首先创建一个`FtpWebRequest`对象，设置其方法为`WebMethod.UploadFile`，然后提供FTP服务器的URL、用户名和密码。接着，打开一个流写入器，将本地文件内容写入请求的主体...
FTP上传和断点续传是网络传输中两个重要的概念，特别是在大文件传输场景下，而更新进度条则是提升用户体验的关键元素。在这个公司项目的第一个版本中，我们关注的是如何实现一个功能完善的FTP上传系统，该系统支持...
FTP上传实现网站预览的过程涉及多个步骤和技术，下面将详细解释这一过程。 1. FTP客户端与服务器： FTP服务需要一个服务器端和客户端。服务器端是存储网站文件的地方，而客户端是用户用来连接服务器并管理文件的...
FTP上传涉及到将本地文件发送到远程FTP服务器。使用libcurl，我们可以通过以下步骤实现： 1. **初始化libcurl**：创建一个`CURL`指针，并调用`curl_global_init()`初始化全局设置。 2. **设置URL**：使用`curl_...
萤石云摄像头自动截图以及FTP上传是一个集成自动化与远程存储功能的系统，它结合了现代监控设备的技术优势，为用户提供了一种高效、便捷的方式来管理和获取摄像头捕获的图像。在这个系统中，萤石云摄像头扮演着核心...
Delphi FTP上传程序是使用Delphi7开发的一个应用程序，它实现了通过FTP（文件传输协议）将本地文件上传到远程服务器的功能。FTP是一种广泛用于互联网上的标准协议，允许用户在计算机之间传输文件。在这个项目中，...
FTP上传程序就是实现这一功能的应用，允许用户将本地计算机上的文件或目录上传到远程FTP服务器上。这种程序通常具有用户友好的界面，简化了文件传输过程。 在"FTP上传程序（典型的ftp上传应用）"中，重点在于程序...
标题“FTP上传与下载pb9.0code”指的是使用PowerBuilder 9.0（简称PB9）开发的一个程序，该程序实现了FTP（File Transfer Protocol）的上传和下载功能。PowerBuilder是一款强大的可视化编程工具，特别适合于构建...
FTP（File Transfer Protocol）是一种基于TCP/IP协议的...综上所述，FTP上传涉及到网络通信、身份验证、文件操作等多个方面，理解并熟练运用FTP上传能有效提高工作效率，特别是在需要跨网络共享和管理文件的环境中。
在这个场景中，我们关注的是一个基于Java开发的FTP上传工具，它能够帮助用户将本地文件上传到FTP服务器。以下是一些关于FTP上传工具和相关技术的知识点： 1. **FTP基本概念**： FTP是一个应用层协议，基于TCP/IP...
很好用的ftp上传工具，上传速度也很快，很好用的ftp上传工具，上传速度也很快，很好用的ftp上传工具，上传速度也很快，
在VC++中实现FTP上传和下载功能，开发者通常会利用WinInet库或第三方FTP库。 首先，让我们深入了解一下FTP上传。FTP上传是指将本地计算机上的文件发送到FTP服务器的过程。在VC++中，可以使用WinInet API来实现这一...