Android实现断点续传功能
本文实例为大家分享了Android实现断点续传的具体代码，供大家参考，具体内容如下
断点续传功能，在文件上传中断时，下次上传同一文件时，能在上次的断点处继续上传，可节省时间和流量
总结规划步骤：
1.给大文件分片，每一个大文件发送前，相对应的创建一个文件夹存放所有分片
2.上传接口，每一个分片上传完成就删掉，直到所有分片上传完成，再删掉存放分片的文件夹，服务器把分片合成完整的文件。
先看分片功能，传入的3个参数分别为源文件地址，分片大小，存放分片的文件夹地址。返回的是分片个数。
/**
*
* @param sourceFilePath 源文件地址
* @param partFileLength 分割文件的每一个片段大小标准
* @param splitPath 分割之后片段所在文件夹
* @return
* @throws Exception
*/
public static int splitFile(String sourceFilePath, int partFileLength, String splitPath) throws Exception {
File sourceFile = null;
File targetFile = null;
InputStream ips = null;
OutputStream ops = null;
OutputStream configOps = null;//该文件流用于存储文件分割后的相关信息，包括分割后的每个子文件的编号和路径,以及未分割前文件名
Properties partInfo = null;//properties用于存储文件分割的信息
byte[] buffer = null;
int partNumber = 1;
sourceFile = new File(sourceFilePath);//待分割文件
ips = new FileInputStream(sourceFile);//找到读取源文件并获取输入流
//创建一个存放分片的文件夹
File tempFile = new File(splitPath);
if (!tempFile.exists()) {
tempFile.mkdirs();
}
configOps = new FileOutputStream(new File(tempFile.getAbsolutePath() + File.separator + "config.properties"));
buffer = new byte[partFileLength];//开辟缓存空间
int tempLength = 0;
partInfo = new Properties();//key:1开始自动编号 value:文件路径
int sliceCount = 0;
while ((tempLength = ips.read(buffer, 0, partFileLength)) != -1) {
String targetFilePath = tempFile.getAbsolutePath() + File.separator + "part_" + (partNumber);//分割后的文件路径+文件名
sliceCount = partNumber;
partInfo.setProperty((partNumber++) + "", targetFilePath);//将相关信息存储进properties
targetFile = new File(targetFilePath);
ops = new FileOutputStream(targetFile);//分割后文件
ops.write(buffer, 0, tempLength);//将信息写入碎片文件
ops.close();//关闭碎片文件
}
partInfo.setProperty("name", sourceFile.getName());//存储源文件名
partInfo.setProperty("sliceCount", sliceCount + "");//存储分片个数
partInfo.store(configOps, "ConfigFile");//将properties存储进实体文件中
ips.close();//关闭源文件流
return sliceCount;
}
接下来，和服务器协商接口，一共2个接口
1.uploadLargeFilePre，传入参数除了常规上传文件参数之外加了分片个数sliceCount和fileHashcode。这一步是给服务器开辟存放分片的控件的，不执行上传操作，文件哈希值作为识别分片归属的唯一标准。返回int类型rCode，根据rCode结果判断是否执行第2步上传动作
2.uploadLargeFile，传入参数除了常规上传文件参数之外加了分片path，分片index，isFinished。isFinished是最后一片的依据。客户端就在上传接口的response里继续上传下一个分片，直到最后一片上传完成，服务器才会返给这个大文件的url。
看代码
protected void addFileMsg(String path) {
forceLogin();
if (path == null) {
return;
}
File file = new File(path);
if (file.exists()) {
ImMsg msg = new ImMsg();
msg.setType(ImMsg.MSG_TYPE_FILE);
msg.setTime(System.currentTimeMillis());
msg.setMsgReaded();
msg.setReceiveTime(System.currentTimeMillis());
AccountInfo accountInfo = IMApp.instance().getAccountInfo();
msg.setUserId(accountInfo.getUserId());
msg.setSex(accountInfo.getSex());
msg.setUserName(accountInfo.mNickName);
msg.setHeadUrl(accountInfo.mHead);
msg.mMasterId = mMasterId;
msg.setMsg(new File(path).getName());
msg.setPicPath(path);
msg.setState(ImMsg.STATE_SEND_UPLOADING);
String ext = null;
if (path.endsWith("doc") || path.endsWith("docx")) {
ext = "doc";
} else if (path.endsWith("xls") || path.endsWith("xlsx")) {
ext = "xls";
} else if (path.endsWith("ppt") || path.endsWith("pptx")) {
ext = "ppt";
} else if (path.endsWith("pdf")) {
ext = "pdf";
}
msg.setMsg_extend3(ext);
msg.mFileSize = (int) new File(path).length();
msg.setHasAtt(hasAtt());
addMsgToDB(msg);
isFileListSingle = fileList.size() == 1;
SPHelper spHelper = SPHelper.build();
int lastSlices = spHelper.get(slice_old, 0);
String aesPath = spHelper.get(slice_aesEncPath, "");
String lastPath = spHelper.get(slice_picPath, "");
int tempTotalCount = spHelper.get(CommonUtils.FAILED_TEMP_SEND_TOTAL_COUNT, 0);//实际发送总个数
if (lastSlices == 1 && tempTotalCount > 1) {
/**
* 读取上次失败文件的进度，如果还剩一个失败文件，但是上次发送的总文件个数大于1，
* 则fileList.size() == 1这个判断不能用，在所有判断处加一个标志
*/
isFileListSingle = false;
}
//根据文件大小，判断是否用分片上传 modify hexiaokang 2019年11月5日11点01分
if (new File(path).length() < Global.FILE_SPILT_LENGTH) {//文件小于5M,常规上传方式
upLoadFile(msg);
} else {
File sourceFile = new File(path);
//分片所在文件夹,以未做AES加密的源文件名作为 分片文件夹名字
String sliceDir = sourceFile.getParent() + File.separator + sourceFile.getName() + "_split";
if (lastSlices == 1
&& path.equals(lastPath)
&& new File(sliceDir).exists()
&& !aesPath.equals("")
&& new File(aesPath).exists()) {//发送上次的旧文件中断的分片
//只走一次
spHelper.put(slice_old, 0);
sliceIndex = spHelper.get(slice_sliceIndex, 0);
int count = spHelper.get(slice_sliceCount, 0);
LogUtil2.i(TAG + "&onUploadComplete", "sendOldFiles sliceIndex = " + sliceIndex + ", sliceCount = " + count);
largeFilePre = true;
upLoadLargeFilePre(msg, count, sliceDir, aesPath);
} else {//发送大文件正常流程
//给文件分片
int partFileLength = Global.FILE_SPILT_LENGTH;//指定分割的子文件大小为5M
//先对文件做AES加密,再进行分片,这里很重要
String aesEncPath = EncryptMgr.encFile(path, accountInfo.getEncTime(), accountInfo.getEncKey());
File f = new File(aesEncPath);
LogUtil2.i(TAG + "&onUploadComplete", "ChatMsgActivity.addFileMsg: big file enc path=" + path);
try {
sliceCount = FileSliceUtil.splitFile(aesEncPath, partFileLength, sliceDir);//将文件分割
} catch (Exception e) {
LogUtil2.e(TAG, "split.e:" + e.getMessage());
e.printStackTrace();
}
// LogUtil2.e(TAG+"&onUploadComplete", "ChatMsgActivity.addFileMsg: sliceCount:" + sliceCount);
//分片上传
largeFilePre = false;
upLoadLargeFilePre(msg, sliceCount, sliceDir, aesEncPath);
}
}
}
}
上面这一块代码，除了小文件常规上传，就是大文件上传方式了。大文件上传这里分了2种情况，
1.发送上次中断的大文件分片，这里就不用分片了，直接从sp拿到上次中断的分片count、index等信息直接上传
2.从分片到发送的全部流程，因为我这里对文件做了AES加密，所以是加密之后再分片
接下来就是上传过程
public void upLoadLargeFilePre(final ImMsg msg, final int sliceCount, final String sliceDir, final String aesEncPath) {
if (msg.getState() != ImMsg.STATE_SEND_WAITING) {
msg.setState(ImMsg.STATE_SEND_UPLOADING);
mListAdapter.notifyDataSetChanged();
}
AccountInfo accountInfo = IMApp.instance().getAccountInfo();
UploadFileHelper helper = new UploadFileHelper(accountInfo.getEncTime(), accountInfo.getEncKey(),
new UploadFileCallback() {
@Override
public void onError(Call call, Exception e) {
e.printStackTrace();
LogUtil2.e("onUploadComplete", "ChatMsgActivity.onError: error(split_upload):" + e.toString()+", call = "+call);
failCount++;
// if (msg.getPicPath() != null && msg.getPicPath().contains(SDCardUtil.getSDcardPathEx())) {
// new File(msg.getPicPath()).delete();
// }
btn_other_sendfile.setClickable(true);
CommonUtils.isSendBtnClickable = true;
Intent comIntent = new Intent();
comIntent.setAction(CommonUtils.USBFILE_COMPLETE_SEND);
comIntent.putExtra("fail_count", failCount);
sendBroadcast(comIntent);
tempProgress = 0;
largeFilePre = false;
//todo 上传失败，上传任务终止 (需要保存失败msg的信息，以及分片信息)
String picPath = msg.getPicPath();
// 保存picPath, sliceIndex, sliceCount, aesEncPath
SPHelper spHelper = SPHelper.build();
spHelper.put(slice_picPath, picPath);
spHelper.put(slice_sliceIndex, sliceIndex);
spHelper.put(slice_sliceCount, sliceCount);
spHelper.put(slice_aesEncPath, aesEncPath);
spHelper.put(slice_old, 1);//标记，1表示有上次失败的碎片，处理完上次失败的碎片之后设置为0
return;
}
@Override
public void onResponse(UploadFileAckPacket uploadFileAckPacket) {
LogUtil2.i("onUploadComplete", "ChatMsgActivity.onResponse: pre upload ack packet code="+uploadFileAckPacket.getRetCode()+", desc="+uploadFileAckPacket.getRetDesc());
if (getMsgFromDB(msg.getId()) == null) {
msg.setState(ImMsg.STATE_SEND_FAILED);
LogUtil2.i("onUploadComplete", "msg not exist d = (split_upload)" + msg.getId());
updateMsgToDB(msg);
mListAdapter.notifyDataSetChanged();
failCount++;
btn_other_sendfile.setClickable(true);
CommonUtils.isSendBtnClickable = true;
Intent comIntent = new Intent();
comIntent.setAction(CommonUtils.USBFILE_COMPLETE_SEND);
sendBroadcast(comIntent);
tempProgress = 0;
return;
}
if (uploadFileAckPacket != null && uploadFileAckPacket.isSuccess()) {
LogUtil2.i("onUploadComplete", "msg exist and sucess(uploadFileAckPacket.sliceIndex(split_upload)):" + uploadFileAckPacket.sliceIndex+", sliceCount="+sliceCount+", url="+uploadFileAckPacket.mUrl);
if (sliceIndex < sliceCount && TextUtils.isEmpty(uploadFileAckPacket.mUrl)) {
//更新进度条
if (isFileListSingle) {//单个大文件
int pro = 100 * sliceIndex / sliceCount;
Intent uploadIntent = new Intent();
uploadIntent.setAction(CommonUtils.USBFILE_PROGRESS_SEND);
uploadIntent.putExtra("sentCount", -1);//-1 代表发送的是单个文件
uploadIntent.putExtra("sentPro", pro);
sendBroadcast(uploadIntent);
} else {//一次发送多个文件，包括大文件
}
//删除掉上传成功的分片
String slicePath = sliceDir + File.separator + "part_" + (sliceIndex);
new File(slicePath).delete();
sliceIndex++;
//还有待上传的分片
upLoadLargeFilePre(msg, sliceCount, sliceDir, aesEncPath);
} else {
//所有分片上传完成
largeFilePre = false;
LogUtil2.i("onUploadComplete", "ChatMsgActivity.onResponse: 所有分片上传完成 largeFilePre="+largeFilePre);
msg.updateImageUpLoadProgress(100);
msg.setPicBigUrl(uploadFileAckPacket.mUrl);
//这里删除原文件
if (msg.getPicPath() != null && msg.getPicPath().contains(SDCardUtil.getSDcardPathEx())) {
File file = new File(msg.getPicPath());
//删除分片所在的文件夹
FileUtil.deleteFolderFile(sliceDir, true);
//删除文件
file.delete();
// EventBus.getDefault().post(new EncFileEvent(EncFileEvent.COM_FILE_DELETE, msg.getPicPath(), 0));
msg.setPicPath("");
}
if (msg.getType() == ImMsg.MSG_TYPE_IMAGE) {
msg.setPicSmallUrl(uploadFileAckPacket.mThumbnail);
msg.mThumbWidth = this.mThumbWidth;
msg.mThumbHeight = this.mThumbHeight;
}
LogUtil2.i("onUploadComplete", "msg exist and sucess(msg.getPicBigUrl()(split_upload)):" + msg.getPicBigUrl());
sendMsg(msg);
sentCount++;
sliceIndex = 1;
if (isFileListSingle) {//单个文件不用处理
} else {
//传递上传进度
Intent uploadIntent = new Intent();
uploadIntent.setAction(CommonUtils.USBFILE_PROGRESS_SEND);
uploadIntent.putExtra("sentCount", sentCount);
sendBroadcast(uploadIntent);
}
//继续上传下一个文件
if (sentCount < fileList.size()) {
addFileMsg(fileList.get(sentCount).getAbsolutePath());
} else {
//所有文件上传完成
btn_other_sendfile.setClickable(true);
CommonUtils.isSendBtnClickable = true;
Intent comIntent = new Intent();
comIntent.setAction(CommonUtils.USBFILE_COMPLETE_SEND);
sendBroadcast(comIntent);
tempProgress = 0;
}
}
} else {
LogUtil2.e("onUploadComplete", "rCode(split_upload)):" + uploadFileAckPacket.getRetCode()+", sliceIndex="+uploadFileAckPacket.sliceIndex);
if(uploadFileAckPacket.getRetCode()==1343688774){
LogUtil2.e("onUploadComplete", "ChatMsgActivity.onResponse: 缺片了！");
}
msg.setState(ImMsg.STATE_SEND_FAILED);
updateMsgToDB(msg);
if (!IMMsgMgr.notifyActivity(IMMsgMgr.IM_CMD_IMP2PMSG_ACK, msg.getUserId(), msg.hasAtt(), false, msg)) {
}
mListAdapter.notifyDataSetChanged();
}
}
@Override
public void inProgress(float progress) {
super.inProgress(progress);
// LogUtil2.i("onUploadProgress", "inProgress " + progress+", path="+msg.getPicPath()+", sliceDir="+sliceDir);
LogUtil2.i("onUploadProgress", "ChatMsgActivity.inProgress: sliceCount="+sliceCount+", sliceIndex="+sliceIndex+", sentCount="+sentCount+", list.size="+fileList.size()+", progress="+progress+", tempProgress="+tempProgress);
int pro = (int) (progress * 100);
if (new File(msg.getPicPath()).length() < Global.FILE_SPILT_LENGTH) {
//
}else{
int allPro= (int)(100*(progress+(sliceIndex-1))/sliceCount);
if (isFileListSingle && allPro - tempProgress >= 1) {
//todo 分片上传，进度条重新计算,
//多个文件上传不用考虑，这里重新计算单个文件的上传问题
LogUtil2.i("onUploadProgress", "ChatMsgActivity.inProgress: big file allPro="+allPro);
Intent uploadIntent = new Intent();
uploadIntent.setAction(CommonUtils.USBFILE_PROGRESS_SEND);
uploadIntent.putExtra("sentCount", -1);//-1代表发送的是单个文件，这里是针对用户感知而言的代码逻辑
uploadIntent.putExtra("sentPro", allPro);
tempProgress = allPro;
sendBroadcast(uploadIntent);
}
}
// 更新
mListAdapter.notifyDataSetChanged();
}
}, msg);
LogUtil2.i("onUploadComplete", "ChatMsgActivity.upLoadLargeFilePre: largeFilePre="+largeFilePre);
if (largeFilePre) {//todo 是否有过预处理
String slicePath = sliceDir + File.separator + "part_" + (sliceIndex);
int isFinished = sliceIndex == sliceCount ? 1 : 0;
helper.upLoadLargeFile(aesEncPath, slicePath, sliceIndex, isFinished);
} else {
//上传大文件 预处理
int rCode = helper.upLoadLargeFilePre(aesEncPath, sliceCount);
if (rCode == 0) {//预处理成功，可以执行上传任务
largeFilePre = true;
String slicePath = sliceDir + File.separator + "part_" + (sliceIndex);
int isFinished = sliceIndex == sliceCount ? 1 : 0;
helper.upLoadLargeFile(aesEncPath, slicePath, sliceIndex, isFinished);
} else {
//预处理失败，不执行上传任务
LogUtil2.i("onUploadComplete", "somewordsrCode:" + rCode+", before plus faileCount="+failCount);
msg.setState(ImMsg.STATE_SEND_FAILED);
updateMsgToDB(msg);
mListAdapter.notifyDataSetChanged();
failCount++;
btn_other_sendfile.setClickable(true);
CommonUtils.isSendBtnClickable = true;
Intent comIntent = new Intent();
comIntent.putExtra("upload_error", 0);
comIntent.putExtra("fail_count",failCount);
comIntent.setAction(CommonUtils.USBFILE_COMPLETE_SEND);
LogUtil.LogShow("onUploadComplete", "ChatMsgActivity.upLoadLargeFilePre: before sendIntent failCount="+failCount);
sendBroadcast(comIntent);
failCount=0;
tempProgress = 0;
}
}
}
上面这一块就是上传过程
int rCode = helper.upLoadLargeFilePre(aesEncPath, sliceCount); 这一句为第一个接口预处理，根据结果决定是否执行上传。
helper.upLoadLargeFile(aesEncPath, slicePath, sliceIndex, isFinished); 这一句执行上传，在onResponse里处理上传结果，我这里有多个文件连续上传，所以结果处理看起来有点凌乱。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。
相关推荐
-
android的RecyclerView实现拖拽排序和侧滑删除示例
在平时开发应用的时候,经常会遇到列表排序.滑动删除的需求.如果列表效果采用的是 ListView 的话,需要经过自定义 View 才能实现效果:但是如果采用的是 RecyclerView 的话,系统 API 就已经为我们提供了相应的功能. 接下来,我们就来看一下怎么用系统 API 来实现排序和删除的效果. 创建 ItemTouchHelper 创建一个 ItemTouchHelper 对象,然后其调用 attachToRecyclerView 方法: RecyclerView recyclerV
-
RecyclerView实现侧滑拖拽功能
本文实例为大家分享了RecyclerView实现侧滑拖拽功能的具体代码,供大家参考,具体内容如下 准备 ItemDragListener package slideslipdrag; import android.support.v7.widget.RecyclerView; /** * Created on 2018/7/22. * * @desc ItemDragListener */ public interface ItemDragListener { /** * 拖拽 * * @par
-
详解Android使用OKHttp3实现下载(断点续传、显示进度)
OKHttp3是如今非常流行的Android网络请求框架,那么如何利用Android实现断点续传呢,今天写了个Demo尝试了一下,感觉还是有点意思 准备阶段 我们会用到OKHttp3来做网络请求,使用RxJava来实现线程的切换,并且开启Java8来启用Lambda表达式,毕竟RxJava实现线程切换非常方便,而且数据流的形式也非常舒服,同时Lambda和RxJava配合食用味道更佳 打开我们的app Module下的build.gradle,代码如下 apply plugin: 'com.an
-
LRecyclerView侧滑iOS阻塞效果不完整的解决办法
最近项目中用到下拉刷新与侧滑删除需要同时实现的情形, 所以对LRecyclerView进行了一些了解, 在测试侧滑功能时, 发现iOS阻塞效果不完整, 即当条目处于侧滑状态时, 点击该条目的非侧滑位置时无法自动关闭, 于是对LRecyclerView项目中的自定义 SwipeMenuView进行了分析, 发现在dispatchTouchEvent的down事件中进行了如下的条件判断: if (mViewCache != this) { mViewCache.smoothClose(); mVie
-
RecyclerView进阶：使用ItemTouchHelper实现拖拽和侧滑删除效果
前言 现在RecyclerView的应用越来越广泛了,不同的应用场景需要其作出不同的改变.有时候我们可能需要实现侧滑删除的功能,比如知乎首页的侧滑删除,又或者长按Item进行拖动与其他Item进行位置的交换,但RecyclerView没有提供现成的API供我们操作,所幸SDK提供了ItemTouchHelper这样一个工具类帮助我们快速实现以上功能.不多说别的,我们来介绍一下ItemTouchHelper. 什么是ItemTouchHelper This is a utility class t
-
RecyclerView实现侧滑和网络断点续传
本文实例为大家分享了RecyclerView实现侧滑和网络断点续传的具体代码,供大家参考,具体内容如下 RecyclerView侧滑 主布局 <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:app="http://schemas.android.com/apk/res-auto" xmlns:tools="http://sch
-
Android recyclerview实现拖拽排序和侧滑删除
Recyclerview现在基本已经替代Listview了,RecyclerView也越来越好用了 当我们有实现条目的拖拽排序和侧滑删除时 可以直接时候Recyclerview提供的API就可以直接实现了 先贴上主要代码 private void initveiw() { ArrayList<String> items = new ArrayList<>(Arrays.asList("itme1", "item2", "itme
-
android实现多线程下载文件（支持暂停、取消、断点续传）
多线程下载文件(支持暂停.取消.断点续传) 多线程同时下载文件即:在同一时间内通过多个线程对同一个请求地址发起多个请求,将需要下载的数据分割成多个部分,同时下载,每个线程只负责下载其中的一部分,最后将每一个线程下载的部分组装起来即可. 涉及的知识及问题 请求的数据如何分段 分段完成后如何下载和下载完成后如何组装到一起 暂停下载和继续下载的实现(wait().notifyAll().synchronized的使用) 取消下载和断点续传的实现 一.请求的数据如何分段 首先通过HttpURLConne
-
android RecyclerView侧滑菜单，滑动删除，长按拖拽，下拉刷新上拉加载
本文介绍的库中的侧滑效果借鉴自SwipeMenu,并对SipwMenu的源码做了修改与Bug修复,然后才开发出的SwipeRecyclerView. 需要说明的是,本库没有对RecyclerView做大的修改,只是ItemView的封装.看起来是对RecyclerView的修改,其实仅仅是为RecyclerView添加了使用的方法API而已. 本库已经更新了三个版本了,会一直维护下去,根据小伙伴的要求,以后也会添加一些其它功能. SwipeRecyclerView将完美解决这些问题: 以下功能全
-
Android实现多线程断点续传
本文实例为大家分享了Android实现多线程断点续传的具体代码,供大家参考,具体内容如下 多线程下载涉及到的知识点: 1.Service的使用:我们在Service中去下载文件:2.Thread的使用:Service本身不支持耗时操作,所以我们要去开启线程:3.Sqlite的使用:使用数据库来存储每个线程下载的文件的进度,和文件的下载情况:4.权限:涉及到文件的读写就要用到权限:5.BroadCastReceiver的使用:通过广播来更新下载进度:6.线程池使用:使用线程池来管理线程,减少资源的