diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 25d4a4cab..289474f43 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -191,8 +191,6 @@ 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 { @@ -256,13 +254,14 @@ 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 { @@ -298,4 +297,5 @@ func (t *TcpClient) HandleCheckTcpHeart(key string) { //} } }() + t.Clients[key].C.Close() }