断点续传简介

在文件的下载中特别是大文件的下载中可能会出现各种原因导致的下载暂停情况如果不做特殊处理下次还需要从头开始下载既浪费了时间又浪费了流量。

不过HTTP协议通过Range首部提供了对文件分块下载的支持也就是说可以指定服务器返回文件特定范围的数据这就为我们实现文件的断点续传提供了基础。

RCP也很好的封装了这一点通过Request对象的transferRange属性可以支持分块下载transferRange可以是TransferRange或者TransferRange数组TransferRange类型包括两个属性from和to

from?:

from用于设置传输数据的起始字节,to用于设置传输数据的结束字节。

有了RCP的支持就比较容易实现文件的断点续传本文将通过一个示例进行演示。

2.断点续传下载文件示例

首选输入要下载文件的URL这里默认是下载的百度网盘的安装文件大概98M左右然后单击“选择”按钮选择本地保存路径如下图所示

选择保存的文件名称为demo.rpm然后回到主界面单击“下载”按钮就行下载

这样就实现了任意时候中断下载或者退出应用都不影响已下载的部分下次可以继续下载实现了真正的断点续传。

3.断点续传下载文件示例编写

//每次下载的字节数downloadPerBatchSize:

number

https://4d677c-1863975141.antpcdn.com:19001/b/pkg-ant.baidu.com/issue/netdisk/LinuxGuanjia/4.17.7/baidunetdisk_4.17.7_x86_64.rpm//是否正在下载Local

isRunning:

​//断点续传下载文件信息使用PersistenceV2进行持久化存储Local

downloadFileInfo:

PersistenceV2.connect(DownloadFileInfo,()

new

DownloadFileInfo(this.defaultUrl,

))!scroller:

rcp.createSession();//当前请求currentReq:

rcp.Request

{Text(this.title).fontSize(14).fontWeight(FontWeight.Bold).width(100%).textAlign(TextAlign.Center).padding(5)

​Flex({

{Text(url地址).fontSize(14).width(80).flexGrow(0)

​TextInput({

value}).width(110).fontSize(11).flexGrow(1)}.width(100%).padding(5)

​Flex({

{Text(本地保存路径).fontSize(14).width(80).flexGrow(1)

{this.downloadFileInfo.filePath

await

getSaveFilePath(getContext(this))if

(fs.accessSync(this.downloadFileInfo.filePath))

{fs.unlinkSync(this.downloadFileInfo.filePath)}}).width(110).fontSize(14)

下载).onClick(()

falsethis.currentSession.cancel(this.currentReq)}

else

​}).enabled(this.downloadFileInfo.filePath

2).width(110).fontSize(14)}.width(100%).padding(5)

​Text(this.downloadFileInfo.filePath).fontSize(14).width(100%).padding(5)

​Flex({

{Text(${(this.downloadFileInfo.totalSize

:((this.downloadFileInfo.downloadedSize

this.downloadFileInfo.totalSize)

100).toFixed(2))}%)}.width(200)

​Column()

this.downloadFileInfo.downloadedSize,total:

this.downloadFileInfo.totalSize,type:

ProgressType.Capsule})}.width(150).flexGrow(1)}.visibility(this.downloadFileInfo.state

Visibility.Visible

Visibility.None).width(100%).padding(10)

{Text(this.msgHistory).textAlign(TextAlign.Start).padding(10).width(100%).backgroundColor(0xeeeeee)}.align(Alignment.Top).backgroundColor(0xeeeeee).height(300).flexGrow(1).scrollable(ScrollDirection.Vertical).scrollBar(BarState.On).scrollBarWidth(20)}.width(100%).justifyContent(FlexAlign.Start).height(100%)}.height(100%)}

{let

session.head(this.downloadFileInfo.url)if

(resp.statusCode

Number.parseInt(resp.headers[content-length].toString())}this.msgHistory

size;}

(this.downloadFileInfo.totalSize

{this.downloadFileInfo.totalSize

await

(this.downloadFileInfo.totalSize

{this.msgHistory

truethis.downloadFileInfo.state

startIndex

this.downloadFileInfo.downloadedSizelet

endIndex

fs.openSync(this.downloadFileInfo.filePath,

fs.OpenMode.READ_WRITE)fs.lseek(localFile.fd,

​//循环下载,

(this.downloadFileInfo.downloadedSize

this.downloadFileInfo.totalSize

this.isRunning)

this.downloadFileInfo.totalSize)

{endIndex

this.downloadFileInfo.totalSize

1}let

this.downloadPartFile(startIndex,

endIndex,

​this.downloadFileInfo.downloadedSize

endIndex

(this.downloadFileInfo.downloadedSize

this.downloadFileInfo.totalSize)

2this.msgHistory

文件下载完成\r\n}fs.closeSync(localFile.fd)}

number,

rcp.Request(this.downloadFileInfo.url,

GET);this.currentReq.transferRange

from:

this.currentSession.fetch(this.currentReq)

​if

服务器状态响应异常状态码${resp.statusCode}\r\nreturn

false}

resp.body)fs.fsyncSync(localFile.fd)return

true}

picker.DocumentSaveOptions();let

documentPicker

picker.DocumentViewPicker(getContext(this));await

documentPicker.save(documentSaveOptions).then((result:

Arraystring)

要实现断点续传功能关键点在于事先获取文件的大小以及每次请求时获取文件的一部分数据获取文件大小是通过函数getDownloadFileSize实现的在这个函数里通过http的head方法可以只获取响应的首部其中包括文件的大小获取文件部分数据是通过设置请求的transferRange属性实现的

this.currentReq

rcp.Request(this.downloadFileInfo.url,

GET);this.currentReq.transferRange

from:

this.currentSession.fetch(this.currentReq)

另外示例支持应用退出以及重启后的断点续传这一点是通过PersistenceV2实现的把断点续传下载文件信息自动进行持久化存储下次启动时还可以自动加载从而实现了完全的文件断点续传。

当然这个示例还有很多需要完善的地方比如可以在重启后的断点续传前重新获取文件大小并且和本地进行比较防止服务端文件发生变化。

本文作者原创除非明确授权禁止转载

https://gitee.com/zl3624/harmonyos_network_samples/tree/master/code/rcp/RCPDownloadFileDemo

本系列源码地址

https://gitee.com/zl3624/harmonyos_network_samples