aa

business/jxstore/event/event_tcp.go

@@ -142,6 +142,9 @@ func ListenTcp() {
 		return
 	}
 	globals.SugarLogger.Debugf("begin listenTcp port 8000......")
+	go HandleTcpMessages()
+	go HandleCheckTcpHeart()
+	go doPrint2(printMsgChan)
 	//go doPrint(printMsgChanFail)
 	for {
 		c, err := l.Accept()
@@ -152,11 +155,6 @@ func ListenTcp() {
 		go handleConn(c)
 	}
 }
-func Run() {
-	go HandleTcpMessages()
-	go HandleCheckTcpHeart()
-	go doPrint2(printMsgChan)
-}
 
 func handleConn(c net.Conn) {
 	var (

main.go

@@ -129,7 +129,6 @@ func main() {
 			}
 		}()
 		if globals.IsPrintEnv() {
-			event.Run()
 			event.ListenTcp()
 		}
 		beego.Run()