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 17:11:30 +08:00
parent 26b0a27628
commit 0783881810
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -134,7 +134,7 @@ func (t *TcpHelper) watch(conn net.Conn) {
n, err := t.client.Read(buffer[:]) n, err := t.client.Read(buffer[:])
if err == nil && n > 0 { if err == nil && n > 0 {
recvStr := string(buffer[:n]) recvStr := string(buffer[:n])
fmt.Println("结果：recvStr:", recvStr) //fmt.Println("结果：recvStr:", recvStr)
if recvStr == "1" { if recvStr == "1" {
fmt.Println("客户端繁忙") fmt.Println("客户端繁忙")
atomic.StoreInt32(t.Full, 1) atomic.StoreInt32(t.Full, 1)