diff --git a/app/http/tcppool/single.go b/app/http/tcppool/single.go index ae2c2f0..38e2f75 100644 --- a/app/http/tcppool/single.go +++ b/app/http/tcppool/single.go @@ -141,6 +141,9 @@ func (t *TcpHelper) watch(conn net.Conn) { } else if recvStr == "2" { fmt.Println("客户端空闲") atomic.StoreInt32(t.Full, 0) + } else if recvStr == "6" { + fmt.Println("客户端心跳") + atomic.StoreInt32(t.Full, 0) } } else { atomic.StoreInt32(t.Full, 1)