tcpmodule

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

type TcpCfg struct {
	ListenAddr          string        //监听地址
	MaxConnNum          int           //最大连接数
	PendingWriteNum     int           //写channel最大消息数量
	LittleEndian        bool          //是否小端序
	LenMsgLen           int           //消息头占用byte数量，只能是1byte,2byte,4byte。如果是4byte，意味着消息最大可以是math.MaxUint32(4GB)
	MinMsgLen           uint32        //最小消息长度
	MaxMsgLen           uint32        //最大消息长度,超过判定不合法,断开连接
	ReadDeadlineSecond  time.Duration //读超时
	WriteDeadlineSecond time.Duration //写超时
}

type TcpModule struct {
	service.Module
	// contains filtered or unexported fields
}

type TcpPack struct {
	Type                TcpPackType //0表示连接 1表示断开 2表示数据
	ClientId            string
	Data                interface{}
	RecyclerReaderBytes func(data []byte)
}

type TcpPackType int8