netwebsocket

Documentation

Index

• type Client
• type ClientMngr
  • func (owner *ClientMngr) DisConnect(connID int32)
  • func (owner *ClientMngr) SendToAll(msg *Msg)
  • func (owner *ClientMngr) SendToConn(ConnID int32, msg *Msg)
  • func (owner *ClientMngr) SendWithOut(msg *Msg, ignore int32)
  • func (owner *ClientMngr) SetConnectCallback(callback NetWSCallback)
  • func (owner *ClientMngr) SetDisConnectCallback(callback NetWSCallback)
• type Config
  • func (owner *Config) String() string
• type Event
• type IHandler
• type Msg
• type NetWSCallback
• type Router
  • func (owner *Router) RegHandler(msgid uint32, handler interface{})
  • func (owner *Router) Route(connid int32, msgid uint32, buf []byte)
• type Service
  • func NewService(conf Config) *Service
  • func (owner *Service) Close()
  • func (owner *Service) GetClientMngr() *ClientMngr
  • func (owner *Service) GetRouter() *Router
  • func (owner *Service) RegHandler(msgid uint32, handler interface{})
  • func (owner *Service) Start()

Types

type Client

type Client struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Client TODO.

type ClientMngr

type ClientMngr struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ClientMngr TODO.

func (*ClientMngr) DisConnect

func (owner *ClientMngr) DisConnect(connID int32)

DisConnect TODO

func (*ClientMngr) SendToAll

func (owner *ClientMngr) SendToAll(msg *Msg)

SendToAll TODO

func (*ClientMngr) SendToConn

func (owner *ClientMngr) SendToConn(ConnID int32, msg *Msg)

SendToConn 通过连接ID发送

func (*ClientMngr) SendWithOut

func (owner *ClientMngr) SendWithOut(msg *Msg, ignore int32)

SendWithOut TODO

func (*ClientMngr) SetConnectCallback

func (owner *ClientMngr) SetConnectCallback(callback NetWSCallback)

SetConnectCallback TODO

func (*ClientMngr) SetDisConnectCallback

func (owner *ClientMngr) SetDisConnectCallback(callback NetWSCallback)

SetDisConnectCallback TODO

type Config

type Config struct {
	Flag int32
	Type string
	Host string
	Port int32
	Max  int32
}

Config struct.

func (*Config) String

func (owner *Config) String() string

type Event

type Event struct {
	Connid   int32
	Msgid    uint32
	MetaData []byte
}

Event struct.

type IHandler

type IHandler interface {
	Handle(ev *Event)
}

IHandler interface.

type Msg

type Msg struct {
	ID       uint32
	MetaData []byte
}

Msg struct.

type NetWSCallback

type NetWSCallback func(connID int32)

NetWSCallback TODO

type Router

type Router struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Router struct.

func (*Router) RegHandler

func (owner *Router) RegHandler(msgid uint32, handler interface{})

RegHandler 注册消息处理函数. 参数: 1-消息ID, 2-消息处理器结构体实例.

func (*Router) Route

func (owner *Router) Route(connid int32, msgid uint32, buf []byte)

Route 解析后的消息放入路由中的事件队列进行分发.

type Service

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

Service struct.

func NewService

func NewService(conf Config) *Service

NewService 创建新的服务.

func (*Service) Close

func (owner *Service) Close()

Close netwebsocket service.

func (*Service) GetClientMngr

func (owner *Service) GetClientMngr() *ClientMngr

GetClientMngr get TcpConnMngr Instance.

func (*Service) GetRouter

func (owner *Service) GetRouter() *Router

GetRouter get router Instance.

func (*Service) RegHandler

func (owner *Service) RegHandler(msgid uint32, handler interface{})

RegHandler register net message handler.

func (*Service) Start

func (owner *Service) Start()

Start netwebsocket service.