Documentation ¶
Overview ¶
Package subnet micserver中的子网信息,管理了所有模块间的连接
Index ¶
- type ConnectMsgQueueStruct
- type Manager
- func (manager *Manager) BindChanSubnet(settings *conf.ModuleConfig) error
- func (manager *Manager) BindTCPSubnet(settings *conf.ModuleConfig) error
- func (manager *Manager) ChanServerListenerProcess(serverChan chan *process.ChanServerHandshake)
- func (manager *Manager) ConnectServer(id string, addr string) error
- func (manager *Manager) GetLatestVersionConnInfoByType(servertype string) uint64
- func (manager *Manager) HookSubnet(subnetHook base.SubnetHook)
- func (manager *Manager) Init(moudleConf *conf.ModuleConfig)
- func (manager *Manager) InitMsgQueue(sum int32)
- func (manager *Manager) MultiQueueControl(msgqueues *ConnectMsgQueueStruct)
- func (manager *Manager) MultiRecvmsgQueue(index int32) (normalreturn bool)
- func (manager *Manager) NotifyAllServerInfo(server *connect.Server)
- func (manager *Manager) OnCreateNewServer(conn *connect.Server)
- func (manager *Manager) OnRecvTCPMsg(conn *connect.Server, msgbinary *msg.MessageBinary)
- func (manager *Manager) OnServerLogin(conn *connect.Server, tarinfo *servercomm.SLoginCommand)
- func (manager *Manager) RecvmsgProcess(index int32)
- func (manager *Manager) TCPServerListenerProcess(listener net.Listener)
- func (manager *Manager) TryConnectServer(id string, addr string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectMsgQueueStruct ¶
type ConnectMsgQueueStruct struct {
// contains filtered or unexported fields
}
ConnectMsgQueueStruct 服务器消息处理封包
type Manager ¶
type Manager struct { *log.Logger // 服务器连接池 connect.ServerPool // contains filtered or unexported fields }
Manager 服务器子网连接管理器
func (*Manager) BindChanSubnet ¶
func (manager *Manager) BindChanSubnet(settings *conf.ModuleConfig) error
BindChanSubnet 绑定本地 chan 连接类型
func (*Manager) BindTCPSubnet ¶
func (manager *Manager) BindTCPSubnet(settings *conf.ModuleConfig) error
BindTCPSubnet 绑定本服务器对子网开放的端口
func (*Manager) ChanServerListenerProcess ¶
func (manager *Manager) ChanServerListenerProcess(serverChan chan *process.ChanServerHandshake)
ChanServerListenerProcess 监听本地 chan 连接的消息
func (*Manager) ConnectServer ¶
ConnectServer 连接服务器
func (*Manager) GetLatestVersionConnInfoByType ¶
GetLatestVersionConnInfoByType 指定类型的获取最新版本的服务器版本号
func (*Manager) HookSubnet ¶
func (manager *Manager) HookSubnet(subnetHook base.SubnetHook)
HookSubnet 设置子网事件监听者
func (*Manager) Init ¶
func (manager *Manager) Init(moudleConf *conf.ModuleConfig)
Init 根据模块配置初始化子网连接管理器
func (*Manager) InitMsgQueue ¶
InitMsgQueue 初始化消息处理队列
func (*Manager) MultiQueueControl ¶
func (manager *Manager) MultiQueueControl( msgqueues *ConnectMsgQueueStruct)
MultiQueueControl 分配消息处理线程
func (*Manager) MultiRecvmsgQueue ¶
MultiRecvmsgQueue 并行处理接收消息队列数据
func (*Manager) NotifyAllServerInfo ¶
NotifyAllServerInfo 发送当前已连接的所有服务器信息到目标连接
func (*Manager) OnCreateNewServer ¶
OnCreateNewServer 当新增一个服务器连接时调用
func (*Manager) OnRecvTCPMsg ¶
func (manager *Manager) OnRecvTCPMsg(conn *connect.Server, msgbinary *msg.MessageBinary)
OnRecvTCPMsg 当收到TCP消息时调用
func (*Manager) OnServerLogin ¶
func (manager *Manager) OnServerLogin(conn *connect.Server, tarinfo *servercomm.SLoginCommand)
OnServerLogin 目标服务器尝试登陆到本服务器
func (*Manager) RecvmsgProcess ¶
RecvmsgProcess 保持服务器消息处理线程
func (*Manager) TCPServerListenerProcess ¶
TCPServerListenerProcess 监听本服务器的子网端口线程
func (*Manager) TryConnectServer ¶
TryConnectServer 这种连接不会跟着super一起停机
Click to show internal directories.
Click to hide internal directories.