4dc77717
 zhouhaihai
压测
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
local MsgPack = MsgPack
local skynet = require "skynet"
local _M = class("login", require("unitTest.unitTest"))
function _M:start()
requestServer(actionCodes.Role_queryLoginRpc, MsgPack.pack({uid = self.client.uid}), handler(self, self.onQueryLogin))
end
function _M:onQueryLogin(data)
local msg = MsgPack.unpack(data)
if msg.ret == "RET_NOT_EXIST" then
requestServer(actionCodes.Role_createRpc, MsgPack.pack({ uid = self.client.uid }), function(data2)
local msg2 = MsgPack.unpack(data2)
self:sendLogin(msg2.roleName)
end)
elseif msg.ret == "RET_HAS_EXISTED" then
self:sendLogin(msg.name)
elseif msg.ret == "INNER_ERROR" then
-- 过几秒中尝试登录
-- local time = math.random(5)*100
-- skynet.timeout(time, function ()
-- rpcServer(actionCodes.Role_queryLoginRpc, MsgPack.pack({uid = self.client.uid}))
-- end)
print("INNER_ERROR")
end
end
function _M:sendLogin(name)
self.client.name = name
local totalWave = 0
local roleData = {}
local waveTag = {}
requestServer(actionCodes.Role_loginRpc, MsgPack.pack({name = self.client.name, codeVersion = 1}), function(data)
local msg = MsgPack.unpack(data)
if msg.wave then
totalWave = msg.wave
for key, value in pairs(msg) do
roleData[key] = value
end
waveTag[1] = true
end
if msg.runeWave then
if not roleData.runeBag then
roleData.runeBag = {}
end
for _, rune in pairs(msg.runeBag) do
table.insert(roleData.runeBag, rune)
end
waveTag[msg.runeWave] = true
end
if msg.heroWave then
if not roleData.heros then
roleData.heros = {}
end
for _, hero in pairs(msg.heros) do
table.insert(roleData.heros, hero)
end
waveTag[msg.heroWave] = true
end
if msg.chatWave then
waveTag[msg.chatWave] = true
end
-- 检查是否全部接收完
if totalWave > 0 then
local finish = true
for _wave = 1, totalWave do
if not waveTag[_wave] then
finish = false
break
end
end
if finish then
self.client.role = roleData
removeListener(actionCodes.Role_loginRpc)
pcall(skynet.call, skynet.self(), "lua", "task") -- 开始任务
end
end
end, true)
end
return _M
|