Goroutine心跳检测

心跳检测的核心思想是，单独启动心跳协程，然后通过向协程发送数据，表示心跳。

package main
import ("fmt""math/rand""time"
)
func main() {rand.Seed(time.Now().UnixNano())doWork := func(done <-chan interface{},pulseInterval time.Duration,genData func() interface{},) (<-chan interface{}, <-chan interface{}) {heartBeat := make(chan interface{}) // 心跳results := make(chan interface{})go func() {defer close(heartBeat)defer close(results)sendPulse := func() {select {case heartBeat <- struct{}{}:default: // 心跳不一定有人接收}}pulse := time.Tick(pulseInterval)sendResult := func(r interface{}) {for {select {case <-done:returncase <-pulse: // 接收channel可能阻塞，因此持续心跳sendPulse()case results <- r:return // 耗时任务完成后，立刻返回}}}bridge := make(chan interface{})go func() {defer close(res)bridge <- genData()  // 我们假设会一直等到有数据发送过来}()for {select {case <-done:returncase <-pulse:sendPulse()case r, ok := <-res:if !ok { // 前边有关掉res了，所以这里需要ok判断return}sendResult(r)}}}()return heartBeat, results}genMyData := func() interface{} {t := rand.Intn(10) + 3time.Sleep(time.Second * time.Duration(t))fmt.Printf("genMyData weak up after:%v\n", t)return "foo"}done := make(chan interface{})defer close(done)interval := time.SecondheatBeat, result := doWork(done,interval, genMyData)for {select {case _, ok := <-heatBeat:if !ok {return}fmt.Println("hearbeat")case r, ok := <-result:if !ok {return}fmt.Printf("get result: %v\n", r)case <-time.After(interval * 2):  // 2倍心跳时间找不到心跳信号，则认为超时fmt.Printf("timeout")return}}
}

Goroutine心跳检测相关推荐

socket心跳机制图片_WebSocket心跳检测和重连机制
1. 心跳重连原由心跳和重连的目的用一句话概括就是客户端和服务端保证彼此还活着,避免丢包发生. websocket连接断开有以下两种情况: 前端断开在使用websocket过程中,可能会出现网络断 ...
socket心跳检测
一.什么是心跳检测判断对方(设备,进程或其它网元)是否正常动行,一般采用定时发送简单的通讯包,如果在指定时间段内未收到对方响应,则判断对方已经当掉.用于检测TCP的异常断开. 基本原因是服务器端不能 ...
心跳检测以及应用层心跳包机制设计
博主联系方式: QQ:1540984562 微信:wxid_nz49532kbh9u22 QQ交流群:892023501(嵌入式方向) QQ交流群:856398158(后端方向) 目录心跳检测应用场 ...
websocket心跳检测前后端架构
websocket心跳检测前后端架构本篇文章为初略架构websocket在前后端的心跳检测机制,实现相对毛糙. 下面介绍内容参照廖雪峰的描述,为了切换页面麻烦,这里就直接挑简要的信息复制黏贴过来 ...
Java笔记-JDBC心跳检测及断开重连线程实例
这里自己写了个JDBC心跳检测及断开重连线程: 运行截图如下: 心跳的时候运行ipconfig /release 然后再给他ipconfig /renew回去: 关键代码如下: Maven: < ...
netty的编解码、粘包拆包问题、心跳检测机制原理
文章目录 1. 编码解码器 2. 编解码序列化机制的性能优化 3. Netty粘包拆包 4. Netty心跳检测机制 5. Netty断线自动重连实现 1. 编码解码器当你通过netty发送或者接受 ...
Netty空闲心跳检测机制
概述 Netty提供了一个读写空闲心跳检测机制的Handler,用于检测读空闲.写空闲.读写空闲. 如果服务端在一定时间内没有执行读请求,就会触发读空闲事件,一定时间内没有执行写请求,就会触发写空闲事 ...
95-850-020-源码-心跳-JobMaster与TaskExecutor之间的心跳检测
文章目录 1.概述 2.JobMaster与TaskExecutor之间的心跳检测 2.1 初始化过程 2.1.1 JobMaster启动 2.1.2 TaskExecutor 2.3.注册过程 2. ...
haproxy心跳检测_haproxy 非常完整的配置
常用配置选项: OPTION 选项: option httpclose :HAProxy会针对客户端的第一条请求的返回添加cookie并返回给客户端,客户端发送后续请求时会发送此cookie到HAP ...

Goroutine心跳检测

Goroutine心跳检测

Goroutine心跳检测相关推荐

最新文章

热门文章