sockUtils

type DataPack struct {
	Head  interface{}
	Datas []byte
}

type DefaultHeadHandler struct {
}

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

type HeadInfo struct {
	Head    interface{}
	BodyLen uint32
	SockId  int32 // 当前的连接，可以读到 SockId，服务器会用到
}

type IMsgHandler interface {
	OnConnect(sock SocketConnection)
	OnDisconnect(sock SocketConnection)
	OnMessage(sock SocketConnection, msg *DataPack)
}

type IPackHeader interface {
	GetSize() uint32
	ReadHead(bits []byte, Head *HeadInfo) bool
	WriteHead(bits []byte, Head *HeadInfo) bool
}

type MsgBody struct {
	MsgHead interface{}
	Datas   []byte
	// contains filtered or unexported fields
}

type MsgHeader struct {
	HeadInfo
	// contains filtered or unexported fields
}

type SockOptions struct {
	HeadHandler    IPackHeader
	MsgHandler     IMsgHandler
	SockBufferSize uint32
}

type SocketClient interface {
	Open()  // 开始连接，打开会会自动连接
	Close() // 关闭连接
	GetConnection() SocketConnection
	Connected() bool // 判断是否连接
}

type SocketConnection interface {
	SendMsg(packHead interface{}, avBytes []byte) bool
	// SendData(data []byte)
	RemoteAddr() net.Addr
	GetId() int32
	Disconnect()
	GetData() interface{}
	SetData(usrData interface{})
}

type SocketServer interface {
	Open(avPort uint16) bool                                        // 开启服务
	Close()                                                         // 关闭
	Foreach(f enum_callback)                                        // 遍历连接
	SendMsg(SockId int32, msgHead interface{}, avBytes []byte) bool // 根据id 发送消息
	SendData(SockId int32, Data []byte) bool                        // 直接发送数据
	GetConnectCount() int32                                         // 获取连接总数
}