subnet

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)

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

func (manager *Manager) ConnectServer(id string, addr string) error

ConnectServer 连接服务器

func (*Manager) GetLatestVersionConnInfoByType

func (manager *Manager) GetLatestVersionConnInfoByType(servertype string) uint64

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

func (manager *Manager) InitMsgQueue(sum int32)

InitMsgQueue 初始化消息处理队列

func (*Manager) MultiQueueControl

func (manager *Manager) MultiQueueControl(
	msgqueues *ConnectMsgQueueStruct)

MultiQueueControl 分配消息处理线程

func (*Manager) MultiRecvmsgQueue

func (manager *Manager) MultiRecvmsgQueue(
	index int32) (normalreturn bool)

MultiRecvmsgQueue 并行处理接收消息队列数据

func (*Manager) NotifyAllServerInfo

func (manager *Manager) NotifyAllServerInfo(server *connect.Server)

NotifyAllServerInfo 发送当前已连接的所有服务器信息到目标连接

func (*Manager) OnCreateNewServer

func (manager *Manager) OnCreateNewServer(conn *connect.Server)

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

func (manager *Manager) RecvmsgProcess(index int32)

RecvmsgProcess 保持服务器消息处理线程

func (*Manager) TCPServerListenerProcess

func (manager *Manager) TCPServerListenerProcess(listener net.Listener)

TCPServerListenerProcess 监听本服务器的子网端口线程

func (*Manager) TryConnectServer

func (manager *Manager) TryConnectServer(id string, addr string)

TryConnectServer 这种连接不会跟着super一起停机