golang 短连接和长连接 超时处理
作为一个可能会和很多Client进行通讯交互的Server,首先要保证的就是整个Server运行状态的稳定性,因此在和Client建立连接通讯的时候,确保连接的及时断开非常重要,否则一旦和多个客户端建立不关闭的长连接,对于服务器资源的占用是很可怕的。因此,我们需要针对可能出现的短连接和长连接,设定不同的限制策略。
针对短连接,我们可以使用golang中的net包自带的timeout函数,一共有三个,分别是:
func (*IPConn) SetDeadline
func (c *IPConn) SetDeadline(t time.Time) errorfunc (*IPConn) SetReadDeadline
func (c *IPConn) SetReadDeadline(t time.Time) errorfunc (*IPConn) SetWriteDeadline
func (c *IPConn) SetWriteDeadline(t time.Time) error</span>
如果想要给服务器设置短连接的timeout,我们就可以这么写:
netListen, err := net.Listen("tcp", Port)Log("Waiting for clients")for {conn, err := netListen.Accept()if err != nil {continue}conn.SetReadDeadline(time.Now().Add(time.Duration(10) * time.Second))</span>
这里的三个函数都是用于设置每次socket连接能够维持的最长时间,一旦超过设置的timeout后,便会在Server端自动断开连接。其中SetReadline, SetWriteline设置的是读取和写入的最长持续时间,而SetDeadline则同时包含了 SetReadline, SetWriteline两个函数。
通过这样设定,每个和Server通讯的Client连接时长最长也不会超过10s了~~
搞定短连接后,接下来就是针对长连接的处理策略了~~
作为长连接,由于我们往往很难确定什么时候会中断连接,因此并不能像处理短连接那样简单粗暴的设定一个timeout就可以搞定,而在Golang的net包中,并没有针对长连接的函数,因此需要我们自己设计并实现针对长连接的处理策略啦~
针对socke长连接,常见的做法是在Server和Socket之间设计通讯机制,当两者之间没有信息交互时,双方便会定时发送数据包(心跳),以维持连接状态。
这种方法是目前使用相对比较多的做法,但是开销相对也较大,特别是当Server和多个client保持长连接的时候,并发会比较高,考虑到公司的业务需求,我最后选择了逻辑相对简单,开销相对较小的策略:
当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))breakcase <-time.After(time.Second*5):Log("It's really weird to get Nothing!!!")conn.Close()}}func GravelChannel(n []byte,mess chan byte){for _ , v := range n{mess <- v}close(mess)
}func Log(v ...interface{}) {log.Println(v...)
}
这样,就可以成功实现对于长连接的处理了~~,我们可以这么进行测试:
func sender(conn net.Conn) {for i := 0; i <5; i++ {words:= strconv.Itoa(i)+"This is a test for long conn" conn.Write([]byte(words))time.Sleep(2*time.Second)}fmt.Println("send over")}
可以发现,Sender函数中time.Sleep阻塞的时间设定的比Server中的timeout短的时候,Client端的信息可以自由的发送到循环结束,而当我们设定Sender函数的阻塞时间较长时,就只能发出第一次循环的信息。
golang 短连接和长连接 超时处理相关推荐
- java长连接心跳包_socket中的短连接与长连接,心跳包示例详解
TCP连接简介 当网络通信时采用TCP协议时,在真正的读写操作之前,server与client之间必须建立一个连接, 当读写操作完成后,双方不再需要这个连接时它们可以释放这个连接, 连接的建立是需要三 ...
- java socket 心跳包_socket中的短连接与长连接,心跳包示例详解
TCP连接简介 当网络通信时采用TCP协议时,在真正的读写操作之前,server与client之间必须建立一个连接, 当读写操作完成后,双方不再需要这个连接时它们可以释放这个连接, 连接的建立是需要三 ...
- httpclient 设置短连接_HTTP长连接和短连接(转)
HTTP的长连接和短连接本质上是TCP长连接和短连接.HTTP属于应用层协议,在传输层使用TCP协议,在网络层使用IP协议.IP协议主要解决网络路由和寻址问题,TCP协议主要解决如何在IP层之上可靠的 ...
- java socket 短连接_socket长连接和短连接的区别
长连接与短连接的区别(tcp socket http概念原理是一样的) 一.长连接与短连接:长连接:client方与server方先建立连接,连接建立后不断开,然后再进行报文发送和接收.这种方式下由于 ...
- Socket 短连接、长连接_YTmarkit的空间_百度空间
Socket 短连接.长连接_YTmarkit的空间_百度空间 Socket 短连接.长连接_YTmarkit的空间_百度空间 Socket 短连接.长连接 socket Socket协议的形象描述 ...
- java长连接转短连接_java原生程序redis连接(连接池/长连接和短连接)选择问题...
原标题:java原生程序redis连接(连接池/长连接和短连接)选择问题 最近遇到的连接问题我准备从重构的几个程序(redis和mysql)长连接和短连接,以及连接池和单连接等问题用几篇博客来总结下. ...
- http协议之长连接与短连接服务器,长连接短连接
HTTP 协议与 TCP/IP 协议的关系 HTTP 协议是应用层的协议,而 TCP 协议是传输层的协议,IP 协议是网络层的协议. IP 协议主要解决网络路由以及寻址等问题,而 TCP 协议主要解决 ...
- 前端面试题必考(四)- HTTP短连接,长连接(keep-alive),websocket,postmessage
一.HTTP与TCP的关系 HTTP属于应用层协议,主要解决如何包装数据: 在传输层使用TCP协议,主要解决数据如何在网络中传输: 在网络层使用IP协议,主要解决网络路由和寻址问题: HTTP把TCP ...
- 网络--基础知识点--tcp的短连接和长连接、http的短连接和长连接
1. tcp的长连接和短连接 1.1 tcp长连接 在TCP层握手成功后,不立即断开连接,并在此连接的基础上进行多次消息(包括心跳)交互,直至连接的任意一方(客户端OR服务端)主动断开连接,此过程称为 ...
最新文章
- 央视与遗传发育所合拍《走进科学-小菌株大作为》——枯草芽孢杆菌替代畜牧业抗生素添加
- boot.ini文件解密
- NULL,,String.Empty三者在C#中的区别
- BASIC-8 回文数
- 【Tools】Navicat Premium12安装教程
- linux系统备份和恢复
- C#模拟POST表单提交 --- WebClient
- 不得不说,其实你的性能优化手段已经过时了
- mvc做网站怎么在mvc中直接访问.html网页 [问题点数:20分]
- 命令行开启一个unity实例和执行其中的脚本方法的使用和注意
- 程序江湖:第五章 机会是一种困扰
- SPSS Modeler 数据导入操作
- 魔兽对战平台服务器更新维护什么,魔兽官方对战平台更新:公会系统正式上线!...
- Nature|人工智能助力蛋白质折叠预测
- python判断是否为整数的函数_实现函数 isInteger(x) 来判断 x 是否是整数
- 大端模式和小端模式是什么意思?
- ARP/RARP协议报文格式
- Cadence IC617工艺库安装步骤
- Linux命令之复制文件或目录cp
- 在Latex论文下方添加copyright