服务器端Go程序对长短链接的处理及运行参数的保存

2020-01-28 11:58:15于海丽

    当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!!!")