Golang 长连接的时候是怎样做心跳机制的

客户端发送心跳请求 重试机制。重试X次失败则定义为离线

服务端响应心跳请求 超时机制。超时X秒未收到心跳请求则定义为下线

//服务端​
//全局变量
var ids = make(map[string]chan byte)
​
func ResponseHeartBeat(id string) {
    if _, ok := ids[id]; ok {
        //保活心跳请求
        ids[id] <- 0
    } else {
        //上线触发器
        ids[id] = make(chan byte)
        go HeartBeat(ids, id, 10)
  }
}
​
/**
 *@brief: 心跳事件触发器
 *@param: ids 全局注册表
 *@param: id
 *@param: 超时时间
 */
func HeartBeat(ids map[string]chan byte, id string, n int64) {
  online := true
    for online {
    select {
        case  <- ids[id]:
          //保活触发器
        case <- time.After(time.Duration(n) * time.Second):
          //下线触发器
          online = false
          delete(ids, id)
          //下线触发通知系列功能操作，可采用观察者模式
    }
  }
}

到此这篇关于“Golang 长连接的时候是怎样做心跳机制的”的文章就介绍到这了,更多文章或继续浏览下面的相关文章，希望大家以后多多支持JQ教程网！

您可能感兴趣的文章：
Golang 长连接的时候是怎样做心跳机制的
mysql driver的bug的深入分析
数据库中的长连接和短连接区别分析
Linux下的heartbeat 双机热备
Golang 深入 slice 实现原理及使用技巧
腾讯微服务框架 Tars 的 Go 性能提升之路
golang版的traceroute实现
Golang基础第五篇——golang的gRPC
数据结构和算法(Golang实现)(10)基础知识-算法复杂度主方法
PHP 登录完成跳转上一访问页面