|
@@ -65,16 +65,6 @@ func WebsocketHandler(ctx *gin.Context, srv *Server) {
|
|
|
srv.Hub.Connect <- client
|
|
|
zlog.Info("client: ", client.UserId)
|
|
|
|
|
|
- conn.SetCloseHandler(func(code int, text string) error {
|
|
|
- message := websocket.FormatCloseMessage(code, "")
|
|
|
- if err := conn.WriteControl(websocket.CloseMessage, message, time.Now().Add(client.writeWait)); err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
- zlog.Infof("close client: %s, %s [%d]", client.UserId, text, code)
|
|
|
- srv.Hub.Disconnect <- client
|
|
|
- return nil
|
|
|
- })
|
|
|
-
|
|
|
go client.reader()
|
|
|
go client.writer()
|
|
|
}
|