在多客户端同时访问服务器的工作模式下，首先要保证服务器的运行正常。因此，Server和Client建立通讯后，确保连接的及时断开就非常重要。否则，多个客户端长时间占用着连接不关闭，是非常可怕的服务器资源浪费。会使得服务器可服务的客户端数量大幅度减少。
因此，针对短链接和长连接，根据业务的需求，配套不同的处理机制。
短连接
一般建立完连接，就立刻传输数据。传输完数据，连接就关闭。服务端根据需要，设定连接的时长。超过时间长度，就算客户端超时。立刻关闭连接。
长连接
建立连接后，传输数据，然后要保持连接，然后再次传输数据。直到连接关闭。
socket读写可以通过 SetDeadline、SetReadDeadline、SetWriteDeadline设置阻塞的时间。
func (*IPConn) SetDeadline
func (c *IPConn) SetDeadline(t ) error
func (*IPConn) SetReadDeadline
func (c *IPConn) SetReadDeadline(t ) error
func (*IPConn) SetWriteDeadline
func (c *IPConn) SetWriteDeadline(t ) error 如果做短连接，直接在Server端的连接上设置SetReadDeadline。当你设置的时限到达，无论客户端是否还在继续传递消息，服务端都不会再接收。并且已经关闭连接。
func main() {
server := ":7373"
netListen, err := ("tcp", server)
if err != nil{
Log("connect error: ", err)
(1)
}
Log("Waiting for Client ...")
for{
conn, err := ()
if err != nil{
Log(().String(), "Fatal error: ", err)
continue
}
//设置短连接(10秒)
(().Add((10)*))
Log(().String(), "connect success!")
...
}
}
这就可以了。在这段代码中，每当10秒中的时限一道，连接就终止了。
根据业务需要，客户端可能需要长时间保持连接。但是服务端不能无限制的保持。这就需要一个机制，如果超过某个时间长度，服务端没有获得客户端的数据，就判定客户端已经不需要连接了（比如客户端挂掉了）。
做到这个，需要一个心跳机制。在限定的时间内，客户端给服务端发送一个指定的消息，以便服务端知道客户端还活着。
func sender(conn *) {
for i := 0; i < 10; i++{
words := (i)+" Hello I'm MyHeartbeat Client."
msg, err := ([]byte(words))
if err != nil {
Log(().String(), "Fatal error: ", err)
(1)
}
Log("服务端接收了", msg)
(2 * )
}
for i := 0; i < 2 ; i++ {
(12 * )
}
for i := 0; i < 10; i++{
words := (i)+" Hi I'm MyHeartbeat Client."
msg, err := ([]byte(words))
if err != nil {
Log(().String(), "Fatal error: ", err)
(1)
}
Log("服务端接收了", msg)
(2 * )
}
}这段客户端代码，实现了两个相同的信息发送频率给服务端。两个频率中间，我们让运行休息了12秒。然后，我们在服务端的对应机制是这样的。
func HeartBeating(conn , bytes chan byte, timeout int) {
select {
case fk := <- bytes:
Log(().String(), "心跳:第", string(fk), "times")
(().Add((timeout) * ))
break
case <- (5 * ):
Log("conn dead now")
()
}
}每次接收到心跳数据就 SetDeadline 延长一个时间段 timeout。如果没有接到心跳数据，5秒后连接关闭。
服务端完整代码示例
/**
* MyHeartbeatServer
* @Author: Jian Junbo
* @Email: junbojian@
* @Create: 2017/9/16 14:02
* Copyright (c) 2017 Jian Junbo All rights reserved.
*
* Description:
*/
package main
import (
"net"
"fmt"
"os"
"time"
)
func main() {
server := ":7373"
netListen, err := ("tcp", server)
if err != nil{
Log("connect error: ", err)
(1)
}
Log("Waiting for Client ...")
for{
conn, err := ()
if err != nil{
Log(().String(), "Fatal error: ", err)
continue
}
//设置短连接(10秒)
(().Add((10)*))
Log(().String(), "connect success!")
go handleConnection(conn)
}
}
func handleConnection(conn ) {
buffer := make([]byte, 1024)
for {
n, err := (buffer)
if err != nil {
Log(().String(), " Fatal error: ", err)
return
}
Data := buffer[:n]
message := make(chan byte)
//心跳计时
go HeartBeating(conn, message, 4)
//检测每次是否有数据传入
go GravelChannel(Data, message)
Log(().Format("2006-01-02 15:04:05.0000000"), ().String(), string(buffer[:n]))
}
defer ()
}
func GravelChannel(bytes []byte, mess chan byte) {
for _, v := range bytes{
mess <- v
}
close(mess)
}
func HeartBeating(conn , bytes chan byte, timeout int) {
select {
case fk := <- bytes:
Log(().String(), "心跳:第", string(fk), "times")
(().Add((timeout) * ))
break
case <- (5 * ):
Log("conn dead now")
()
}
}
func Log(v ...interface{}) {
(v...)
return
}客户端完整代码示例
/**
* MyHeartbeatClient
* @Author: Jian Junbo
* @Email: junbojian@
* @Create: 2017/9/16 14:21
* Copyright (c) 2017 Jian Junbo All rights reserved.
*
* Description:
*/
package main
import (
"net"
"fmt"
"os"
"strconv"
"time"
)
func main() {
server := "127.0.0.1:7373"
tcpAddr, err := ("tcp4",server)
if err != nil{
Log(,"Fatal error:",())
(1)
}
conn, err := ("tcp",nil,tcpAddr)
if err != nil{
Log("Fatal error:",())
(1)
}
Log(().String(), "connection succcess!")
sender(conn)
Log("send over")
}
func sender(conn *) {
for i := 0; i < 10; i++{
words := (i)+" Hello I'm MyHeartbeat Client."
msg, err := ([]byte(words))
if err != nil {
Log(().String(), "Fatal error: ", err)
(1)
}
Log("服务端接收了", msg)
(2 * )
}
for i := 0; i < 2 ; i++ {
(12 * )
}
for i := 0; i < 10; i++{
words := (i)+" Hi I'm MyHeartbeat Client."
msg, err := ([]byte(words))
if err != nil {
Log(().String(), "Fatal error: ", err)
(1)
}
Log("服务端接收了", msg)
(2 * )
}
}
func Log(v ...interface{}) {
(v...)
return
}参考：
/docs/share/ef732d9e-f488-4e7e-8d64-43a1c18872ea