设为首页 收藏本站
查看: 835|回复: 0

[经验分享] java实现FTP断点续传

[复制链接]

尚未签到

发表于 2016-6-8 11:23:49 | 显示全部楼层 |阅读模式
  
  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
  
  */ 
  
  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
  
  */ 
  
  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.21.171", 21, "test", "test"); 
  
  System.out.println(myFtp.upload("E:\\VP6.flv", "/MIS/video/VP6.flv")); 
  
  myFtp.disconnect(); 
  
  } catch (IOException e) { 
  
  System.out.println("连接FTP出错:"+e.getMessage()); 
  
  } 
  
  } 
  
  }

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-227808-1-1.html 上篇帖子: FTP服务器的文件管理 下篇帖子: Java实现ftp功能
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表