The highest tagged major version is v2.

tcpserver

package

v0.0.0-...-79e39e7 Latest Latest Go to latest Published: Jul 1, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/jqiris/kungfu

Links

Open Source Insights

Documentation ¶

Index ¶

func NewServer(server *treaty.Server) tcpface.IServer
type ConnManager
- func NewConnManager() *ConnManager
type Server

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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) 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 停止服务

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL