第Golang實現(xiàn)斷點續(xù)傳功能本文實例為大家分享了Golang實現(xiàn)斷點續(xù)傳的具體代碼，供大家參考，具體內容如下

1、將文件pic_src.jpg復制到pic_des.jpg文件；

2、讀寫過程中斷時，讀寫的中斷位置會記錄在pic_des.jpgtemp.txt文件里；

3、下次再啟動程序時，程序會接著pic_des.jpgtemp.txt文件里記錄的中斷位置，繼續(xù)讀、寫文件，直到完成傳輸；

具體代碼實現(xiàn)，如下：

packagemain

import(

"fmt"

"os"

"strconv"

"io"

"log"

//"time"

funcmain(){

/*

斷點續(xù)傳：

文件傳遞：文件復制

srcFile復制到destFile

思路：

邊復制，邊記錄復制的總量（記錄總復制字節(jié)數(shù)保存至tempFile）

復制一半中斷后，若再次復制，會先讀取tempFile文件里記錄的已完成字節(jié)總數(shù)

然后將這個字節(jié)數(shù)作為文件讀寫offset（偏移量），

來結合whence（偏移位置）來決定后面讀寫文件的起點位置。

seek(offset,whence),設置指針光標的位置

第一個參數(shù)：偏移量

第二個參數(shù)：如何設置

0：seekStart表示相對于文件開始，

1：seekCurrent表示相對于當前偏移量，

2：seekend表示相對于結束。

*/

srcFile:="./0731/ddxc/pic_src.jpg"

destFile:="./0731/ddxc/pic_des.jpg"

tempFile:=destFile+"temp.txt"

file1,err:=os.Open(srcFile)

iferr!=nil{

log.Fatalln(err)

}

file2,_:=os.OpenFile(destFile,os.O_CREATE|os.O_WRONLY,os.ModePerm)

file3,_:=os.OpenFile(tempFile,os.O_CREATE|os.O_RDWR,os.ModePerm)

deferfile1.Close()

deferfile2.Close()

//1.讀取臨時文件中的數(shù)據(jù)，根據(jù)seek

file3.Seek(0,io.SeekStart)

bs:=make([]byte,100,100)

n1,err:=file3.Read(bs)

fmt.Println(n1)

countStr:=string(bs[:n1])

fmt.Println(countStr)

count,_:=strconv.ParseInt(countStr,10,64)

fmt.Println(count)

//2.設置讀，寫的偏移量

file1.Seek(count,0)//設置file1下一次讀或者寫的起點

file2.Seek(count,0)//設置file2下一次讀或者寫的起點

data:=make([]byte,1024,1024)

n2:=-1//讀取的數(shù)據(jù)量，默認值

n3:=-1//寫出的數(shù)據(jù)量

total:=int(count)//讀取的總量

for{

//3.讀取數(shù)據(jù)

//基于上面的起點，讀取file1文件len（data）個字節(jié)，

//n2：實際讀取的字節(jié)數(shù)（小于等于len（data），將讀取的字節(jié)存入data。

n2,err=file1.Read(data)

iferr==io.EOF{

fmt.Println("文件復制完畢。。")

file3.Close()

//os.Remove(tempFile)//復制完，先不刪除，驗證最后存儲的字節(jié)總數(shù)是不是跟復制的文件大小一致。

break

}

//將數(shù)據(jù)寫入到目標文件

//基于上面的起點，向file2文件寫入len（data[:n2]）個字節(jié)，也就是寫入data中前n2個元素；

//n3：實際寫入的字節(jié)數(shù)（小于等于n2）。

n3,_=file2.Write(data[:n2])

total+=n3

//將復制總量，存儲到臨時文件中

file3.Seek(0,io.SeekStart)//設置file3的下次讀寫起點為源點：0點，即覆蓋重寫。

file3.WriteString(strconv.Itoa(total))

//假裝斷電

//iftotal1800000{

//

panic("假裝斷電了。。。，假裝的。。。")

//}