0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
1
2
3
|
package main
import (
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
4
5
|
"github.com/golang/protobuf/proto"
"math"
|
8d983031
zhangqijia
loginReq uid -> t...
|
6
|
"pro2d/cmd/gameserver/action"
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
7
8
|
"pro2d/common"
"pro2d/common/components"
|
765431a4
zhangqijia
增加schema接口, 抽象 mo...
|
9
|
"pro2d/common/logger"
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
10
|
"pro2d/models"
|
8d983031
zhangqijia
loginReq uid -> t...
|
11
|
"pro2d/pb"
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
12
|
"pro2d/utils"
|
58e37bfe
zhangqijia
add sync.Pool to ...
|
13
|
"sync"
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
14
15
16
17
18
19
20
21
|
"sync/atomic"
)
type Agent struct {
components.IConnection
Server components.IServer
Role *models.RoleModel
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
22
23
24
25
26
|
nextCheckTime int64 //下一次检查的时间
lastHeartCheckTime int64
heartTimeoutCount int //超时次数
}
|
58e37bfe
zhangqijia
add sync.Pool to ...
|
27
|
var agentPool = sync.Pool{New: func() interface{} { return new(Agent)}}
|
9a9d092e
zhangqijia
每条连接增加一个定时器,每条连接增...
|
28
|
|
58e37bfe
zhangqijia
add sync.Pool to ...
|
29
30
31
|
func NewAgent(s components.IServer) *Agent {
a := agentPool.Get().(*Agent)
a.Server = s
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
32
|
|
58e37bfe
zhangqijia
add sync.Pool to ...
|
33
34
35
36
|
a.nextCheckTime = 0
a.lastHeartCheckTime = utils.Timex()
a.heartTimeoutCount= 0
return a
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
37
38
|
}
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
39
40
|
func (c *Agent) OnConnection(conn components.IConnection) {
c.IConnection = conn
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
41
42
|
}
|
8d983031
zhangqijia
loginReq uid -> t...
|
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
func (c *Agent) OnLogin(msg components.IMessage) {
//第一次登录
errCode, irole := action.LoginRpc(msg)
if errCode != 0 {
c.Send(errCode, msg.GetHeader().GetMsgID(), nil)
return
}
role := irole.(*models.RoleModel)
protoMsg := &pb.RoleRsp{
Role: role.Role,
Hero: role.GetAllHero(),
Team: role.GetAllTeam(),
}
rsp, err := proto.Marshal(protoMsg)
if err != nil {
c.Send(-100, msg.GetHeader().GetMsgID(), nil)
return
}
c.Send(errCode, msg.GetHeader().GetMsgID(), rsp)
//登录成功,存储agent role
c.Role = role
}
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
67
|
func (c *Agent) OnMessage(msg components.IMessage) {
|
9a9d092e
zhangqijia
每条连接增加一个定时器,每条连接增...
|
68
|
atomic.StoreInt64(&c.lastHeartCheckTime, utils.Timex())
|
8d983031
zhangqijia
loginReq uid -> t...
|
69
70
71
72
73
74
|
if msg.GetHeader().GetMsgID() == uint32(pb.ProtoCode_LoginReq) {
c.OnLogin(msg)
return
}
|
765431a4
zhangqijia
增加schema接口, 抽象 mo...
|
75
|
md := c.Server.GetAction(msg.GetHeader().GetMsgID())
|
77f5eec7
zhangqijia
plugin 插件热更 接口
|
76
|
if md == nil {
|
58e37bfe
zhangqijia
add sync.Pool to ...
|
77
|
logger.Debug("cmd: %d, handler is nil", msg.GetHeader().GetMsgID())
|
77f5eec7
zhangqijia
plugin 插件热更 接口
|
78
79
|
return
}
|
58e37bfe
zhangqijia
add sync.Pool to ...
|
80
81
|
logger.Debug("protocolID: %d", msg.GetHeader().GetMsgID())
//fmt.Printf("errCode: %d, protoMsg:%v\n", errCode, protoMsg)
|
77f5eec7
zhangqijia
plugin 插件热更 接口
|
82
|
|
765431a4
zhangqijia
增加schema接口, 抽象 mo...
|
83
|
f := md.(func (msg components.IMessage) (int32, interface{}))
|
58e37bfe
zhangqijia
add sync.Pool to ...
|
84
|
errCode, protoMsg := f(msg)
|
8d983031
zhangqijia
loginReq uid -> t...
|
85
|
|
58e37bfe
zhangqijia
add sync.Pool to ...
|
86
|
if protoMsg == nil {
|
8d983031
zhangqijia
loginReq uid -> t...
|
87
|
c.Send(errCode, msg.GetHeader().GetMsgID(), nil)
|
58e37bfe
zhangqijia
add sync.Pool to ...
|
88
89
90
91
|
return
}
rsp, err := proto.Marshal(protoMsg.(proto.Message))
|
77f5eec7
zhangqijia
plugin 插件热更 接口
|
92
|
if err != nil {
|
8d983031
zhangqijia
loginReq uid -> t...
|
93
|
c.Send(-100, msg.GetHeader().GetMsgID(), nil)
|
58e37bfe
zhangqijia
add sync.Pool to ...
|
94
|
return
|
77f5eec7
zhangqijia
plugin 插件热更 接口
|
95
|
}
|
8d983031
zhangqijia
loginReq uid -> t...
|
96
|
c.Send(errCode, msg.GetHeader().GetMsgID(), rsp)
|
9a9d092e
zhangqijia
每条连接增加一个定时器,每条连接增...
|
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
}
func (c *Agent) OnTimer() {
nextCheckTime := atomic.LoadInt64(&c.nextCheckTime)
now := utils.Timex()
if now >= nextCheckTime {
//检查心跳
c.checkHeartBeat(now)
nextCheckTime = now + common.HeartTimerInterval
atomic.StoreInt64(&c.nextCheckTime, nextCheckTime)
}
if c.Role != nil {
//role 恢复数据
c.Role.OnRecoverTimer(now)
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
112
|
}
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
113
114
115
|
}
func (c *Agent) OnClose() {
|
9a9d092e
zhangqijia
每条连接增加一个定时器,每条连接增...
|
116
|
c.Close()
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
117
118
119
|
}
func (c *Agent) Close() {
|
8d983031
zhangqijia
loginReq uid -> t...
|
120
|
c.Role = nil
|
58e37bfe
zhangqijia
add sync.Pool to ...
|
121
122
|
agentPool.Put(c)
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
123
124
125
126
127
128
129
130
131
|
if c.Role == nil {
return
}
c.Role.OnOfflineEvent()
}
func (c *Agent) checkHeartBeat(now int64) {
lastHeartCheckTime := atomic.LoadInt64(&c.lastHeartCheckTime)
|
58e37bfe
zhangqijia
add sync.Pool to ...
|
132
|
//logger.Debug("checkHeartBeat ID: %d, last: %d, now: %d", c.GetID(), lastHeartCheckTime, now)
|
0e5d52de
zhangqijia
reactor: 重构底层框架1.0
|
133
134
135
136
137
138
139
140
141
142
143
|
if math.Abs(float64(lastHeartCheckTime - now)) > common.HeartTimerInterval {
c.heartTimeoutCount++
if c.heartTimeoutCount >= common.HeartTimeoutCountMax {
c.Stop()
return
}
logger.Debug("timeout count: %d", c.heartTimeoutCount)
}else {
c.heartTimeoutCount = 0
}
}
|