代码语言
.
CSharp
.
JS
Java
Asp.Net
C
MSSQL
PHP
Css
PLSQL
Python
Shell
EBS
ASP
Perl
ObjC
VB.Net
VBS
MYSQL
GO
Delphi
AS
DB2
Domino
Rails
ActionScript
Scala
代码分类
文件
系统
字符串
数据库
网络相关
图形/GUI
多媒体
算法
游戏
Jquery
Extjs
Android
HTML5
菜单
网页交互
WinForm
控件
企业应用
安全与加密
脚本/批处理
开放平台
其它
【
GO
】
简单的心跳实现
作者:
dezai
/ 发布于
2014/6/17
/
434
针对tcp长连接做的应用层心跳检测。关键代码是用time.AfterFunc实现定时器,检测心跳返回失败后,立即关闭对应的连接。
package server import ( "sync" "time" ) //连接过期处理器接口类 type DierInterface interface { Die() } type PingTimer struct { mu sync.Mutex ptmr *time.Timer //ping定时器 pTime time.Time //记录最近ping时间戳 dier DierInterface //心跳死亡后的执行函数 } //注册连接过期的处理器 func (t *PingTimer) SetDier(pi DierInterface) { t.dier = pi t.pTime = time.Now() } //定时器唤醒处理函数 func (t *PingTimer) Process() { bDie := false t.mu.Lock() t.ptmr = nil //如果连接未激活时间超过最大时长,则认为该连接过期,销毁处理 if t.pTime.Nanosecond() != 0 && (time.Since(t.pTime) > (time.Duration)(opts.PingTimeOut)*time.Second) { bDie = true } t.mu.Unlock() if bDie {//销毁,并且关闭定时器 t.dier.Die() t.Clear() } else { //重置心跳检测定时器 t.Set() } } //设置定时器 func (t *PingTimer) Set() { t.mu.Lock() defer t.mu.Unlock() xylogs.Debug("Set PingTimer.") t.ptmr = time.AfterFunc(time.Duration(GOpts.PingInterval)*time.Second, func() { t.Process() }) } //刷新激活时间戳 func (t *PingTimer) RefleshTime() { t.mu.Lock() defer t.mu.Unlock() t.pTime = time.Now() } //销毁函数 func (t *PingTimer) Clear() { t.mu.Lock() defer t.mu.Unlock() if t.ptmr == nil { return } t.ptmr.Stop() t.ptmr = nil }
试试其它关键字
心跳实现
同语言下
.
将SQL查询结果转换成map数组
.
德州扑克的核心规则算法
.
格式化时间
.
超简单QR二维码生成器
.
检查命令位置,替代 mac 下 whereis
.
百度 API 翻译工具
.
鼠标事件处理
.
快速排序
.
鸡尾酒排序
.
冒泡排序
可能有用的
.
C#实现的html内容截取
.
List 切割成几份 工具类
.
SQL查询 多列合并成一行用逗号隔开
.
一行一行读取txt的内容
.
C#动态修改文件夹名称(FSO实现,不移动文件)
.
c# 移动文件或文件夹
.
c#图片添加水印
.
Java PDF转换成图片并输出给前台展示
.
网站后台修改图片尺寸代码
.
处理大图片在缩略图时的展示
dezai
贡献的其它代码
(
1065
)
.
双色球
.
列出所有物理网络适配器
.
快乐数的 Python 实现
.
计算当月还剩天数
.
猜属相
.
二十四小时时钟
.
每日一语
.
很酷的日历
.
超长日历表单
.
最简单的时钟
Copyright © 2004 - 2024 dezai.cn. All Rights Reserved
站长博客
粤ICP备13059550号-3