socks

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

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

type DefaultMsgHead struct {
	Cmd uint32
	// contains filtered or unexported fields
}

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

type HashIdType = int32 // =, 用别名，方便兼容

type IHeaderCreator interface {
	CreateMsgHeader() IMsgHeader
}

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

type IMsgHeader interface {
	GetHeaderSize() int
	ReadHeader(br *BufferUtils) (isOk bool, bodyLen int)
	WriteHeader(bw *BufferUtils, bodyLen int) bool
}

type IPackHeader interface {
	ReadPack(reader io.Reader, conn SocketConnection) (pack *PackData) // 不成功返回空
	WritePack(writer io.Writer, datas []byte) bool                     // 发送普通包的时候用到
}

type MsgBody struct {
	MsgHead interface{}
	Datas   []byte
}

type PByteArray (*[cMaxArrSize]byte)

type PStrArray (*[cMaxArrSize]string)

type PackData struct {
	Head interface{}
	Body []byte
}

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

type SockOptions struct {
	HeadHandler IPackHeader
	MsgHandler  IMsgHandler
}

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

type SocketConnection interface {
	SendData(avDatas []byte) bool //普通消息，需要组包，写入包头
	SendRawData(data []byte) bool // 发送原始消息，不需要组包，直接发送
	RemoteAddr() net.Addr
	GetId() int32
	Disconnect()
	GetData() interface{}
	SetData(usrData interface{})
}

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