diff --git a/examples/zinx_client/main.go b/examples/zinx_client/main.go index abb7410..9d14cdf 100644 --- a/examples/zinx_client/main.go +++ b/examples/zinx_client/main.go @@ -56,7 +56,7 @@ func main() { return } - // fmt.Println("==> Test Router:[Ping] Recv Msg: ID=", msg.Id ", len=", msg.DataLen, ", data=", string(msg.Data)) + fmt.Println("==> Test Router:[Ping] Recv Msg: ID=", msg.ID, ", len=", msg.DataLen, ", data=", string(msg.Data)) } time.Sleep(1 * time.Second) diff --git a/znet/connection.go b/znet/connection.go index df307cb..ede5239 100644 --- a/znet/connection.go +++ b/znet/connection.go @@ -158,12 +158,13 @@ func (c *Connection) Start() { //Stop 停止连接,结束当前连接状态M func (c *Connection) Stop() { - c.Lock() - defer c.Unlock() //如果用户注册了该链接的关闭回调业务,那么在此刻应该显示调用 c.TCPServer.CallOnConnStop(c) + c.Lock() + defer c.Unlock() + //如果当前链接已经关闭 if c.isClosed == true { return