先上代码

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吧