当Server每次收到Client发到的信息之后,便会开始心跳计时,如果在心跳计时结束之前没有再次收到Client发来的信息,那么便会断开跟Client的连接。而一旦在设定时间内再次收到Client发来的信息,那么Server便会重置计时器,再次重新进行心跳计时,直到超时断开连接为止。
下面就是实现该计时的代码:
//长连接入口
func handleConnection(conn net.Conn,timeout int) {
buffer := make([]byte, 2048)
for {
n, err := conn.Read(buffer)
if err != nil {
LogErr(conn.RemoteAddr().String(), " connection error: ", err)
return
}
Data :=(buffer[:n])
messnager := make(chan byte)
postda :=make(chan byte)
//心跳计时
go HeartBeating(conn,messnager,timeout)
//检测每次Client是否有数据传来
go GravelChannel(Data,messnager)
Log( "receive data length:",n)
Log(conn.RemoteAddr().String(), "receive data string:", string(Data
}
}
//心跳计时,根据GravelChannel判断Client是否在设定时间内发来信息
func HeartBeating(conn net.Conn, readerChannel chan byte,timeout int) {
select {
case fk := <-readerChannel:
Log(conn.RemoteAddr().String(), "receive data string:", string(fk))
conn.SetDeadline(time.Now().Add(time.Duration(timeout) * time.Second))
//conn.SetReadDeadline(time.Now().Add(time.Duration(5) * time.Second))
break
case <-time.After(time.Second*5):
Log("It's really weird to get Nothing!!!")









