Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( MaxClient = 10 ErrReadTimeout = errors.New("tcp read timeout") )
Functions ¶
func NewHeaderLenEncoder ¶
func NewHeaderLenEncoder(headerLen, writeBufferLen int) *headerLenEncoder
NewHeaderLenEncoder 创建基于头部长度的编码器 headerLen TCP包的头部内容,用来描述这个包的字节长度 writeBufferLen 服务器发送给客户端包的建议长度,当发送的包小于这个值时,会利用到内存池优化
func SockaddrToAddr ¶
func SockaddrToAddr(sa syscall.Sockaddr) (syscall.SockaddrInet4, error)
Types ¶
type Decoder ¶
Decoder 解码器
func NewHeaderLenDecoder ¶
NewHeaderLenDecoder 创建基于头部长度的解码器 headerLen TCP包的头部内容,用来描述这个包的字节长度 readMaxLen 所读取的客户端包的最大长度,客户端发送的包不能超过这个长度
type Handler ¶
type Handler interface { OnConnect(c *Conn) // OnConnect 当TCP长连接建立成功是回调 OnMessage(c *Conn, bytes []byte) // OnMessage 当客户端有数据写入是回调 OnClose(c *Conn, err error) // OnClose 当客户端主动断开链接或者超时时回调,err返回关闭的原因 }
Handler Server 注册接口
type Option ¶
type Option interface {
// contains filtered or unexported methods
}
func WithIOEventQueueLen ¶
WithIOEventQueueLen 设置IO事件队列长度,默认值是1024
func WithTimeout ¶
WithTimeout 设置TCP超时检查的间隔时间以及超时时间
Click to show internal directories.
Click to hide internal directories.