在Go語言的后端中，實現斷點續傳可以通過以下幾個步驟來完成：
客戶端請求文件時，需要在HTTP請求的頭部加上Range字段，指定請求文件的起始位置。
后端服務器接收到請求后，根據客戶端請求頭中的Range字段，檢查是否支持斷點續傳。
如果支持斷點續傳，服務器根據請求頭中的Range字段，讀取文件的指定部分，并將讀取到的文件內容返回給客戶端。
如果不支持斷點續傳，服務器將完整的文件返回給客戶端。
下面是一個簡單的示例代碼，用于實現斷點續傳：
func handleFileDownload(w http.ResponseWriter, r *http.Request) {
file, err := os.Open("path/to/file") // 打開文件
if err != nil {
http.Error(w, "File not found", http.StatusNotFound)
return
}
defer file.Close()
fileInfo, err := file.Stat()
if err != nil {
http.Error(w, "Internal server error", http.StatusInternalServerError)
return
}
fileSize := fileInfo.Size()
rangeHeader := r.Header.Get("Range") // 獲取請求頭中的Range字段
if rangeHeader != "" { // 如果請求頭中存在Range字段
ranges, err := parseRangeHeader(rangeHeader, fileSize) // 解析Range字段
if err != nil {
http.Error(w, "Invalid range header", http.StatusBadRequest)
return
}
if len(ranges) == 1 { // 如果只有一個范圍
start := ranges[0].start
end := ranges[0].end
if start < 0 || start >= fileSize || end >= fileSize || end < start {
http.Error(w, "Invalid range", http.StatusBadRequest)
return
}
w.Header().Set("Content-Length", strconv.FormatInt(end-start+1, 10))
w.Header().Set("Content-Range", fmt.Sprintf("bytes %d-%d/%d", start, end, fileSize))
w.WriteHeader(http.StatusPartialContent)
_, err := file.Seek(start, io.SeekStart)
if err != nil {
http.Error(w, "Internal server error", http.StatusInternalServerError)
return
}
io.CopyN(w, file, end-start+1) // 將文件內容寫入ResponseWriter
return
} else {
// 如果有多個范圍，暫不支持斷點續傳
http.Error(w, "Multiple ranges not supported", http.StatusBadRequest)
return
}
}
// 如果請求頭中不存在Range字段，返回完整文件
w.Header().Set("Content-Length", strconv.FormatInt(fileSize, 10))
w.WriteHeader(http.StatusOK)
io.Copy(w, file) // 將文件內容寫入ResponseWriter
}
func parseRangeHeader(rangeHeader string, fileSize int64) ([]rangeInfo, error) {
ranges := make([]rangeInfo, 0)
rangeStrs := strings.Split(rangeHeader, ",")
for _, rangeStr := range rangeStrs {
parts := strings.SplitN(rangeStr, "=", 2)
if len(parts) != 2 || parts[0] != "bytes" {
return nil, errors.New("Invalid range header")
}
rangeParts := strings.Split(parts[1], "-")
if len(rangeParts) != 2 {
return nil, errors.New("Invalid range header")
}
start, err := strconv.ParseInt(rangeParts[0], 10, 64)
if err != nil {
return nil, err
}
end, err := strconv.ParseInt(rangeParts[1], 10, 64)
if err != nil {
return nil, err
}
if start >= 0 && start <= fileSize {
ranges = append(ranges, rangeInfo{start, end})
}
}
return ranges, nil
}
type rangeInfo struct {
start int64
end int64
}
以上代碼通過解析Range字段，判斷是否支持斷點續傳，如果支持，則根據客戶端請求的范圍讀取文件內容并返回給客戶端。如果不支持斷點續傳，則返回完整文件內容。請根據實際情況進行適當修改。
