diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 11a74ee48..25d4a4cab 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -191,6 +191,8 @@ func (t *TcpClient) doPrint(key string) (err error) { if !t.isExistMsg(key) { return err } + defer close(t.MsgMap[key]) + defer close(t.CallBackMap[key]) globals.SugarLogger.Debugf("doPrint printNo: %s", key) go func() { for { @@ -201,7 +203,7 @@ func (t *TcpClient) doPrint(key string) (err error) { default: select { case printMsg, ok := <-t.MsgMap[key]: - if !ok{ + if !ok { return } var ( @@ -254,14 +256,13 @@ func (t *TcpClient) doPrint(key string) (err error) { } } }() - close(t.MsgMap[key]) - close(t.CallBackMap[key]) return err } //检测心跳 func (t *TcpClient) HandleCheckTcpHeart(key string) { globals.SugarLogger.Debugf("HandleCheckTcpHeart begin key: %s", key) + defer t.Clients[key].C.Close() go func() { for { select { @@ -297,5 +298,4 @@ func (t *TcpClient) HandleCheckTcpHeart(key string) { //} } }() - t.Clients[key].C.Close() }