server

type Decoder interface {
	Decode(*TCPSession, io.Reader) ([]byte, error)
}

type Encoder interface {
	Encode(*TCPSession, []byte) ([]byte, error)
}

type Handler interface {
	Process(*TCPSession, []byte)
}

type LenFieldLen int

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

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

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

type TCPServer struct {
	SessionMgr     *SessionManager
	Encoder        func() Encoder
	Decoder        func() Decoder
	Handler        func() Handler
	OnSessionOpen  func(*TCPSession)
	OnSessionClose func(*TCPSession)
	// contains filtered or unexported fields
}

type TCPServerConfigurator struct {
	NoDelay            bool
	KeepAlive          bool
	KeepAlivePeriodSec int
	MaxConnectionNum   int
	ReadTimeOutSec     int
	SendBufferSize     int
}

type TCPSession struct {

	// 读超时时间
	ReadTimeOut time.Duration
	// 业务消息发送缓冲区大小
	SendBufferSize int
	// 自定义属性
	Attributes map[string]any
	// contains filtered or unexported fields
}