Android FTP 多线程断点续传下载\上传的实例

发布时间 - 2026-01-11 02:37:33    点击率:

最近在给我的开源下载框架Aria增加FTP断点续传下载和上传功能,在此过程中,爬了FTP的不少坑,终于将功能实现了,在此把一些核心功能点记录下载。

FTP下载原理

FTP单线程断点续传

FTP和传统的HTTP协议有所不同,由于FTP没有所谓的头文件,因此我们不能像HTTP那样通过设置header向服务器指定下载区间。

但是FTP协议提供了一个更好用的命令REST用于从指定位置恢复任务,同时FTP协议也提供了一个命令SIZE用于获取下载的文件大小,有了这两个命令,FTP断点续传也就没有什么问题。

FTP断点续传的原理和HTTP的断点续传原理差不多,在暂停时记录文件的停止位置,再次下载时,先读取记录的位置,如果位置存在,则通过REST命令告诉服务器从指定区间进行下载。

FTP多线程断点续传

多线程下载的原理和HTTP多线程下载的原理差不多。先获取文件大小,然后根据线程数,对整个文件进行分段下载,在任务停止时,记录每一条线程的暂停位置,重新开始下载,每一条线程读取对应的下载记录,然后每一线程从指定位置开始下载。

分段下载

和HTTP所不同的是,FTP并没有提供文件区间的API,因此,FTP在分段下载中,只有起始位置而没有结束位置。
因此,你需要在指定位置手动停止线程。

功能实现

本文使用将采用apache commons-net实现FTP断点续传下载\上传功能。<br>

通过下文的几步操作,你就能很简单的实现FTP断点续传。

登录

FTP协议和HTTP协议有所不同,使用FTP进行下载时,你需要进行登录操作。

当然,如果你服务器没有登录功能,你可以忽略登录操作。

FTPClient client = new FTPClient();
client.connect(serverIp, port); //连接到FTP服务器
client.login(userName, passsword);

通过上面三行代码,就可以很简单的登录到FTP服务器上。

在进行登录后,还需要验证是否登录成功

int reply = client.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
  client.disconnect();
  Log.d(TAG, "无法连接到ftp服务器,错误码为:" + reply);
  return;
 }

由于FTP协议中,连接成功的状态有多个,因此需要通过FTPReply.isPositiveCompletion(reply)用于验证是否成功连接到FTP服务器。

文件信息获取

在连接到FTP服务器后,就需要开始获取下载最重要的几个参数(文件长度、文件名)。

客户端可以通过client.listFiles(remotePath)获取FTP服务器上该路径的文件列表。

  • 如果路径是文件,只会返回一个长度为1的数组。
  • 如果该路径为文件夹,则会返回该文件夹下对应的所有文件。
String remotePath = "/upload/qjnn.apk"; //FTP服务器上文件路径
FTPFile[] files = client.listFiles(remotePath);
FTPFile file = files[0]; //文件信息
long size = file.getSize();
String fileaName = file.getName();

如果你的文件为英文名,并且路径中没有中文,那么通过上述代码,便可以获取到正确的文件信息。

但如果FTP上的服务器上的文件名有中文或路径有中文,那么上述代码,你将获取不到正确的文件信息。

正确的写法

由于FTP服务器默认的编码是ISO-8859-1,因此,客户端在获取文件信息时

  • 需要请求服务器使用UTF-8编码(如果服务器支持的话),如果服务器不支持开启UTF-8编码,那么客户端需要指定字符串编码格式
  • 客户端在请求remotePath路径、获取文件名时,都需要对路径进行编码转换处理。
String remotePath = "/upload/qjnn.apk"; //FTP服务器上文件路径

String charSet = "UTF-8";
if (!FTPReply.isPositiveCompletion(client.sendCommand("OPTS UTF8", "ON"))) {  //向服务器请求使用"UTF-8"编码
  charSet = "GBK";
}
FTPFile[] files = client.listFiles(new String(remotePath.getBytes(charSet), "ISO-8859-1")); //对remotePath进行编码转换
FTPFile file = files[0]; //文件信息
long size = file.getSize();
String fileaName = new String(fileName.getBytes(), Charset.forName(charSet));

通过以上代码,便可以获取到正确的文件信息。

文件下载

配置每条线程的下载区间

