aa

business/jxstore/event/event_tcp.go

@@ -56,6 +56,7 @@ func ListenTcp() {
 		return
 	}
 	globals.SugarLogger.Debugf("begin listenTcp port 8000......")
+	go HandleTcpMessages()
 	for {
 		c, err := l.Accept()
 		if err != nil {

main.go

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