1

business/jxstore/event/event_tcp.go

@@ -3,6 +3,7 @@ package event
 import (
 	"encoding/hex"
 	"encoding/json"
+	"errors"
 	"fmt"
 	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-callback/business/model"
@@ -30,14 +31,19 @@ func ListenTcp() {
 			fmt.Println("accept error:", err)
 			break
 		}
-		go t.handleConn(c)
+		go func() {
+			if err := t.handleConn(c); err != nil {
+				t = nil
+				return
+			}
+		}()
 	}
 }
 
-func (t *TcpClient) handleConn(c net.Conn) {
+func (t *TcpClient) handleConn(c net.Conn) error {
 	if c == nil {
 		globals.SugarLogger.Debugf("conn is nil")
-		return
+		return errors.New("conn is nil")
 	}
 	defer c.Close()
 	for {
@@ -52,7 +58,7 @@ func (t *TcpClient) handleConn(c net.Conn) {
 			} else {
 				fmt.Println("ReadString err", err)
 			}
-			return
+			return err
 		}
 
 		//看是心跳还是打印回调
@@ -63,11 +69,11 @@ func (t *TcpClient) handleConn(c net.Conn) {
 			}{}
 			if err := json.Unmarshal(buffer[0:n], &param); err != nil {
 				c.Write([]byte(err.Error()))
-				return
+				return err
 			}
 			t.buildMsgMap(param.PrintNoClear.String())
 			c.Write([]byte("ok"))
-			return
+			return err
 		}
 		//证明是心跳
 		if strings.Contains(data, heartText) || strings.Contains(data, heartTextNew) {

business/jxstore/event/event_tcp_utils.go

@@ -318,12 +318,12 @@ func (t *TcpClient) GetCallbackChan(key string) string {
 func (t *TcpClient) clear(key string) {
 	t.Lock()
 	defer t.Unlock()
-	//t.Clients[key].C.Close()
+	t.Clients[key].C.Close()
-	//delete(t.Clients, key)
+	delete(t.Clients, key)
-	//close(t.MsgMap[key])
+	close(t.MsgMap[key])
-	//delete(t.MsgMap, key)
+	delete(t.MsgMap, key)
-	//close(t.CallBackMap[key])
+	close(t.CallBackMap[key])
-	//delete(t.CallBackMap, key)
+	delete(t.CallBackMap, key)
 	delete(t.TimeoutMap, key)
 }