golang接收断点续传文件

断点续传文件是一个常见的需求，在大文件的传输过程中，如果中途出现网络中断或其他原因导致传输失败，重新传输整个文件将会非常耗时。golang作为一门高性能的编程语言，提供了丰富的库和工具，使得实现断点续传文件变得相对容易。

计算文件的MD5值

在进行文件的断点续传前，我们首先需要计算文件的MD5值。MD5是一种常用的散列算法，它可以将任意长度的数据转换为固定长度的哈希值。通过比较源文件和目标文件的MD5值，我们可以验证文件是否完整和准确。

在golang中计算文件的MD5值非常简单，可以使用crypto/md5包提供的Sum函数。下面是一个示例代码：

import (
    "crypto/md5"
    "io/ioutil"
    "log"
)

func GetFileMD5(filename string) ([]byte, error) {
    data, err := ioutil.ReadFile(filename)
    if err != nil {
        return nil, err
    }

    hasher := md5.New()
    hasher.Write(data)

    return hasher.Sum(nil), nil
}

支持断点续传的HTTP服务

实现支持断点续传的HTTP服务可以使用golang内置的net/http包。通过设置HTTP头部的Range字段，我们可以告诉客户端只传输文件的一部分。在golang的HTTP请求处理函数中，我们可以解析Range字段，并读取对应部分的文件内容返回给客户端。

下面是一个实现支持断点续传的HTTP服务的示例代码：

import (
    "io"
    "log"
    "net/http"
    "os"
    "strconv"
    "strings"
)

func downloadHandler(w http.ResponseWriter, req *http.Request) {
    file, err := os.Open("largefile.jpg")
    if err != nil {
        log.Fatal(err)
    }
    defer file.Close()

    fileInfo, err := file.Stat()
    if err != nil {
        log.Fatal(err)
    }

    fileSize := fileInfo.Size()
    rangeHeader := req.Header.Get("Range")
    if rangeHeader != "" {
        ranges := strings.Split(rangeHeader, "=")[1]
        startEnd := strings.Split(ranges, "-")
        start, _ := strconv.ParseInt(startEnd[0], 10, 64)
        end, _ := strconv.ParseInt(startEnd[1], 10, 64)
        contentLength := end - start + 1

        w.Header().Set("Content-Range", ranges+"/"+strconv.FormatInt(fileSize, 10))
        w.Header().Set("Content-Length", strconv.FormatInt(contentLength, 10))
        w.WriteHeader(http.StatusPartialContent)

        file.Seek(start, 0)
        io.CopyN(w, file, contentLength)
    } else {
        w.Header().Set("Content-Range", "bytes 0-"+strconv.FormatInt(fileSize-1, 10)+"/"+strconv.FormatInt(fileSize, 10))
        w.Header().Set("Content-Length", strconv.FormatInt(fileSize, 10))
        w.WriteHeader(http.StatusOK)
        io.Copy(w, file)
    }
}

客户端实现断点续传

为了实现客户端的断点续传功能，我们需要在HTTP请求中设置Range字段。Range字段的格式为"bytes=start-end"，表示从start字节到end字节的范围。

下面是一个客户端实现断点续传的示例代码：

import (
    "io"
    "log"
    "net/http"
    "os"
)

func main() {
    file, err := os.Create("largefile.jpg")
    if err != nil {
        log.Fatal(err)
    }
    defer file.Close()

    client := &http.Client{}
    req, err := http.NewRequest("GET", "http://example.com/largefile.jpg", nil)
    req.Header.Set("Range", "bytes=0-")

    resp, err := client.Do(req)
    if err != nil {
        log.Fatal(err)
    }
    defer resp.Body.Close()

    io.Copy(file, resp.Body)
}

通过以上代码，我们可以在不耗费过多时间和资源的情况下，实现对大文件的断点续传。golang提供了丰富的库和工具使得这一过程变得非常简单和高效。