netConn

Documentation

Index

• type IConnManager
• type IConnection
• type IMsgHandle
• type IReceiver
• type IRequest
• type IService

Types

type IConnManager

type IConnManager interface {
	Add(conn IConnection)                                 //添加链接
	Remove(conn IConnection)                              //删除连接
	Get(connID uint64) (IConnection, bool)                //利用ConnID获取链接
	GetOvertimeConn(overtimeSecond float64) []IConnection //获取超时未上数据的连接
	ClearConn()                                           //删除并停止所有链接
}

连接管理接口

type IConnection

type IConnection interface {
	GetConnId() uint64                                                                                       //获取客户端ID
	GetRemoteAddr() net.Addr                                                                                 //获取远程客户端地址信息
	GetHeartTime() time.Time                                                                                 //心跳时间
	SendData(data []byte) error                                                                              //发送消息到客户端
	SendDataCall(data []byte, param interface{}, callFunc func(IConnection, bool, interface{}, error)) error //发送消息到客户端带回调
	SetProperty(key string, value interface{})                                                               //设置链接属性
	GetProperty(key string) (interface{}, error)                                                             //获取链接属性
	RemoveProperty(key string)                                                                               //移除链接属性
	GetPackCount() int64                                                                                     //当前包数
	GetBytesCache() *bytes.Buffer                                                                            //分包内容数据缓存
	OnCompleted(data []byte, offset int, count int)                                                          //数据上次一包(未分包开始处理不确定是否完成)
	OnReceiveCompleted(data []byte)                                                                          //数据上传完整的一包处理
	Start()                                                                                                  //启动连接，让当前连接开始工作
	Stop()                                                                                                   //停止连接，结束当前连接状态M
}

连接的接口

type IMsgHandle

type IMsgHandle interface {
	StartWorkerPool()                    //启动worker工作池
	StopWorkerPool()                     //停止worker工作池
	SendMsgToTaskQueue(request IRequest) //将消息交给TaskQueue,由worker进行处理
}

消息处理池接口

type IReceiver

type IReceiver interface {
	IsMeHandle(conn IConnection, buffer []byte) (isMe bool)       //是否处理
	Receiver(conn IConnection, buffer []byte) ([]byte, int, bool) //分包处理[处理一包后跳出]
}

分包器

type IRequest

type IRequest interface {
	GetConnection() (IConnection, bool) //获取请求连接信息
	GetConnId() uint64                  //获取连接id
	GetData() []byte                    //获取请求消息的数据
	GetCount() int                      //获取消息长度
}

客户端请求的内容接口

type IService

type IService interface {
	Start()                                                           //启动服务器方法
	Stop()                                                            //停止服务器方法
	GetConnMgr() IConnManager                                         //得到链接管理
	GetConn(connId uint64) (IConnection, bool)                        //获取连接
	SetErrorHandle(func(level string, msg string))                    //设置内部异常抛出处理
	SetCreateReceiver(hookFunc func(IConnection, []byte) []IReceiver) //设置分包处理方法(支持TCP,UDP都是上传完整数据包不需要分包)
	SetOnConnStart(hookFunc func(IConnection))                        //设置连接结束处理方法
	SetOnConnStop(hookFunc func(IConnection))                         //设置连接开始处理方法
	SetOnReceiveCompleted(hookFunc func(IConnection, []byte))         //连接上传一包完整数据
}

定义服务器接口