diff --git a/server/event.go b/server/event.go index 22ede48..7343f73 100644 --- a/server/event.go +++ b/server/event.go @@ -64,6 +64,7 @@ func (slf *event) OnConnectionClosedEvent(conn *Conn) { for _, handle := range slf.connectionClosedEventHandles { handle(slf.Server, conn) } + conn.Close() } // RegConnectionOpenedEvent 在连接打开后将立刻执行被注册的事件处理函数 diff --git a/server/server.go b/server/server.go index 5cf90a3..11bdc65 100644 --- a/server/server.go +++ b/server/server.go @@ -165,7 +165,6 @@ func (slf *Server) Run(addr string) error { go func(conn *Conn) { defer func() { if err := recover(); err != nil { - conn.Close() slf.OnConnectionClosedEvent(conn) } }() @@ -242,7 +241,6 @@ func (slf *Server) Run(addr string) error { defer func() { if err := recover(); err != nil { - conn.Close() slf.OnConnectionClosedEvent(conn) } }()