前言

对于一些较大文件的上传下载，我们期望的是能够一次就完成，这样不仅节省时间也节省用户流量，用户体验也会更好等等。但是网络环境的不可靠性导致较大文件的传输一次就完成的把握实在不是很大，所以针对这种情况，人们就考虑能否让失败的任务在下次继续时接着传输未传输的部分，而已经传输过的则不再传输，由此，断点续传被创造出来了。

一、Seek介绍

Golang中的断点续传实现最简便的方法是借助Seek方法：

type Seeker interface {Seek(offset int64, whence int) (int64, error)
}

在断点续传中我们使用file类去读取写入文件，因为file实现了Seeker接口，通过它我们可以很方便的实现我们想要的功能。

Seek有两个参数：
1.offset 偏移量
2.whence 决定偏移量从什么地方开始
2.1 SeekStart 从头开始
2.2 SeekCurrent 从当前开始
2.3 SeekEnd 从末尾开始

二、Seek的使用

根据D:\test.txt文件来测试Seek函数中whence参数的作用：

1.SeekStart

代码如下：

fileName := "D:\\test.txt"
file,_ := os.OpenFile(fileName,os.O_CREATE,os.ModePerm)
b := []byte{0}
file.Seek(2,io.SeekStart)
file.Read(b)
fmt.Println(string(b))

结果：

解释：由于SeekStart是表示offset是从头开始，所以这里从头开始偏移两位，得到第三位的数据：C

2.SeekCurrent

代码如下：

fileName := "D:\\test.txt"
file,_ := os.OpenFile(fileName,os.O_CREATE,os.ModePerm)
b := []byte{0}
file.Read(b)
file.Seek(2,io.SeekCurrent)
file.Read(b)
fmt.Println(string(b))

结果：

解释:由于SeekCurrent是从当前位置开始，所以当前面已经读取过一个byte之后，再偏移两位，总共偏移三位，所以得到第四位：D

3.SeekEnd

代码如下：

fileName := "D:\\test.txt"
file,_ := os.OpenFile(fileName,os.O_CREATE,os.ModePerm)
file.Seek(0,io.SeekEnd)
file.WriteString("a")

结果：

解释：由于SeekEnd是表示从末尾开始，所以写入的 a 被添加到最后。

三、断点续传

仍然使用上面的test.txt文本来进行断点续传的操作。

func duanDian() {fileName := "D:\\test.txt" //源文件destFile := "D:\\dest.txt" //下载的目标文件tempFile := "D:\\temp.txt" //临时文件（用来记录下载过的字节数）file,err := os.OpenFile(fileName,os.O_CREATE,os.ModePerm)dest, _ := os.OpenFile(destFile,os.O_CREATE|os.O_WRONLY,os.ModePerm)temp,_ := os.OpenFile(tempFile,os.O_CREATE|os.O_RDWR,os.ModePerm)defer file.Close()defer dest.Close()defer temp.Close()//首先读取临时文件中保存的已经下载过的数量temp.Seek(0,io.SeekStart)bs := make([]byte,100)n1,_ := temp.Read(bs)//读取临时文件中保存的字节数countStr := string(bs[:n1])//转换成int型count,_ := strconv.ParseInt(countStr,10,64)//得到已经下载过的进度之后同步源文件跟目标文件//偏移量为已经下载过的，我们需要继续下载的是剩下的file.Seek(count,io.SeekStart)dest.Seek(count,io.SeekStart)//定义一个byte切片，大小设置为1，因为我们的测试案例只有几个单词data := make([]byte,1)//设置变量来记录读取写入的字节数n2,n3 := -1,-1//已经写入的字节总数，用来存放到temp文件total := int(count)for {//开始读取源文件内容n2,err = file.Read(data)if err == io.EOF {fmt.Println("文件复制完毕！")temp.Close()//下载完成之后删除临时文件err = os.Remove(tempFile)if err != nil {panic(err)}break}//读取之后写入目标文件n3,_ = dest.Write(data[:n2])//更新写入的总数total += n3temp.Seek(0,io.SeekStart)temp.WriteString(strconv.Itoa(total))//这里可以测试网络中断造成的下载异常，//注释之后重新运行将会从失败的地方重新下载//if total == 2 {//    panic("网络异常，下载失败！")//}}
}

Golang断点续传相关推荐

golang实现文件服务器,【Golang】实现文件服务器断点续传
Loading... # 0x00 下载文件时暂停后可以继续接着下载,在线看视频时可以随意拖动进度条,这些都是断点续传所实现的应用. http1.1支持**Range**属性从而实现断点续传,客户端在 ...
golang实现多协程下载文件(支持断点续传)
golang实现多协程下载文件(支持断点续传) 引言写这篇文章主要是周末休息太无聊,看了看别人代码,发现基本上要么是多协程下载文件要么就只有单协程的断点续传,所以就试了试有进度条的多协程下载文件(支 ...
golang实现断点续传
这里只展示了核心代码部分,使用了封装request和response的gin框架,若小伙伴没使用可用改成go自带的http. func SendFile(r *gin.Context) {//断点续传 ...
Golang：实现断点续传（http单线程下载文件）
package breakpointContinuationimport ("fmt""io""io/ioutil""net/ht ...
Golang：实现断点续传（复制文件）
1.将文件pic_src.jpg复制到pic_des.jpg文件: 2.读写过程中断时,读写的中断位置会记录在"pic_des.jpgtemp.txt"文件里: 3.下次再启动程序 ...
golang之文件读写/复制/断点续传
目录一.常用读取文件的三种方式 (1)利用os和file原生操作读文件 (2)使用bufio读取文件 (3)使用ioutil读取文件二.常用写文件的三种方式 (1)利用os和file原生操作写文件 ...
Golang操作阿里云OSS上传文件
为什么要使用OSS?应用场景是什么? 最近在开发考试系统,里面需要上传课件,课件包括pdf,map等等各种类型的文件,这些文件不能像图片一样,直接上传到项目目录下面,需要单独存放,阿里云就提供了存储方 ...
minio断点续传方案
minio断点续传方案一.功能二.特点三.效果四.详细方案完整代码在此完整代码在此完整代码在此一.功能 1.分片上传 2.断点续传 3.秒传二.特点 1.不暴露minio敏感信息 2 ...
golang 实战企业网盘
一.功能需求 1.基于golang实现分布式文件上传服务 2.ceph和阿里云oss 3.支持断点续传和秒传功能 4.微服务化和容器部署二.项目使用到的技术 redis mysql rabbitmq ...

Golang断点续传

目录

前言

一、Seek介绍

二、Seek的使用

1.SeekStart

2.SeekCurrent

3.SeekEnd

三、断点续传

Golang断点续传相关推荐

最新文章

热门文章