Golangでチャンク転送アップロードを実現する方法

2年 ago
光, 明
2 minutes

Go言語のバックエンドで部分ダウンロードを実現するには、以下の手順に従います。

  1. ファイル要求時にHTTP要求ヘッダー部にRangeフィールドを追加し、要求対象ファイルの開始位置を明示する必要がある。
  2. クライアントからリクエストヘッダのRangeフィールドで断片的な再開がサポートされているかどうかをバックエンドサーバが確認する
  3. Rangeヘッダーの値に応じて、サーバはファイルの一部を読み込み、読み込まれた内容をクライアントに返します。
  4. ブレークポイントがサポートされていない場合、サーバは完全なファイルをクライアントに返します。

以下は、再開可能な断点を实现するための簡単なサンプルコードです。

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 フィールドを解析して、レンジダウンロード（部分ダウンロード）に対応しているかを判断します。対応している場合は、クライアント要求の範囲に基づいてファイル内容を読み込み、クライアントに返します。対応していない場合は、ファイルの完全版を返します。必要に応じて実際の状況に合わせて適切に変更してください。

bannerAds