gate

Documentation

Index

• Constants
• Variables
• func SendHandle(p *PlayerGame, kcpMsg *alg.PackMsg)
• type GateServer
  • func NewGate(cfg *config.Config, appid string) *GateServer
  • func (s *GateServer) AutoDelPlayer()
  • func (s *GateServer) Close() error
  • func (s *GateServer) GlobalRotationEvent5s()
  • func (s *GateServer) NewGame(kcpConn *kcp.UDPSession) *PlayerGame
  • func (s *GateServer) PlayerGetTokenCsReq(p *PlayerGame, playerMsg []byte)
  • func (s *GateServer) RunKcp() error
• type HandlerFunc
• type KcpEvent
• type NodeService
  • func (n *NodeService) GateToNodePingReq()
  • func (n *NodeService) GateToNodePingRsp(serviceMsg pb.Message)
  • func (n *NodeService) ServiceConnectionReq()
  • func (n *NodeService) ServiceConnectionRsp(serviceMsg pb.Message)
• type PlayerGame
  • func (p *PlayerGame) ApplyFriendCsReq(tcpMsg *alg.PackMsg)
  • func (p *PlayerGame) GateToGame(tcpMsg *alg.PackMsg)
  • func (p *PlayerGame) GateToPlayer(cmdId uint16, playerMsg pb.Message)
  • func (p *PlayerGame) HandleFriendCsReq(tcpMsg *alg.PackMsg)
  • func (p *PlayerGame) HandlePlayerHeartBeatCsReq(tcpMsg *alg.PackMsg)
  • func (p *PlayerGame) PlayerLogoutCsReq(tcpMsg *alg.PackMsg)
  • func (p *PlayerGame) PlayerRegisterMessage(cmdId uint16, tcpMsg *alg.PackMsg)
  • func (p *PlayerGame) SendMsgCsReq(tcpMsg *alg.PackMsg)
• type RouteManager
  • func NewRouteManager(p *PlayerGame) (r *RouteManager)
• type Store
  • func NewStore(config *config.Config) *Store
  • func (s *Store) DistLockSync(accountId string) bool
  • func (s *Store) DistUnlock(accountId string)
  • func (s *Store) DistUnlockPlayerStatus(accountId string)
  • func (s *Store) GetComboTokenByAccountId(accountId string) string
  • func (s *Store) GetPlayerStatus(accountId string) ([]byte, bool)
  • func (s *Store) GetPlayerUidByAccountId(AccountId uint32) *database.PlayerUid
  • func (s *Store) UpdatePlayerUid(AccountId uint32) *database.PlayerUid

Constants

const (
	MaxLockAliveTime  = 10000 // 单个锁的最大存活时间 毫秒
	LockRetryWaitTime = 50    // 同步加锁重试间隔时间 毫秒
	MaxLockRetryTimes = 2     // 同步加锁最大重试次数
)

const (
	PacketMaxLen            = 343 * 1024 // 最大应用层包长度
	KcpConnAddrChangeNotify = "KcpConnAddrChangeNotify"
)

Variables

var CLIENT_CONN_NUM int32 = 0 // 当前客户端连接数

var QPS int64

Functions

func SendHandle

func SendHandle(p *PlayerGame, kcpMsg *alg.PackMsg)

发送事件处理

Types

type GateServer

type GateServer struct {
	AppId     uint32
	WorkerId  int64
	Port      string
	InnerAddr string
	OuterAddr string
	Config    *config.Config
	Store     *Store

	Ec2b *random.Ec2b

	Ticker *time.Ticker
	Stop   chan struct{}
	// contains filtered or unexported fields
}

func NewGate

func NewGate(cfg *config.Config, appid string) *GateServer

func (*GateServer) AutoDelPlayer

func (s *GateServer) AutoDelPlayer()

玩家超时离线

func (*GateServer) Close

func (s *GateServer) Close() error

func (*GateServer) GlobalRotationEvent5s

func (s *GateServer) GlobalRotationEvent5s()

func (*GateServer) NewGame

func (s *GateServer) NewGame(kcpConn *kcp.UDPSession) *PlayerGame

