From 29634ad17f7844e6d25a8f4cab7c17e1515dc8ed Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Tue, 12 May 2026 16:38:52 +0800 Subject: [PATCH] : --- business/jxstore/event/event_tcp.go | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 0c7e745c0..3e3e40df5 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -67,17 +67,16 @@ func handleConn(c net.Conn) error { globals.SugarLogger.Debugf("remoteIP1: %s", remoteIP) globals.SugarLogger.Debugf("remotePort1: %d", remotePort) - printRemoteAddr := c.RemoteAddr().String() - printRemoteAddr = strings.Split(printRemoteAddr, ":")[0] - globals.SugarLogger.Debugf("printRemoteAddr2: %s", printRemoteAddr) - + // 重连 if err != nil { if err == io.EOF { fmt.Println("connection close") } else { fmt.Println("ReadString err:", err) } - + printRemoteAddr22 := c.RemoteAddr().String() + printRemoteAddr22 = strings.Split(printRemoteAddr22, ":")[0] + globals.SugarLogger.Debugf("printRemoteAddr22: %s", printRemoteAddr22) return err } @@ -106,7 +105,7 @@ func handleConn(c net.Conn) error { } if heartbeat { // 证明是心跳 - Heartbeat(c, t, data, printNo, printRemoteAddr) + Heartbeat(c, t, data, printNo, "") } else if callback { // 打印回调 Callback(c, t, data, printNo)