tcpserver

Documentation

Index

• func NewServer(server *treaty.Server) tcpface.IServer
• type ConnManager
  • func NewConnManager() *ConnManager
  • func (connMgr *ConnManager) Add(conn tcpface.IConnection)
  • func (connMgr *ConnManager) ClearConn()
  • func (connMgr *ConnManager) Get(connID int) (tcpface.IConnection, error)
  • func (connMgr *ConnManager) GetAll() map[int]tcpface.IConnection
  • func (connMgr *ConnManager) Len() int
  • func (connMgr *ConnManager) Remove(conn tcpface.IConnection)
• type Server
  • func (s *Server) CallOnConnStart(conn tcpface.IConnection)
  • func (s *Server) CallOnConnStop(conn tcpface.IConnection)
  • func (s *Server) GetConnMgr() tcpface.IConnManager
  • func (s *Server) GetMsgHandler() tcpface.IMsgHandle
  • func (s *Server) GetServerID() string
  • func (s *Server) ListenAndServe(msgHandler tcpface.IMsgHandle, connHandler tcpface.IConnHandler)
  • func (s *Server) ListenAndServeWs(msgHandler tcpface.IMsgHandle, connHandler tcpface.IConnHandler)
  • func (s *Server) Serve()
  • func (s *Server) SetOnConnStart(hookFunc func(tcpface.IConnection))
  • func (s *Server) SetOnConnStop(hookFunc func(tcpface.IConnection))
  • func (s *Server) Start()
  • func (s *Server) Stop()

Functions

func NewServer

func NewServer(server *treaty.Server) tcpface.IServer

NewServer 创建一个服务器句柄

Types

type ConnManager

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

func NewConnManager

func NewConnManager() *ConnManager

func (*ConnManager) Add

func (connMgr *ConnManager) Add(conn tcpface.IConnection)

Add 添加链接

func (*ConnManager) ClearConn

func (connMgr *ConnManager) ClearConn()

ClearConn 清除并停止所有连接

func (*ConnManager) Get

func (connMgr *ConnManager) Get(connID int) (tcpface.IConnection, error)

Get 利用ConnID获取链接

func (*ConnManager) GetAll

func (connMgr *ConnManager) GetAll() map[int]tcpface.IConnection

获取所有连接

func (*ConnManager) Len

func (connMgr *ConnManager) Len() int

Len 获取当前连接

func (*ConnManager) Remove

func (connMgr *ConnManager) Remove(conn tcpface.IConnection)

Remove 删除连接

type Server

type Server struct {
	//服务器的名称
	Name string
	//tcp4 or other
	IPVersion string
	//服务绑定的IP地址
	IP string
	//服务绑定的端口
	Port int
	//配置
	Config config.ConnectorConf
	//当前Server的链接管理器
	ConnMgr tcpface.IConnManager
	//消息处理器
	MsgHandler tcpface.IMsgHandle
	//连接处理器
	ConnHandler tcpface.IConnHandler
	//该Server的连接创建时Hook函数
	OnConnStart func(conn tcpface.IConnection)
	//该Server的连接断开时的Hook函数
	OnConnStop func(conn tcpface.IConnection)
	//服务配置信息
	Server *treaty.Server
}

Server 接口实现，定义一个Server服务类

func (*Server) CallOnConnStart

func (s *Server) CallOnConnStart(conn tcpface.IConnection)

CallOnConnStart 调用连接OnConnStart Hook函数

func (*Server) CallOnConnStop

func (s *Server) CallOnConnStop(conn tcpface.IConnection)

CallOnConnStop 调用连接OnConnStop Hook函数

func (*Server) GetConnMgr

func (s *Server) GetConnMgr() tcpface.IConnManager

GetConnMgr 得到链接管理

func (*Server) GetMsgHandler

func (s *Server) GetMsgHandler() tcpface.IMsgHandle

func (*Server) GetServerID

func (s *Server) GetServerID() string

func (*Server) ListenAndServe

func (s *Server) ListenAndServe(msgHandler tcpface.IMsgHandle, connHandler tcpface.IConnHandler)

func (*Server) ListenAndServeWs

func (s *Server) ListenAndServeWs(msgHandler tcpface.IMsgHandle, connHandler tcpface.IConnHandler)

func (*Server) Serve

func (s *Server) Serve()

Serve 运行服务

func (*Server) SetOnConnStart

func (s *Server) SetOnConnStart(hookFunc func(tcpface.IConnection))

SetOnConnStart 设置该Server的连接创建时Hook函数

func (*Server) SetOnConnStop

func (s *Server) SetOnConnStop(hookFunc func(tcpface.IConnection))

SetOnConnStop 设置该Server的连接断开时的Hook函数

func (*Server) Start

func (s *Server) Start()

Start 开启网络服务

func (*Server) Stop

func (s *Server) Stop()

Stop 停止服务