znet

Documentation

Index

• func NewServer(name string) ziface.IServer
• type BaseRouter
  • func (br *BaseRouter) AfterHandle(request ziface.IRequest)
  • func (br *BaseRouter) BeforeHandle(request ziface.IRequest)
  • func (br *BaseRouter) Handle(request ziface.IRequest)
• type Connection
  • func NewConnection(conn *net.TCPConn, connID uint32, router ziface.IRouter) *Connection
  • func (c *Connection) GetConnID() uint32
  • func (c *Connection) GetTCPConnection() *net.TCPConn
  • func (c *Connection) RemoteAddr() net.Addr
  • func (c *Connection) Send(data []byte) error
  • func (c *Connection) Start()
  • func (c *Connection) StartReader()
  • func (c *Connection) Stop()
• type Request
  • func (r *Request) GetConnection() ziface.IConnection
  • func (r *Request) GetData() []byte
• type Server
  • func (s *Server) AddRouter(router ziface.IRouter)
  • func (s *Server) Serve()
  • func (s *Server) Start()
  • func (s *Server) Stop()

Functions

func NewServer

func NewServer(name string) ziface.IServer

初始化server

Types

type BaseRouter

type BaseRouter struct {
}

func (*BaseRouter) AfterHandle

func (br *BaseRouter) AfterHandle(request ziface.IRequest)

处理后的方法

func (*BaseRouter) BeforeHandle

func (br *BaseRouter) BeforeHandle(request ziface.IRequest)

baserouter的方法都为空，router默认 为空。 处理前的方法

func (*BaseRouter) Handle

func (br *BaseRouter) Handle(request ziface.IRequest)

处理时的方法

type Connection

type Connection struct {
	//获取链接套接字
	Conn *net.TCPConn
	//链接的ID
	ConnID uint32

	//当前链接所绑定的处理方法API
	//handleAPI ziface.HandleFunc
	//告知当前链接已经退出的/停止 channel
	ExitChan chan bool
	// 该链接处理的方法Router
	Router ziface.IRouter
	// contains filtered or unexported fields
}

链接模块

func NewConnection

func NewConnection(conn *net.TCPConn, connID uint32, router ziface.IRouter) *Connection

初始化链接模块的方法

func (*Connection) GetConnID

func (c *Connection) GetConnID() uint32

获取当前链接模块的链接ID

func (*Connection) GetTCPConnection

func (c *Connection) GetTCPConnection() *net.TCPConn

获取当前链接的绑定socket conn

func (*Connection) RemoteAddr

func (c *Connection) RemoteAddr() net.Addr

获取远程客户端的TCP状态 IP port

func (*Connection) Send

func (c *Connection) Send(data []byte) error

发送数据，将数据发送给客户端

func (*Connection) Start

func (c *Connection) Start()

启动链接，让当前的链接准备开始工作

func (*Connection) StartReader

func (c *Connection) StartReader()

链接的读业务方法

func (*Connection) Stop

func (c *Connection) Stop()

停止链接，结束当前链接的工作

type Request

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

func (*Request) GetConnection

func (r *Request) GetConnection() ziface.IConnection

得到当前链接

func (*Request) GetData

func (r *Request) GetData() []byte

得到请求的消息数据

type Server

type Server struct {
	//服务器的名称
	Name string
	//服务器绑定的ip版本
	IPVersion string
	//服务器绑定的IP地址
	IP string
	//服务器绑定的端口号
	Port int
	//当前的server添加一个router。
	Router ziface.IRouter
}

iServer 的接口实现，定义一个server的服务器结构体

func (*Server) AddRouter

func (s *Server) AddRouter(router ziface.IRouter)

func (*Server) Serve

func (s *Server) Serve()

运行服务器

func (*Server) Start

func (s *Server) Start()

启动服务器

func (*Server) Stop

func (s *Server) Stop()

停止服务器