Documentation ¶
Index ¶
- func NewConnection(server ziface.IServer, conn *net.TCPConn, connID uint32, ...) ziface.IConnection
- func NewServer(name string) ziface.IServer
- type BaseRoute
- type ConnManger
- type Connection
- func (c *Connection) GetConnID() uint32
- func (c *Connection) GetTCPConnection() *net.TCPConn
- func (c *Connection) RemoteAddr() net.Addr
- func (c *Connection) SendMsg(msgId uint32, data []byte) error
- func (c *Connection) Start()
- func (c *Connection) StartReader()
- func (c *Connection) StartWriter()
- func (c *Connection) Stop()
- type DataPack
- type Message
- type MsgHandler
- func (s *MsgHandler) AddRoute(msgId uint32, route ziface.IRoute)
- func (s *MsgHandler) DoMsgHandler(request ziface.IRequest)
- func (s *MsgHandler) SendMsgToTaskQueue(request ziface.IRequest)
- func (s *MsgHandler) StartOneWorker(workerID int, taskQueue chan ziface.IRequest)
- func (s *MsgHandler) StartWorkerPool()
- type Request
- type Server
- func (s *Server) AddRoute(msgId uint32, route ziface.IRoute)
- func (s *Server) CallOnConnStart(conn ziface.IConnection)
- func (s *Server) CallOnConnStop(conn ziface.IConnection)
- func (s *Server) GetConnMgr() ziface.IConnManger
- func (s *Server) Server()
- func (s *Server) SetOnConnStart(hookFunc func(ziface.IConnection))
- func (s *Server) SetOnConnStop(hookFunc func(ziface.IConnection))
- func (s *Server) Start()
- func (s *Server) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConnection ¶
func NewConnection(server ziface.IServer, conn *net.TCPConn, connID uint32, msgHandler ziface.IMsgHandle) ziface.IConnection
Types ¶
type BaseRoute ¶
type BaseRoute struct{}
func (BaseRoute) PostHandler ¶
func (*BaseRoute) PreHandler ¶
type ConnManger ¶
type ConnManger struct {
// contains filtered or unexported fields
}
func NewConnManger ¶
func NewConnManger() *ConnManger
func (*ConnManger) Add ¶
func (c *ConnManger) Add(conn ziface.IConnection)
func (*ConnManger) ClearConn ¶
func (c *ConnManger) ClearConn()
func (*ConnManger) Get ¶
func (c *ConnManger) Get(connID uint32) (ziface.IConnection, error)
func (*ConnManger) Len ¶
func (c *ConnManger) Len() int
func (*ConnManger) Remove ¶
func (c *ConnManger) Remove(conn ziface.IConnection)
type Connection ¶
type Connection struct { Conn *net.TCPConn ConnID uint32 ExitBuffChan chan bool MsgHandler ziface.IMsgHandle TcpServer ziface.IServer // contains filtered or unexported fields }
func (*Connection) GetConnID ¶
func (c *Connection) GetConnID() uint32
func (*Connection) GetTCPConnection ¶
func (c *Connection) GetTCPConnection() *net.TCPConn
func (*Connection) RemoteAddr ¶
func (c *Connection) RemoteAddr() net.Addr
func (*Connection) Start ¶
func (c *Connection) Start()
func (*Connection) StartReader ¶
func (c *Connection) StartReader()
func (*Connection) StartWriter ¶
func (c *Connection) StartWriter()
func (*Connection) Stop ¶
func (c *Connection) Stop()
type DataPack ¶
type DataPack struct { }
func NewDataPack ¶
func NewDataPack() *DataPack
func (*DataPack) GetHeadLen ¶
type MsgHandler ¶
type MsgHandler struct { Apis map[uint32]ziface.IRoute WorkerPoolSize uint32 TaskQueue []chan ziface.IRequest }
func NewMsgHandle ¶
func NewMsgHandle() *MsgHandler
func (*MsgHandler) DoMsgHandler ¶
func (s *MsgHandler) DoMsgHandler(request ziface.IRequest)
func (*MsgHandler) SendMsgToTaskQueue ¶
func (s *MsgHandler) SendMsgToTaskQueue(request ziface.IRequest)
func (*MsgHandler) StartOneWorker ¶
func (s *MsgHandler) StartOneWorker(workerID int, taskQueue chan ziface.IRequest)
func (*MsgHandler) StartWorkerPool ¶
func (s *MsgHandler) StartWorkerPool()
type Request ¶
type Request struct {
// contains filtered or unexported fields
}
func (*Request) GetConnection ¶
func (r *Request) GetConnection() ziface.IConnection
type Server ¶
type Server struct { Name string IPVersion string IP string Port int ConnMgr ziface.IConnManger // 函数一等公民 OnConnStart func(ziface.IConnection) OnConnStop func(ziface.IConnection) // contains filtered or unexported fields }
func (*Server) CallOnConnStart ¶
func (s *Server) CallOnConnStart(conn ziface.IConnection)
func (*Server) CallOnConnStop ¶
func (s *Server) CallOnConnStop(conn ziface.IConnection)
func (*Server) GetConnMgr ¶
func (s *Server) GetConnMgr() ziface.IConnManger
func (*Server) SetOnConnStart ¶
func (s *Server) SetOnConnStart(hookFunc func(ziface.IConnection))
func (*Server) SetOnConnStop ¶
func (s *Server) SetOnConnStop(hookFunc func(ziface.IConnection))
Click to show internal directories.
Click to hide internal directories.