314bc5df
 zhengshouren
提交服务器初始代码
|
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
|
require "csvdata.init"
require "shared.init"
require "utils.init"
require "GlobalVar"
require "RedisKeys"
require "ProtocolCode"
require "skynet.manager"
local harbor = require "skynet.harbor"
skynet = require "skynet"
redisproxy = require("shared.redisproxy")
globalCsv = require "csvdata/GlobalDefine"
SendPacket = function ( ... ) end
local function initRedisDb( ... )
local servId = tonumber(skynet.getenv("servId"))
if servId then
redisproxy:hsetnx("autoincrement_set", "role", servId * MAX_ROLE_NUM)
redisproxy:hsetnx("autoincrement_set", "union", servId * MAX_ROLE_NUM)
redisproxy:hsetnx("autoincrement_set", "trade", servId * MAX_ROLE_NUM * 100)
redisproxy:hsetnx("autoincrement_set", "email", 0)
redisproxy:hsetnx("autoincrement_set", "emailTimestamp", 0)
redisproxy:hsetnx("autoincrement_set", "delay_email", 0)
end
end
local steps = {
[1] = {
handler = initRedisDb,
desc = "initialize redis database "
}
}
skynet.start(function ()
redisd = harbor.queryname("REDIS")
redisproxy = require("shared.redisproxy")
|
|
314bc5df
zhengshouren
提交服务器初始代码
|
42
43
44
45
46
47
48
49
50
51
52
53
54
|
if not new then
print("server has been initialized...")
skynet.exit()
return
end
for _, action in ipairs(steps) do
print(action.desc .. "start ...")
action.handler()
print(action.desc .. "finished ...")
end
skynet.exit()
end)
|
登陆成功。 增加数据结构修正功能