func (*GateServer) PlayerGetTokenCsReq

func (s *GateServer) PlayerGetTokenCsReq(p *PlayerGame, playerMsg []byte)

func (*GateServer) RunKcp

func (s *GateServer) RunKcp() error

type HandlerFunc

type HandlerFunc func(tcpMsg *alg.PackMsg)

type KcpEvent

type KcpEvent struct {
	SessionId    uint32
	EventId      string
	EventMessage any
}

type NodeService

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

func (*NodeService) GateToNodePingReq

func (n *NodeService) GateToNodePingReq()

func (*NodeService) GateToNodePingRsp

func (n *NodeService) GateToNodePingRsp(serviceMsg pb.Message)

func (*NodeService) ServiceConnectionReq

func (n *NodeService) ServiceConnectionReq()

向node注册

func (*NodeService) ServiceConnectionRsp

func (n *NodeService) ServiceConnectionRsp(serviceMsg pb.Message)

type PlayerGame

type PlayerGame struct {
	Status         spb.PlayerStatus
	Uid            uint32 // uid
	AccountId      uint32
	Seed           uint64
	XorKey         []byte // 密钥
	KcpConn        *kcp.UDPSession
	LastActiveTime uint64 // 最近一次的活跃时间
	RouteManager   *RouteManager
	// contains filtered or unexported fields
}

func (*PlayerGame) ApplyFriendCsReq

func (p *PlayerGame) ApplyFriendCsReq(tcpMsg *alg.PackMsg)

func (*PlayerGame) GateToGame

func (p *PlayerGame) GateToGame(tcpMsg *alg.PackMsg)

将玩家消息转发到game

func (*PlayerGame) GateToPlayer

func (p *PlayerGame) GateToPlayer(cmdId uint16, playerMsg pb.Message)

将消息发送给客户端

func (*PlayerGame) HandleFriendCsReq

func (p *PlayerGame) HandleFriendCsReq(tcpMsg *alg.PackMsg)

func (*PlayerGame) HandlePlayerHeartBeatCsReq

func (p *PlayerGame) HandlePlayerHeartBeatCsReq(tcpMsg *alg.PackMsg)

玩家ping包处理

func (*PlayerGame) PlayerLogoutCsReq

func (p *PlayerGame) PlayerLogoutCsReq(tcpMsg *alg.PackMsg)

玩家主动离线处理

func (*PlayerGame) PlayerRegisterMessage

func (p *PlayerGame) PlayerRegisterMessage(cmdId uint16, tcpMsg *alg.PackMsg)

func (*PlayerGame) SendMsgCsReq

func (p *PlayerGame) SendMsgCsReq(tcpMsg *alg.PackMsg)

type RouteManager

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

func NewRouteManager

func NewRouteManager(p *PlayerGame) (r *RouteManager)

type Store

type Store struct {
	PlayerUidMysql *gorm.DB
	LoginRedis     *redis.Client
	StatusRedis    *redis.Client
	// contains filtered or unexported fields
}

func NewStore

func NewStore(config *config.Config) *Store

NewStore 创建一个新的 store。

func (*Store) DistLockSync

func (s *Store) DistLockSync(accountId string) bool

DistLockSync 加锁同步阻塞直到成功或超时

func (*Store) DistUnlock

func (s *Store) DistUnlock(accountId string)

DistUnlock 解锁

func (*Store) DistUnlockPlayerStatus

func (s *Store) DistUnlockPlayerStatus(accountId string)

删除玩家状态

func (*Store) GetComboTokenByAccountId

func (s *Store) GetComboTokenByAccountId(accountId string) string

根据accounid拉取combotoken

func (*Store) GetPlayerStatus

func (s *Store) GetPlayerStatus(accountId string) ([]byte, bool)

获取玩家状态

func (*Store) GetPlayerUidByAccountId

func (s *Store) GetPlayerUidByAccountId(AccountId uint32) *database.PlayerUid

使用account id拉取数据

func (*Store) UpdatePlayerUid

func (s *Store) UpdatePlayerUid(AccountId uint32) *database.PlayerUid

指定account id 创建数据