Golang的坑之http读取大文件必须读完

先上代码

package main
import (
 "fmt"
 "net/http"
)
func main() {
 resp, err := http.Get("http://mirrors.ustc.edu.cn/opensuse/distribution/12.3/iso/openSUSE-12.3-GNOME-Live-i686.iso")
 if err != nil {
 panic(err)
 }
 fmt.Println("Resp code", resp.StatusCode)
 resp.Body.Close() // 注意,这里并不读取resp.Body, 而resp.Body有大概700mb未读取
}

你猜会怎样呢? 卡住了?!

如果你的网速够快,你会发现, 几十秒之后, 程序自动退出了,但如果你很不幸是小水管,你会发现一直卡住...

原因是啥呢?

http包默认会重用连接,重用连接就需要先把前一个连接的数据读完

代码片段(net/http/transfer.go)

func (b *body) Close() error {
 if b.closed {
 return nil
 }
 defer func() {
 b.closed = true
 }()
 if b.hdr == nil && b.closing {
 return nil
 }
 
 if b.res != nil && b.res.requestBodyLimitHit {
 return nil
 }
 // 操,问题就在这了,读完整个body!!
 if _, err := io.Copy(ioutil.Discard, b); err != nil {
 return err
 }
 return nil
}

怎么解决呢?

按上面代码片段的逻辑, 需要提前返回nil,从而避免被读取

 // b.hdr 总是为nil,因为从不设置
 // 那b.closing什么时候为true呢?
 if b.hdr == nil && b.closing {
 return nil
 }

读源码可知, b.closing依赖于transferReader的Close值

而transferReader的Close值, 是根据shouldClose方法判断的

// 这里的header是resp的
func shouldClose(major, minor int, header Header) bool {
 if major < 1 { return true } else if major == 1 && minor == 0 { if !strings.Contains(strings.ToLower(header.Get("Connection")), "keep-alive") { return true } return false } else { // TODO: Should split on commas, toss surrounding white space, // and check each field. if strings.ToLower(header.Get("Connection")) == "close" { header.Del("Connection") return true } } return false } 

由于没法在这些代码之前修改resp的header,所以修改req的header,使服务器总是返回Connection: close

最终代码

package main
import (
 "fmt"
 "net/http"
)
func main() {
 req, _ := http.NewRequest("GET", "http://mirrors.ustc.edu.cn/opensuse/distribution/12.3/iso/openSUSE-12.3-GNOME-Live-i686.iso", nil)
 req.Header.Set("Connection", "close")
 resp, err := http.DefaultClient.Do(req)
 if err != nil {
 panic(err)
 }
 fmt.Println("Resp code", resp.StatusCode)
 resp.Body.Close()
}

一个月没写blog了, 心情欠佳+身体抱恙 ~_~ 哎,多事的3月

2013年4月5号更新

coocood提醒到, go1.1有个新的API来完成这个蛋碎的东西

http.DefaultTransport.(*http.Transport).CancelRequest(req)

如果不是默认的DefaultTransport,就找你自己set的Transport吧

本文来自:Wendal 随笔

感谢作者:Wendal Chen

查看原文:Golang的坑之http读取大文件必须读完

• 编辑
• 预览