yunfantec
/
mq
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

增加重连

This commit is contained in:
qiyunfanbo126.com 2025-01-22 14:15:01 +08:00
parent 2c62f5d38a
commit 90a4ad85d0
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
app/http/tcppool/single.go
View File

@ -144,6 +144,7 @@ func (t *TcpHelper) watch(conn net.Conn) {
} else { } else {
atomic.StoreInt32(t.Full, 1) atomic.StoreInt32(t.Full, 1)
utils.Log(nil, "连接关闭", err) utils.Log(nil, "连接关闭", err)
t.reconnect(config.GetConf().OrderPort)
} }
} }
time.Sleep(1 * time.Second) time.Sleep(1 * time.Second)