Go에서 http.Transport를 사용하여 대용량 파일의 중단점 재개 전송을 구현하는 방법은 무엇입니까?-Golang-php.cn

Go에서 http.Transport를 사용하여 대용량 파일의 중단점 재개 전송을 구현하는 방법은 무엇입니까?

王林

풀어 주다： 2023-07-22 19:40:50

원래의

1126명이 탐색했습니다.

Go에서 http.Transport를 사용하여 대용량 파일의 중단점 재개 전송을 구현하는 방법은 무엇입니까?

네트워크 전송 과정에서 대용량 파일을 전송하는 데 시간이 오래 걸리는 경우가 많습니다. 전송 효율성과 안정성을 높이기 위해 중단점 재개 기술이 일반적인 솔루션이 되었습니다. Go 언어에서는 http.Transport를 사용하여 대용량 파일의 중단점 재개 전송을 구현하여 네트워크 전송을 더욱 안정적이고 안정적으로 만들 수 있습니다. 이 기사에서는 http.Transport를 사용하여 중단점 재개를 구현하고 해당 코드 예제를 제공하는 방법을 소개합니다.

http.Transport 초기화

먼저, 네트워크 전송을 담당할 http.Transport 객체를 초기화해야 합니다. http.Transport 객체의 매개변수를 구성하여 전송의 일부 세부 사항을 제어할 수 있습니다.

transport := &http.Transport{
    MaxIdleConnsPerHost:   10,
    DisableCompression:    true,
    DisableKeepAlives:     true,
    ResponseHeaderTimeout: time.Second * 5,
}

로그인 후 복사

위 코드에서는 최대 유휴 연결 수를 10으로 설정하고 압축을 비활성화하고 연결을 유지하는 옵션을 설정했으며 응답 헤더 시간 제한을 5초로 설정했습니다. 이러한 매개변수는 실제 필요에 따라 조정될 수 있습니다.

HTTP 요청 시작

다음으로 http.Transport 개체를 사용하여 HTTP 요청을 시작할 수 있습니다. 요청을 시작하기 전에 http.Request 객체를 생성하고 요청된 URL, 요청 방법, 요청 헤더 및 기타 정보를 지정해야 합니다.

req, err := http.NewRequest("GET", "http://example.com/large_file.zip", nil)
if err != nil {
    log.Fatal(err)
}
// 添加断点续传的相关请求头信息
if fileInfo, err := os.Stat("local_file.zip"); err == nil {
    req.Header.Set("Range", "bytes="+strconv.FormatInt(fileInfo.Size(), 10)+"-")
}

로그인 후 복사

위 코드에서는 http.NewRequest 메서드를 사용하여 GET 요청을 생성하고 다운로드할 대용량 파일의 URL을 지정했습니다. 동시에 다운로드한 로컬 파일의 크기에 따라 "Range" 요청 헤더를 설정하여 중단점 재개를 구현합니다.

HTTP 요청 실행

요청이 생성된 후 http.Transport 개체의 RoundTrip 메서드를 통해 HTTP 요청을 실행하고 응답 결과를 얻을 수 있습니다.

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

if resp.StatusCode != http.StatusPartialContent {
    // 如果服务器未返回部分内容，无法进行断点续传
    log.Fatal("Server does not support partial content")
}

// 检查是否支持断点续传
contentRange := resp.Header.Get("Content-Range")
if contentRange == "" {
    // 如果服务器未返回Content-Range头部，无法进行断点续传
    log.Fatal("Server does not support content range")
}

// 获取已下载的文件大小
currentSize, err := getCurrentFileSize(contentRange)
if err != nil {
    log.Fatal(err)
}

로그인 후 복사

위 코드에서는 먼저 서버가 콘텐츠의 일부를 반환했는지 확인합니다(상태 코드는 206). 서버가 콘텐츠의 일부를 반환하지 않으면 업로드를 재개할 수 없습니다. 그런 다음 응답 헤더의 "Content-Range" 필드를 확인하여 서버가 재개 가능한 다운로드를 지원하는지 확인합니다. 서버가 "Content-Range" 필드를 반환하지 않으면 업로드가 재개되지 않습니다.

파일 다운로드

이전 단계가 성공적으로 통과되면, 즉 서버가 중단점 재개를 지원하면 파일 다운로드를 시작하고 파일을 로컬에 저장할 수 있습니다.

out, err := os.OpenFile("local_file.zip", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
if err != nil {
    log.Fatal(err)
}
defer out.Close()

_, err = io.Copy(out, resp.Body)
if err != nil {
    log.Fatal(err)
}

// 下载完成后，检查文件完整性
fileSize, err := getFileSize(contentRange)
if err != nil {
    log.Fatal(err)
}

if currentSize != fileSize {
    log.Fatal("Downloaded file size does not match")
}

fmt.Println("Download completed")

로그인 후 복사

위 코드에서는 먼저 다운로드한 콘텐츠를 저장하기 위해 로컬 파일을 엽니다. 그런 다음 io.Copy 함수를 통해 응답 내용이 로컬 파일에 기록됩니다. 마지막으로 파일 무결성을 보장하기 위해 다운로드한 파일 크기가 서버에서 반환한 파일 크기와 일치하는지 확인합니다.

이 시점에서 우리는 http.Transport를 사용하여 대용량 파일의 재개 가능한 전송을 구현하는 프로세스를 완료했습니다. 위의 단계를 통해 네트워크 전송 중 전송의 효율성과 안정성을 향상시키고 대용량 파일의 안전한 전송을 보장할 수 있습니다.

요약

이 글에서는 Go 언어로 http.Transport를 사용하여 대용량 파일의 중단점 재개 전송을 구현하는 방법을 소개합니다. http.Transport 개체의 매개 변수를 적절하게 구성하면 최대 유휴 연결 수, 압축 기능, 요청 시간 초과 등과 같은 전송 세부 정보를 제어할 수 있습니다. 동시에 다운로드한 파일의 크기에 따라 "Range" 요청 헤더를 설정하여 중단점 재개를 구현할 수 있습니다. 마지막으로 io.Copy 함수를 통해 응답 내용을 로컬 파일에 쓰고 파일의 무결성을 확인합니다. 이러한 단계는 대용량 파일 전송 시 전송 효율성과 안정성을 향상하고 더 나은 사용자 경험을 달성하는 데 도움이 될 수 있습니다.

참조 코드: https://gist.github.com/anonymous/043cdf4cf58e183d08c5ad7d01c8db82

위 내용은 Go에서 http.Transport를 사용하여 대용량 파일의 중단점 재개 전송을 구현하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!