diff --git a/common/socket/ServerEvent.go b/common/socket/ServerEvent.go index b87a1893..0e916c71 100644 --- a/common/socket/ServerEvent.go +++ b/common/socket/ServerEvent.go @@ -100,7 +100,10 @@ func (s *Server) OnTraffic(c gnet.Conn) (action gnet.Action) { return action } if !ok { //升级失败,说明是tcp连接 - + if c.Context().(*player.ClientData).ERROR_CONNUT > 5 { + return gnet.Close + } + c.Context().(*player.ClientData).ERROR_CONNUT += 1 return s.handleTcp(c) } diff --git a/logic/service/player/wscodec.go b/logic/service/player/wscodec.go index fc5439a5..b30e43e5 100644 --- a/logic/service/player/wscodec.go +++ b/logic/service/player/wscodec.go @@ -63,6 +63,7 @@ func (w *WsCodec) Upgrade(c gnet.Conn) (ok bool, action gnet.Action) { buf.Next(skipN) logging.Errorf("conn[%v] [err=%v]", c.RemoteAddr().String(), err.Error()) action = gnet.Close + //ok = true w.Tcp = true return }