long fileLength = mEntity.getFileSize();
Properties pro = CommonUtil.loadConfig(mConfigFile);
int blockSize = (int) (fileLength / mThreadNum);
int[] recordL = new int[mThreadNum];
for (int i = 0; i < mThreadNum; i++) {
 recordL[i] = -1;
}
int rl = 0;
for (int i = 0; i < mThreadNum; i++) {
 long startL = i * blockSize, endL = (i + 1) * blockSize;
 Object state = pro.getProperty(mTempFile.getName() + "_state_" + i);
 if (state != null && Integer.parseInt(state + "") == 1) { //该线程已经完成
  if (resumeRecordLocation(i, startL, endL)) return;
  continue;
 }
 //分配下载位置
 Object record = pro.getProperty(fileName + "_record_" + i);
 //如果有记录,则恢复下载
 if (record != null && Long.parseLong(record + "") >= 0) {
  Long r = Long.parseLong(record + "");
  mConstance.CURRENT_LOCATION += r - startL;
  Log.d(TAG, "任务【" + mEntity.getFileName() + "】线程__" + i + "__恢复下载");
  startL = r;
  recordL[rl] = i;
  rl++;
 } else {
  recordL[rl] = i;
  rl++;
 }
 //最后一个线程的结束位置即为文件的总长度
 if (i == (mThreadNum - 1)) endL = fileLength;
 //创建分段线程
 AbsThreadTask task = createSingThreadTask(i, startL, endL, fileLength);
 if (task == null) return;
 mTask.put(i, task);
}
startSingleTask(recordL);

在上面的代码中,主要做了两步操作:

  • 在文件下载前,先从本地文件中读取当前下载的每一条线程的下载情况
  • 如果下载记录存在,从记录位置开始下载,如果记录不存在,则重新开始下载

FTP 分段线程区间自动停止

由于FTP协议没有区间下载的原因,为了让线程只下载特定区间的内容,需要客户端在单条线程累计读的数据长度已经超过了所分配的区间长度的时候,停止该条线程。

 client.enterLocalPassiveMode();  //设置被动模式
 client.setFileType(FTP.BINARY_FILE_TYPE); //设置文件传输模式
 client.setRestartOffset(mConfig.START_LOCATION);  //设置恢复下载的位置
 client.allocate(mBufSize);
 is = client.retrieveFileStream(new String(remotePath.getBytes(charSet), SERVER_CHARSET));
 //发送第二次指令时,还需要再做一次判断
 reply = client.getReplyCode();
 if (!FTPReply.isPositivePreliminary(reply)) {
  client.disconnect();
  fail(mChildCurrentLocation, "获取文件信息错误,错误码为:" + reply, null);
  return;
 }
 file = new BufferedRandomAccessFile(mConfig.TEMP_FILE, "rwd", mBufSize);
 file.seek(mConfig.START_LOCATION);
 byte[] buffer = new byte[mBufSize];
 int len;
 while ((len = is.read(buffer)) != -1) { 
  //如果该条线程读取的数据长度大于所分配的区间长度,则只能读到区间的最大长度
  if (mChildCurrentLocation + len >= mConfig.END_LOCATION) {
    len = (int) (mConfig.END_LOCATION - mChildCurrentLocation);
    file.write(buffer, 0, len);
    progress(len);
    break;
  } else {
    file.write(buffer, 0, len);
    progress(len);
  }
 }

这里还有几个坑需要处理一下:

  1. 对于FTP客户端来说,一般需要设置被动模式,被动模式和主动模式的区别
  2. 在获取文件流后,还需要使用FTPReply.isPositivePreliminary(reply)进行第二次命令判断

关于FTP文件上传

FTP 文件断点续传的方式原理和下载的都差不多:

  1. 都是在停止的时候记录停止位置,重新开始下载的时候从指定位置通过REST命令恢复断点。
  2. 都需要在任务执行前获取文件信息,比对服务器上的文件。

而和下载有区别的是:

  1. FTP上传时需要指定工作目录、在远程服务器上创建文件夹
  2. 需要服务器给用户打开删除和读入IO的权限,否则会出现550权限错误问题
  3. 上传文件需要storeFileStream获取outputStream流

最终效果



以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。


