改进websocket示例代码

This commit is contained in:
John
2018-06-03 00:03:14 +08:00
parent d852ee8cb4
commit d7b31d09b0

View File

@ -8,13 +8,13 @@ import (
func main() {
s := g.Server()
s.BindHandler("/ws", func(r *ghttp.Request) {
conn, _ := r.WebSocket()
ws, _ := r.WebSocket()
for {
msgType, msg, err := conn.ReadMessage()
msgType, msg, err := ws.ReadMessage()
if err != nil {
return
}
if err = conn.WriteMessage(msgType, msg); err != nil {
if err = ws.WriteMessage(msgType, msg); err != nil {
return
}
}