hj212

Documentation

Index

• Variables
• type MessageHandler
• type Option
• type Protocol
  • func (protocol *Protocol) NewCodec(rw io.ReadWriter) (link.Codec, error)
• type ProtocolCodec
  • func (codec *ProtocolCodec) Close() error
  • func (codec *ProtocolCodec) Receive() (interface{}, error)
  • func (codec *ProtocolCodec) Send(msg interface{}) error
• type Server
  • func NewServer(option Option) *Server
  • func (server *Server) AddHandler(st uint16, handler MessageHandler)
  • func (server *Server) GetSession(sessionID uint64) (*Session, bool)
  • func (server *Server) RemoveHandler(st, cn uint16)
  • func (server *Server) Run() error
  • func (server *Server) SessionCount() uint64
  • func (server *Server) Stop()
• type Session
  • func (session *Session) ID() uint64
  • func (session *Session) Send(entity protocol.Entity) error

Variables

var BuffPool *buffPool

Types

type MessageHandler

type MessageHandler func(session *Session, message *protocol.Message)

type Option

type Option struct {
	ListenAddress string
	SendChanSize  int
	Keepalive     int
	CloseHandler  func(session *Session)
	Protocol      link.Protocol
}

type Protocol

type Protocol struct {
}

func (*Protocol) NewCodec

func (protocol *Protocol) NewCodec(rw io.ReadWriter) (link.Codec, error)

NewCodec 创建编解器

type ProtocolCodec

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

func (*ProtocolCodec) Close

func (codec *ProtocolCodec) Close() error

Close 关闭编解器

func (*ProtocolCodec) Receive

func (codec *ProtocolCodec) Receive() (interface{}, error)

Receive 接收消息

func (*ProtocolCodec) Send

func (codec *ProtocolCodec) Send(msg interface{}) error

Send 发送消息

type Server

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

func NewServer

func NewServer(option Option) *Server

func (*Server) AddHandler

func (server *Server) AddHandler(st uint16, handler MessageHandler)

AddHandler 添加消息处理器

func (*Server) GetSession

func (server *Server) GetSession(sessionID uint64) (*Session, bool)

GetSession 获取session

func (*Server) RemoveHandler

func (server *Server) RemoveHandler(st, cn uint16)

RemoveHandler 移除消息处理器

func (*Server) Run

func (server *Server) Run() error

func (*Server) SessionCount

func (server *Server) SessionCount() uint64

func (*Server) Stop

func (server *Server) Stop()

Stop 停止服务

type Session

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

func (*Session) ID

func (session *Session) ID() uint64

ID 获取sessionID

func (*Session) Send

func (session *Session) Send(entity protocol.Entity) error

Send 发送消息