91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

golang怎么實現大文件傳輸和斷點續傳

小億
229
2024-02-28 14:39:31
欄目: 編程語言

在Golang中,可以使用HTTP協議來實現大文件傳輸和斷點續傳。下面是一個簡單的示例代碼:

package main

import (
	"fmt"
	"io"
	"net/http"
	"os"
	"strconv"
)

func handler(w http.ResponseWriter, r *http.Request) {
	file, err := os.Open("large_file.txt")
	if err != nil {
		fmt.Println("Error opening file: ", err)
		return
	}
	defer file.Close()

	fileInfo, err := file.Stat()
	if err != nil {
		fmt.Println("Error getting file info: ", err)
		return
	}

	w.Header().Set("Content-Disposition", "attachment; filename=large_file.txt")
	w.Header().Set("Content-Type", "application/octet-stream")
	w.Header().Set("Content-Length", strconv.FormatInt(fileInfo.Size(), 10))

	http.ServeContent(w, r, "large_file.txt", fileInfo.ModTime(), file)
}

func main() {
	http.HandleFunc("/", handler)
	http.ListenAndServe(":8080", nil)
}

在上面的示例中,我們首先打開了一個名為large_file.txt的大文件,并設置了HTTP響應頭,然后使用http.ServeContent函數將文件內容發送給客戶端。客戶端可以通過訪問http://localhost:8080來下載這個大文件。

如果要實現斷點續傳功能,可以通過檢查HTTP請求的Range頭來決定從文件的哪個位置開始傳輸。以下是一個修改后的示例代碼:

func handler(w http.ResponseWriter, r *http.Request) {
	file, err := os.Open("large_file.txt")
	if err != nil {
		fmt.Println("Error opening file: ", err)
		return
	}
	defer file.Close()

	fileInfo, err := file.Stat()
	if err != nil {
		fmt.Println("Error getting file info: ", err)
		return
	}

	w.Header().Set("Content-Disposition", "attachment; filename=large_file.txt")
	w.Header().Set("Content-Type", "application/octet-stream")
	w.Header().Set("Content-Length", strconv.FormatInt(fileInfo.Size(), 10))

	rangeHeader := r.Header.Get("Range")
	if rangeHeader != "" {
		startRange, endRange, err := parseRangeHeader(rangeHeader, fileInfo.Size())
		if err != nil {
			fmt.Println("Error parsing range header: ", err)
			return
		}
		w.Header().Set("Content-Range", fmt.Sprintf("bytes %d-%d/%d", startRange, endRange, fileInfo.Size()))
		http.ServeContent(w, r, "large_file.txt", fileInfo.ModTime(), io.NewSectionReader(file, startRange, endRange-startRange+1))
	} else {
		http.ServeContent(w, r, "large_file.txt", fileInfo.ModTime(), file)
	}
}

func parseRangeHeader(rangeHeader string, fileSize int64) (int64, int64, error) {
	prefix := "bytes="
	if len(rangeHeader) < len(prefix) || rangeHeader[:len(prefix)] != prefix {
		return 0, 0, fmt.Errorf("Invalid range header format")
	}
	rangeStr := rangeHeader[len(prefix):]

	dashIndex := strings.IndexByte(rangeStr, '-')
	if dashIndex == -1 {
		return 0, 0, fmt.Errorf("Invalid range header format")
	}

	startRange, err := strconv.ParseInt(rangeStr[:dashIndex], 10, 64)
	if err != nil {
		return 0, 0, err
	}

	endRangeStr := rangeStr[dashIndex+1:]
	var endRange int64
	if endRangeStr == "" {
		endRange = fileSize - 1
	} else {
		endRange, err = strconv.ParseInt(endRangeStr, 10, 64)
		if err != nil {
			return 0, 0, err
		}
	}

	return startRange, endRange, nil
}

在上面的修改后的示例代碼中,我們首先解析了HTTP請求的Range頭,然后根據請求的范圍讀取文件內容,并設置Content-Range頭告知客戶端傳輸的內容范圍。

通過這種方式,我們可以實現大文件傳輸和斷點續傳的功能。在實際應用中,可以根據需要對代碼進行進一步的優化和擴展。

0
教育| 凤凰县| 新和县| 牙克石市| 建平县| 承德市| 麻江县| 丹棱县| 上高县| 阳高县| 嵊泗县| 安康市| 黎城县| 怀集县| 万州区| 敦煌市| 任丘市| 常州市| 上栗县| 南靖县| 嘉兴市| 万载县| 泗阳县| 柘荣县| 双鸭山市| 微山县| 杭锦旗| 洛南县| 大荔县| 钟山县| 罗田县| 西城区| 绥宁县| 徐汇区| 石棉县| 湖南省| 车致| 德兴市| 永登县| 通海县| 尚义县|