# Android  # 多线程断点续传下载  # 多线程断点续传上传  # android实现多线程下载文件(支持暂停、取消、断点续传)  # Android多线程+单线程+断点续传+进度条显示下载功能  # Android多线程断点续传下载功能实现代码  # Android多线程断点续传下载示例详解  # Android 使用AsyncTask实现多任务多线程断点续传下载  # Android实现网络多线程断点续传下载实例  # Android编程开发实现多线程断点续传下载器实例  # PC版与Android手机版带断点续传的多线程下载  # Android 使用AsyncTask实现多线程断点续传  # android原生实现多线程断点续传功能  # 断点续传  # 器上  # 客户端  # 连接到  # 还需要  # 的是  # 几个  # 多线程  # 在此  # 有所不同  # 很简单  # 便可  # 上传  # 则会  # 进行下载  # 如果你  # 是在  # 你可以  # 就能  # 也就 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: Laravel Facade的原理是什么_深入理解Laravel门面及其工作机制  Laravel如何使用Spatie Media Library_Laravel图片上传管理与缩略图生成【步骤】  Laravel如何优雅地处理服务层_在Laravel中使用Service层和Repository层  浏览器如何快速切换搜索引擎_在地址栏使用不同搜索引擎【搜索】  手机钓鱼网站怎么制作视频,怎样拦截钓鱼网站。怎么办?  如何自己制作一个网站链接,如何制作一个企业网站,建设网站的基本步骤有哪些?  Midjourney怎么调整光影效果_Midjourney光影调整方法【指南】  网站制作报价单模板图片,小松挖机官方网站报价?  Laravel如何集成第三方登录_Laravel Socialite实现微信QQ微博登录  如何在建站之星网店版论坛获取技术支持?  Zeus浏览器网页版官网入口 宙斯浏览器官网在线通道  免费的流程图制作网站有哪些,2025年教师初级职称申报网上流程?  悟空识字如何进行跟读录音_悟空识字开启麦克风权限与录音  Windows10电脑怎么设置虚拟光驱_Win10右键装载ISO镜像文件  高端云建站费用究竟需要多少预算?  ChatGPT怎么生成Excel公式_ChatGPT公式生成方法【指南】  海南网站制作公司有哪些,海口网是哪家的?  Laravel路由Route怎么设置_Laravel基础路由定义与参数传递规则【详解】  ChatGPT常用指令模板大全 新手快速上手的万能Prompt合集  如何实现javascript表单验证_正则表达式有哪些实用技巧  通义万相免费版怎么用_通义万相免费版使用方法详细指南【教程】  济南网站建设制作公司,室内设计网站一般都有哪些功能?  如何用PHP快速搭建CMS系统?  Laravel如何处理表单验证?(Requests代码示例)  谷歌Google入口永久地址_Google搜索引擎官网首页永久入口  网站制作价目表怎么做,珍爱网婚介费用多少?  公司网站制作需要多少钱,找人做公司网站需要多少钱?  python中快速进行多个字符替换的方法小结  javascript和jQuery中的AJAX技术详解【包含AJAX各种跨域技术】  轻松掌握MySQL函数中的last_insert_id()  制作网站软件推荐手机版,如何制作属于自己的手机网站app应用?  消息称 OpenAI 正研发的神秘硬件设备或为智能笔,富士康代工  高防服务器租用首荐平台,企业级优惠套餐快速部署  夸克浏览器网页跳转延迟怎么办 夸克浏览器跳转优化  三星、SK海力士获美批准:可向中国出口芯片制造设备  Laravel如何使用API Resources格式化JSON响应_Laravel数据资源封装与格式化输出  Android中Textview和图片同行显示(文字超出用省略号,图片自动靠右边)  Edge浏览器如何截图和滚动截图_微软Edge网页捕获功能使用教程【技巧】  Java Adapter 适配器模式(类适配器,对象适配器)优缺点对比  Java类加载基本过程详细介绍  为什么要用作用域操作符_php中访问类常量与静态属性的优势【解答】  学生网站制作软件,一个12岁的学生写小说,应该去什么样的网站?  大学网站设计制作软件有哪些,如何将网站制作成自己app?  Laravel Asset编译怎么配置_Laravel Vite前端构建工具使用  武汉网站设计制作公司,武汉有哪些比较大的同城网站或论坛,就是里面都是武汉人的?  在centOS 7安装mysql 5.7的详细教程  Laravel如何处理CORS跨域问题_Laravel项目CORS配置与解决方案  Laravel如何创建自定义Artisan命令?(代码示例)  laravel怎么使用数据库工厂(Factory)生成带有关联模型的数据_laravel Factory生成关联数据方法  php后缀怎么变mp4格式错误_修改扩展名提示格式不对怎么办【技巧】