java基于Apache FTP点断续传的文件上传和下载
更新时间：2016年11月01日 15:41:35 作者：boonya
本篇文章主要介绍了java基于Apache FTP点断续传的文件上传和下载，利用FTP实现文件的上传和下载，具有一定的参考价值，感兴趣的小伙伴们可以参考一下。
基于Apache FTP实现文件上传下载工具 ，上传文件时需要考虑以下问题（实例是续传功能）：
（1）、 FTP服务器是否存在改目录，如果不存在目录则需要创建目录。
（2）、判断上传文件是否已经存在，如果存在是需要删除后再上传还是续传。
1、上传或下载状态的枚举类：
package com.scengine.wtms.utils.ftp;
public enum UploadStatus
{
File_Exits(0), Create_Directory_Success(1), Create_Directory_Fail(2), Upload_From_Break_Success(3), Upload_From_Break_Faild(4), Download_From_Break_Success(5), Download_From_Break_Faild(6), Upload_New_File_Success(7), Upload_New_File_Failed(8), Delete_Remote_Success(9), Delete_Remote_Faild(10),Remote_Bigger_Local(11),Remote_smaller_locall(12);
private int status;
public int getStatus()
{
return status;
}
public void setStatus(int status)
{
this.status = status;
}
UploadStatus(int status)
{
this.status = status;
}
}
2、工具类代码：
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 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;
public class ContinueFTP
{
private FTPClient ftpClient = new FTPClient();
/**
* 对象构造 设置将过程中使用到的命令输出到控制台
*/
public ContinueFTP()
{
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
* 远程文件路径
*
* @param local
* 本地文件路径
*
* @return 是否成功
*
* @throws IOException
*/
@SuppressWarnings("resource")
public boolean download(String remote, String local) throws IOException
{
ftpClient.enterLocalPassiveMode();
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
boolean result;
File f = new File(local);
FTPFile[] files = ftpClient.listFiles(remote);
if (files.length != 1)
{
System.out.println("远程文件不唯一");
return false;
}
long lRemoteSize = files[0].getSize();
if (f.exists())
{
OutputStream out = new FileOutputStream(f, true);
System.out.println("本地文件大小为:" + f.length());
if (f.length() >= lRemoteSize)
{
System.out.println("本地文件大小大于远程文件大小，下载中止");
return false;
}
ftpClient.setRestartOffset(f.length());
result = ftpClient.retrieveFile(remote, out);
out.close();
} else
{
OutputStream out = new FileOutputStream(f);
result = ftpClient.retrieveFile(remote, out);
out.close();
}
return result;
}
/**
*
* 上传文件到FTP服务器，支持断点续传
*
* @param local
* 本地文件名称，绝对路径
*
* @param remote
* 远程文件路径，使用/home/directory1/subdirectory/file.ext
* 按照Linux上的路径指定方式，支持多级目录嵌套，支持递归创建不存在的目录结构
*
* @return 上传结果
*
* @throws IOException
*/
@SuppressWarnings("resource")
public UploadStatus upload(String local, String remote) throws IOException
{
// 设置PassiveMode传输
ftpClient.enterLocalPassiveMode();
// 设置以二进制流的方式传输
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
UploadStatus 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
{
System.out.println("创建目录失败");
return UploadStatus.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 UploadStatus.File_Exits;
} else if (remoteSize > localSize)
{
return UploadStatus.Remote_Bigger_Local;
}
// 尝试移动文件内读取指针,实现断点续传
InputStream is = new FileInputStream(f);
if (is.skip(remoteSize) == remoteSize)
{
ftpClient.setRestartOffset(remoteSize);
if (ftpClient.storeFile(remote, is))
{
return UploadStatus.Upload_From_Break_Success;
}
}
// 如果断点续传没有成功，则删除服务器上文件，重新上传
if (!ftpClient.deleteFile(remoteFileName))
{
return UploadStatus.Delete_Remote_Faild;
}
is = new FileInputStream(f);
if (ftpClient.storeFile(remote, is))
{
result = UploadStatus.Upload_New_File_Success;
} else
{
result = UploadStatus.Upload_New_File_Failed;
}
is.close();
} else
{
InputStream is = new FileInputStream(local);
if (ftpClient.storeFile(remoteFileName, is))
{
result = UploadStatus.Upload_New_File_Success;
} else
{
result = UploadStatus.Upload_New_File_Failed;
}
is.close();
}
return result;
}
/**
*
* 断开与远程服务器的连接
*
* @throws IOException
*/
public void disconnect() throws IOException
{
if (ftpClient.isConnected())
{
ftpClient.disconnect();
}
}
public static void main(String[] args)
{
ContinueFTP myFtp = new ContinueFTP();
try
{
myFtp.connect("192.168.1.200", 21, "duser", "HTPDuserXP32");
System.out.println(myFtp.upload("C:\\Users\\Administrator\\Desktop\\swing.drawer.jar", "/jars/swing.drawer.jar"));
myFtp.disconnect();
} catch (IOException e)
{
System.out.println("连接FTP出错：" + e.getMessage());
}
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
intellij idea设置统一JavaDoc模板的方法详解
这篇文章主要介绍了intellij idea设置统一JavaDoc模板的方法详解,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-04-04
springboot vue接口测试前后端实现模块树列表功能
这篇文章主要为大家介绍了springboot vue接口测试前后端实现模块树列表功能，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-05-05
linux部署出现java文件操作报错:java.io.FileNotFoundException解决办法
这篇文章主要g介绍了linux部署出现java文件操作报错:java.io.FileNotFoundException解决的相关资料,这个错误通常表示你的Spring Boot应用程序无法找到指定的文本文件,需要的朋友可以参考下2023-12-12
详解Spring Data Jpa当属性为Null也更新的完美解决方案
这篇文章主要介绍了详解Spring Data Jpa当属性为Null也更新的完美解决方案，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2019-02-02
这篇文章主要介绍了Spring Boot配置读取实现方法解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-08-08
这篇文章主要介绍了Java中避免空指针的几种方法解析,Java 中任何对象都有可能为空,当我们调用空对象的方法时就会抛出 NullPointerException 空指针异常,这是一种非常常见的错误类型,需要的朋友可以参考下2023-12-12
java聊天程序代码分享,大家参考使用吧2013-12-12
这篇文章主要为大家介绍了Netty分布式高性能工具类同线程下回收对象解析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-03-03
这篇文章主要介绍了Java多线程之条件对象Condition，Condition中的await()方法相当于Object的wait()方法，Condition中的signal()方法相当于Object的notify()方法，Condition中的signalAll()相当于Object的notifyAll()方法，接下来和小编一起进入文章了解更具体的内容2021-10-10
Spring提供了一个RedisTemplate来进行对Redis的操作，但是RedisTemplate默认配置的是使用Java本机序列化。如果要对对象操作，就不是那么的方便。所以本文为大家介绍了另一种SpringBoot结合Redis实现序列化的方法，需要的可以参考一下2022-07-07
最新评论