我通过创建一个自定义拨号函数返回一个包装连接来得到这个工作。我的包装拦截了连接上的第一次读取,并用HTTP/1.1替换了ICY。不是超级健壮的,但证明了这个概念:
package main
import (
"fmt"
"net"
"net/http"
)
type IcyConnWrapper struct {
net.Conn
haveReadAny bool
}
func (i *IcyConnWrapper) Read(b []byte) (int, error) {
if i.haveReadAny {
return i.Conn.Read(b)
}
i.haveReadAny = true
//bounds checking ommitted. There are a few ways this can go wrong.
//always check array sizes and returned n.
n, err := i.Conn.Read(b[:3])
if err != nil {
return n, err
}
if string(b[:3]) == "ICY" {
//write Correct http response into buffer
copy(b, []byte("HTTP/1.1"))
return 8, nil
}
return n, nil
}
func main() {
tr := &http.Transport{
Dial: func(network, a string) (net.Conn, error) {
realConn, err := net.Dial(network, a)
if err != nil {
return nil, err
}
return &IcyConnWrapper{Conn: realConn}, nil
},
}
client := &http.Client{Transport: tr}
http.DefaultClient = client
resp, err := http.Get("http://178.33.230.189:8100") //random url I found on the internet
fmt.Println(err)
fmt.Println(resp.StatusCode)
}
谁的想法是偏离规范在这样一个基本的方式?这似乎是一个糟糕的主意。你有没有考虑分出net/http包并使其不那么严格? – captncraig
这是错的。 Icecast不会这样回复。这是一个HTTP 1.0兼容的服务器。另一方面,Shoutcast正在被推迟,而不是HTTP服务器。 – TBR
@ captncraig 1997是一个更简单的时间...并不是说它找不到它。 – Brad