connect

type KcpSocket struct {
	MySocket
}

type MyProtocol struct {
	Length int32  // 消息的长度，用4个字节表示
	Data   []byte // 消息的内容，用字节切片表示，长度由Length决定
}

type MySocket struct {
	UuidOnCoon sync.Map // 连接
	//queue       chan []byte                              //结果
	Pool *common.Pool //线程池

	Tls   *Tls
	Debug bool // 是否开启调试模式，开启后会打印发送日志
	// contains filtered or unexported fields
}

type Socket interface {

	// ListenBack 监听连接收到的消息，回写到上层方法，当返回 byte 不为空时则写入到客户端,
	// uuid 为连接建立时的唯一id,message为具体消息内容
	ListenBack(func(uuid uint32, message []byte) []byte)
	ListenAddr(addr string)
	SendSelectMessage(bytes []byte, socketIds ...uint32)
	SendMessage(bytes []byte)
	OnClose(close func(socketId uint32))
}

type SocketClose interface {
	OnClose(socketId uint32)
}

type TcpSocket struct {
	MySocket
}

type Tls struct {
	CertFile string //证书文件
	KeyFile  string //密钥文件
}

type WebSocket struct {
	MySocket
	// ws连接路径
	Path string
}