管理创建连接管理模块将连接管理模块集成到

make(map[uint32]ziface.IConnection),}

}//

加写锁connMgr.connLock.Lock()defer

conn

ConnManagerconnMgr.connections[conn.GetConnID()]

add

加写锁connMgr.connLock.Lock()defer

删除连接信息delete(connMgr.connections,

conn.GetConnID())fmt.Println(connection

Remove

加读锁connMgr.connLock.RLock()defer

conn,

加写锁connMgr.connLock.Lock()defer

connID,

Remove()方法用于删除指定的连接而ClearConn()则会首先停止所有的连接再删除应当在服务器停止前调用。

将连接管理模块集成到

添加到连接管理器中c.TCPServer.GetConnMgr().Add(c)return

}Server

回顾我们引入连接管理模块的动机我们建立连接管理模块是为了控制连接的数量以避免服务器同时与过多的客户端建立连接。

因此当连接建立之前我们应该首先判断一下当前与

Server

的数量是否达到上限如果达到了上限那么就拒绝连接。

实现的方法非常简单在

Server

设置服务器最大连接控制,如果超过最大连接那么则关闭此新的连接if

s.ConnMgr.Len()

将连接从管理器中删除c.TCPServer.GetConnMgr().Remove(c)//

关闭该链接全部管道close(c.ExitBuffChan)close(c.msgBuffChan)

Server

将其它需要清理的连接信息或其他信息一并停止或清理s.ConnMgr.ClearConn()

Zinx

当中。

如果客户端的连接较多处理不及时可能会产生短暂的阻塞因此我们可以补充一个带有缓冲的消息发送方法来做一些非阻塞的用户体验。

首先修改

settings.Conf.MaxMsgChanLen),}//

Conn

添加到连接管理器中c.TCPServer.GetConnMgr().Add(c)return

}func

fmt.Println(c.RemoteAddr().String(),

[conn

有时在创建连接之后或是在连接断开之前我们希望执行一些用户自定义的业务所以我们为

Zinx

得到连接管理器SetOnConnStart(func(IConnection))

设置该

函数SetOnConnStop(func(IConnection))

设置该

c.StartReader()c.TCPServer.CallOnConnStart(c)for

{select

那么应该在此刻显式调用c.TCPServer.CallOnConnStop(c)//

socket

将连接从管理器中删除c.TCPServer.GetConnMgr().Remove(c)//

关闭该链接全部管道close(c.ExitBuffChan)close(c.msgBuffChan)