314bc5df
zhengshouren
提交服务器初始代码
|
1
2
3
4
5
6
|
require "shared.init"
require "utils.init"
require "GlobalVar"
require "RedisKeys"
require "ProtocolCode"
require "skynet.manager"
|
314bc5df
zhengshouren
提交服务器初始代码
|
7
8
9
10
|
skynet = require "skynet"
redisproxy = require("shared.redisproxy")
|
314bc5df
zhengshouren
提交服务器初始代码
|
11
12
13
14
15
16
17
18
19
20
21
22
|
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)
|
1b20cfdb
zhouhaihai
赛季更新完善 无尽冒险排行榜
|
23
24
25
|
redisproxy:hsetnx("adv_season", "idx", 0)
redisproxy:hsetnx("adv_season", "chapter", globalCsv.adv_endless_default_chapter)
redisproxy:hsetnx("adv_season", "overTime", 0)
|
314bc5df
zhengshouren
提交服务器初始代码
|
26
27
28
29
30
31
32
33
34
35
36
|
end
end
local steps = {
[1] = {
handler = initRedisDb,
desc = "initialize redis database "
}
}
skynet.start(function ()
|
314bc5df
zhengshouren
提交服务器初始代码
|
37
38
|
redisproxy = require("shared.redisproxy")
|
be83d162
zhouahaihai
登陆成功。 增加数据结构修正功能
|
39
|
local new = redisproxy:hsetnx("autoincrement_set", "server_start", os.date("%Y%m%d", skynet.timex())) == 1
|
314bc5df
zhengshouren
提交服务器初始代码
|
40
41
42
43
44
|
if not new then
print("server has been initialized...")
skynet.exit()
return
end
|
a5486ede
zhouhaihai
csvdata 修改为 share...
|
45
46
|
csvdb = require "shared.csvdata"
globalCsv = csvdb["GlobalDefineCsv"]
|
314bc5df
zhengshouren
提交服务器初始代码
|
47
48
49
50
51
52
53
54
|
for _, action in ipairs(steps) do
print(action.desc .. "start ...")
action.handler()
print(action.desc .. "finished ...")
end
skynet.exit()
end)
|