【FTP】FTP文件上传下载-支持断点续传
- Jar包：apache的commons-net包；
- 支持断点续传
- 支持进度监控(有时出不来，搞不清缘由)
相关知识点
- 编码格式: UTF-8等;
- 文件类型： 包括[BINARY_FILE_TYPE(经常使用)]和[ASCII_FILE_TYPE]两种;
- 数据链接模式：通常使用LocalPassiveMode模式，由于大部分客户端都在防火墙后面；
1. LocalPassiveMode：服务器端打开数据端口，进行数据传输；
2. LocalActiveMode：客户端打开数据端口，进行数据传输；
- 系统类型：UNIX/WINDOWS等，默认为Unix
流程
- 步骤1： 建立FTPClient对象，设置ftpClient属性：如编码格式、链接超时、文件上传下载进度监听器等;
- 步骤2： 使用ftpClient链接远程server：connect()；
- 步骤3： 获取connect()的返回码getReplyCode()，判断是否链接成功：isPositiveCompletion()；
- 步骤4： 登陆远程server：login(),并转到相应目录，必要时要递归建立目录;
- 步骤5： 设置ftpClient属性：如缓存大小、文件类型、超时时间、数据链接模式等；
- 步骤6： ftp相关操做：如文件上传、下载等；
- 步骤7： 断开链接，释放资源：logout()/disconnect();
程序
FTP链接和登陆
文件上传
文件下载
测试程序
完整程序
package com.sssppp.Communication;import java.io.File;import java.io.FileOutputStream;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.io.PrintWriter;import java.io.RandomAccessFile;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.FTPClientConfig;import org.apache.commons.net.ftp.FTPFile;import org.apache.commons.net.ftp.FTPReply;import org.apache.commons.net.io.CopyStreamEvent;import org.apache.commons.net.io.CopyStreamListener;/** * FTP进行文件上传和下载； * 支持断点续传； */public final class FTPUtil { private final FTPClient ftp = new FTPClient(); /** * * @param hostname * 如：IP * @param port * @param username * @param password * @return * @throws IOException */ public boolean connect(String hostname, int port, String username, String password) throws IOException { boolean debug = false; if (debug) { // 设置将过程当中使用到的命令输出到控制台 this.ftp.addProtocolCommandListener(new PrintCommandListener( new PrintWriter(System.out), true)); } //设置系统类型 final FTPClientConfig config = new FTPClientConfig( FTPClientConfig.SYST_UNIX); this.ftp.configure(config); try { this.ftp.connect(hostname, port); if (!FTPReply.isPositiveCompletion(this.ftp.getReplyCode())) { this.ftp.disconnect(); System.err.println("FTP server refused connection."); return false; } } catch (IOException e) { if (this.ftp.isConnected()) { try { this.ftp.disconnect(); } catch (IOException f) { } } System.err.println("Could not connect to server."); e.printStackTrace(); return false; } if (!this.ftp.login(username, password)) { this.ftp.logout(); System.err.println("Could not login to server."); return false; } return true; } public void disconnect() throws IOException { if (this.ftp.isConnected()) { try { this.ftp.logout(); this.ftp.disconnect(); } catch (IOException f) { } } } /** * * @param absSrcFileName * @param destDir * @param destFileName * @throws IOException */ public void upLoadByFtp(String absSrcFileName, String destDir, String destFileName) throws IOException { // 建立并转到工做目录 String absDstDir = this.ftp.printWorkingDirectory() + "/" + destDir; absDstDir = absDstDir.replaceAll("//", "/"); createDirectory(absDstDir, this.ftp); // 设置各类属性 this.ftp.setFileType(FTP.BINARY_FILE_TYPE); // Use passive mode as default because most of us are behind firewalls these days. this.ftp.enterLocalPassiveMode(); this.ftp.setControlEncoding("utf-8"); this.ftp.setBufferSize(1024); // 进度监听 File srcFile = new File(absSrcFileName); this.ftp.setCopyStreamListener(new MyCopyStreamListener(srcFile.length())); FTPFile[] files = this.ftp.listFiles(destFileName); if (files.length == 1) {// 断点续传 long dstFileSize = files[0].getSize(); if (srcFile.length() <= dstFileSize) {// 文件已存在 return; } boolean b = uploadFile(destFileName, srcFile, this.ftp, dstFileSize); if (!b) {// 若是断点续传没有成功，则删除服务器上文件，从新上传 if (this.ftp.deleteFile(destFileName)) { uploadFile(destFileName, srcFile, this.ftp, 0); }else { System.err.println("Delete file fail."); } } } else { uploadFile(destFileName, srcFile, this.ftp, 0); } } /** * * @param remoteFileName * @param localFileName * @throws IOException */ public void downLoadByFtp(String remoteFileName, String localFileName) throws IOException { InputStream input = null; FileOutputStream fos = null; // 设置各类属性 this.ftp.setBufferSize(1024); this.ftp.setDataTimeout(1000 * 10); this.ftp.setFileType(FTPClient.BINARY_FILE_TYPE); this.ftp.enterLocalPassiveMode(); // 判断远程文件是否存在 FTPFile[] files = this.ftp.listFiles(remoteFileName); if (files.length != 1) { System.err.println("Remote file not exist."); return; } //进度监听 long remoteSize = files[0].getSize(); this.ftp.setCopyStreamListener(new MyCopyStreamListener(remoteSize)); File file = new File(localFileName); if (file.exists()) { long localSize = file.length(); if (localSize >= remoteSize) { return; } System.out.println("@@@Break point download.@@@"); fos = new FileOutputStream(file, true);// append模式 this.ftp.setRestartOffset(localSize); } else { fos = new FileOutputStream(file); // override模式 } input = this.ftp.retrieveFileStream(remoteFileName); byte[] b = new byte[8192]; int n = 0; while (-1 != (n = input.read(b))) { if (Thread.currentThread().isInterrupted()) { break; } fos.write(b, 0, n); } if (input != null) { input.close(); } if (fos != null) { fos.flush(); fos.close(); } if (!this.ftp.completePendingCommand()) { System.err.println("Download file fail."); this.ftp.logout(); this.ftp.disconnect(); } } /** * * @param destFileName * @param srcFile * @param ftpClient * @param dstFileSize 文件写入的起始位置； >0:表示断点续传，<=0:表示上传新文件 * @return * @throws IOException */ private boolean uploadFile(String destFileName, File srcFile, FTPClient ftpClient, long dstFileSize) throws IOException { RandomAccessFile input = null; OutputStream fout = null; input = new RandomAccessFile(srcFile, "r"); // 只读模式 if (dstFileSize > 0) {// 断点续传 fout = ftpClient.appendFileStream(destFileName); input.seek(dstFileSize); ftpClient.setRestartOffset(dstFileSize); } else { fout = ftpClient.storeFileStream(destFileName); } byte[] b = new byte[8192]; // 缓存大小 int n = 0; while (-1 != (n = input.read(b))) { if (Thread.currentThread().isInterrupted()) { break; } fout.write(b, 0, n); } if (input != null) { input.close(); } if (fout != null) { fout.flush(); fout.close(); } if (!ftpClient.completePendingCommand()) { System.err.println("Upload file fail."); ftpClient.logout(); ftpClient.disconnect(); return false; } return true; } /** * 在FTP服务器上建立并转到工做目录 * * @param relativePath * 相对工做路径，不包含文件名：如 dd/11/22/33 * @param ftpClient * 录建立是否成功 * @return * @throws IOException */ private boolean createDirectory(String relativePath, FTPClient ftpClient) throws IOException { if (!relativePath.startsWith("/")) { relativePath = "/" + relativePath; } String dir = (ftpClient.printWorkingDirectory().equals("/") ? "" : ftpClient.printWorkingDirectory()) + relativePath; if (!ftpClient.changeWorkingDirectory(dir)) { //目录不存在，则建立各级目录 for (String subDir : relativePath.split("/")) { if (!subDir.equals("")) { String newDir = ftpClient.printWorkingDirectory() + "/" + subDir; ftpClient.mkd(newDir); if (!ftpClient.changeWorkingDirectory(newDir)) { return false; } } } } return true; } /** * 进度监听器 */ private class MyCopyStreamListener implements CopyStreamListener { private long totalSize = 0; private long percent = -1; // 进度 /** * 文件的总大小 * @param totalSize */ public MyCopyStreamListener(long totalSize) { super(); this.totalSize = totalSize; } @Override public void bytesTransferred(CopyStreamEvent event) { bytesTransferred(event.getTotalBytesTransferred(), event.getBytesTransferred(), event.getStreamSize()); } //totalBytesTransferred:当前总共已传输字节数; //bytesTransferred:最近一次传输字节数 @Override public void bytesTransferred(long totalBytesTransferred, int bytesTransferred, long streamSize) { if (percent >= totalBytesTransferred * 100 / totalSize) { return; } percent = totalBytesTransferred * 100 / totalSize; System.out.println("Completed " + totalBytesTransferred + "(" + percent + "%) out of " + totalSize + "."); } } public static void main(String[] args) throws IOException { String hostname = "10.180.137.241"; String username = "xxx"; String password = "xxx"; int port = 21; FTPUtil ftp = new FTPUtil(); //上传文件 String absSrcFileName = "C:\\tmp\\m2eclipse1.zip"; String destDir = "ww/11/22/33"; String destFileName = "m2eclipse1.zip"; ftp.connect(hostname, port, username, password); ftp.upLoadByFtp(absSrcFileName, destDir, destFileName); ftp.disconnect(); // 下载文件 String localFileName = "C:\\tmp\\m2eclipse-download3333.zip"; String remoteFileName = "/ww/11/22/33/m2eclipse.zip"; ftp.connect(hostname, port, username, password); ftp.downLoadByFtp(remoteFileName, localFileName); ftp.disconnect(); }}
参考连接
https://my.oschina.net/csmw00/blog/676049 （可参考如何实现进度监控）
相关文章
- 1. C# FTP上传下载（支持断点续传）
- 2. FTP断点续传
- 3. FTP文件上传下载
- 4. java实现FTP多线程断点续传，上传下载！
- 5. FTP文件上传并支持断点续传（一）—— win10 本地环境 ftp站点构建
- 6. Delphi实现Ftp客户端下载（支持断点续传，多线程传输）
- 7. Java ftp断点续传
- 8. java ftp上传文件 支持并发
- 9. FTP文件上传 支持断点续传 并 打印下载进度（二） —— 单线程实现
- 10. Android FTP 断点上传文件
- 更多相关文章...
- • PHP 文件上传 - PHP教程
- • PHP FTP 函数 - PHP参考手册
- • Flink 数据传输及反压详解
- • Docker容器实战(七) - 容器眼光下的文件系统
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. 「插件」Runner更新Pro版，帮助设计师远离996
- 2. 错误 707 Could not load file or assembly ‘Newtonsoft.Json, Version=12.0.0.0, Culture=neutral, PublicKe
- 3. Jenkins 2018 报告速览，Kubernetes使用率跃升235%！
- 4. TVI-Android技术篇之注解Annotation
- 5. android studio启动项目
- 6. Android的ADIL
- 7. Android卡顿的检测及优化方法汇总（线下+线上）
- 8. 登录注册的业务逻辑流程梳理
- 9. NDK(1)创建自己的C/C++文件
- 10. 小菜的系统框架界面设计-你的评估是我的决策
欢迎关注本站公众号,获取更多信息
