【发布时间】:2017-12-28 22:00:12
【问题描述】:
我在 go-lang 中做这个确切的 connection 时遇到了一些麻烦。
到目前为止,我已经完成了:
u := url.URL{Scheme: "wss", Host: "streamer.cryptocompare.com"}
var dialer *websocket.Dialer
conn, _, err := dialer.Dial(u.String(), nil)
l.Log(err)
msg, err := json.Marshal(Message{"SubAdd", map[string]interface{}{"subs": []string{"5~CCCAGG~BTC~USD"}}})
l.Log(err)
err = conn.WriteMessage(websocket.TextMessage, msg)
fmt.Println(err.Error())
l.Log(err)
我仍在学习 websocket 以及如何使用它们。
编辑:这是错误,我得到了:
panic: runtime error: invalid memory address or nil pointer dereference
[signal SIGSEGV: segmentation violation code=0x1 addr=0x10 pc=0x718937]
goroutine 22 [running]:
github.com/gorilla/websocket.(*Conn).WriteMessage(0x0, 0x1, 0xc420248020, 0x36, 0x40, 0x0, 0x0)
/home/avl/go/src/github.com/gorilla/websocket/conn.go:734 +0x37
main.SetupSockets(0xc420058370)
/home/avl/Dropbox/Development/mixed/server/crypto.go:55 +0x378
created by main.main
/home/avl/Dropbox/Development/mixed/server/main.go:21 +0x9a
exit status 2
编辑 2:crypto.go 中的第 55 行对应于这个msg, err := json.Marshal(Message{"SubAdd", map[string]interface{}{"subs": []string{"5~CCCAGG~BTC~USD"}}})
【问题讨论】:
-
dialer.Dial 的第二个返回值是来自服务器的响应。我建议打印响应状态和正文,看看可能出了什么问题。此外,该服务使用 socket.io。您将需要使用或实现任何 socket.io 在 websocket 协议之上添加的内容。
-
正在尝试,但没有成功。响应为零
-
Unexpected EOF -
该错误表明服务器正在关闭连接而没有写入 HTTP 响应。可能服务器正在关闭连接,因为请求无效。
-
想通了。不过谢谢!已经写好了!