network

type Channel interface {
	//启动连接，让当前连接开始工作
	Start()
	//停止连接，结束当前连接状态M
	Stop()
	//从当前连接获取原始的socket TCPConn
	GetTCPConnection() *net.TCPConn
	//获取当前连接ID
	GetConnID() uint32
	//获取远程客户端地址信息
	RemoteAddr() net.Addr
	//发送消息
	SendMsg(message TcpMessage) error
	//连接是否关闭
	IsClose() bool
	//关联的Server
	GetServer() Server
	//设置链接属性
	SetProperty(key string, value interface{})
	//获取链接属性
	GetProperty(key string) (interface{}, error)
	//移除链接属性
	RemoveProperty(key string)
	//无缓冲管道，用于读、写两个goroutine之间的消息通信
	GetMsgChan() chan []byte
	//有缓冲管道，用于读、写两个goroutine之间的消息通信
	GetMsgBuffChan() chan []byte
}

type ChannelManager interface {
	Add(conn Channel)                   //添加链接
	Remove(conn Channel)                //删除连接
	Get(connID uint32) (Channel, error) //利用ConnID获取链接
	Len() int                           //获取当前连接
	ClearConn()                         //删除并停止所有链接
}

type Client interface {
	//启动客户端方法
	Start()
	//停止客户端方法
	Stop()
	//开启业务服务方法
	Run()
	//得到链接
	GetChannel() Channel
	//设置该Client的连接创建时Hook函数
	SetChannelActive(func(Channel))
	//设置该Client的连接断开时的Hook函数
	SetChannelInactive(func(Channel))
	//调用连接OnConnStart Hook函数
	ChannelActive(conn Channel)
	//调用连接OnConnStop Hook函数
	ChannelInactive(conn Channel)
}

type ClientDataPack struct{}

type ClientMessage struct {
	DataLen uint32  //消息的长度
	Id      int32   //消息的ID
	Data    []byte  //消息的内容
	Time    int64   //消息时间
	Channel Channel //连接会话
}

type DataPack interface {
	//获取包头长度方法
	GetHeadLen() uint32
	//封包方法
	Pack(msg TcpMessage) ([]byte, error)
	//拆包方法
	Unpack([]byte, uint32) (TcpMessage, error)
}

type HandUnregisterMessageMethod func(message TcpMessage)

type HandlerMethod func(message TcpMessage) bool

type InnerDataPack struct{}

type InnerMessage struct {
	DataLen   uint32  //消息的长度
	Id        int32   //消息的ID
	Data      []byte  //消息的内容
	SessionId int64   //会话id
	SenderId  int64   //发送者id
	Channel   Channel //连接会话
}

type MessageDistribute interface {
	//处理消息
	RunHandler(message TcpMessage)
	//为消息添加具体的处理逻辑
	RegisterHandler(msgId int32, handler *TcpHandler)
	//启动worker工作池
	StartWorkerPool()
	//将消息交给TaskQueue,由worker进行处理
	SendMessageToTaskQueue(message TcpMessage)
}

type Server interface {
	//启动服务器方法
	Start()
	//停止服务器方法
	Stop()
	//开启业务服务方法
	Run()
	//路由功能：给当前服务注册一个路由业务方法，供客户端链接处理使用
	RegisterHandler(msgId int32, handler HandlerMethod)
	//得到链接管理
	GetChannelManager() ChannelManager
	//设置该Server的连接创建时Hook函数
	SetChannelActive(func(Channel))
	//设置该Server的连接断开时的Hook函数
	SetChannelInactive(func(Channel))
	//调用连接OnConnStart Hook函数
	ChannelActive(conn Channel)
	//调用连接OnConnStop Hook函数
	ChannelInactive(conn Channel)
	//服务器类型 0客户端，1内部服务器
	GetServerType() int32
}

type TcpHandler struct {
	// contains filtered or unexported fields
}

type TcpMessage interface {
	//获取消息数据段长度
	GetDataLen() uint32
	//获取消息ID
	GetMsgId() int32
	//获取消息内容
	GetData() []byte
	//获取消息时间戳
	GetTime() int64
	//会话id
	GetSessionId() int64
	//对象唯一id
	GetObjectId() int64
	//设置消息ID
	SetMsgId(int32)
	//设置消息内容
	SetData([]byte)
	//设置消息数据段长度
	SetDataLen(uint32)
	//设置时间戳
	SetTime(int64)
	//获取Channel
	GetChannel() Channel
	//设置Channel
	SetChannel(Channel)
}