440 lines
13 KiB
Lua
440 lines
13 KiB
Lua
local skynet = require "skynet"
|
||
require "skynet.manager"
|
||
skynet.server = {}
|
||
require "Include"
|
||
local json =require "json"
|
||
local gameCmd = require "GameCmd"
|
||
local log = require "Log"
|
||
local errorInfo = require "ErrorInfo"
|
||
local cluster = require "skynet.cluster"
|
||
local socket = require "skynet.socket"
|
||
local pb = require "pb"
|
||
local mongo = require "skynet.db.mongo"
|
||
local redis = require "skynet.db.redis"
|
||
local redisKeyUrl = require "RedisKeyUrl"
|
||
local serverId = tonumber(skynet.getenv "serverId")
|
||
local clusterServer = require "ClusterServer"
|
||
local db = require "DB"
|
||
|
||
--AES 04169967a0dda41831aae37ae5f7c37a
|
||
--接收HTTP消息
|
||
function skynet.StartRecv()
|
||
skynet.register("StartServer")
|
||
skynet.dispatch("lua", function (_,_, cmd, ...)
|
||
if "TcpMsg" == cmd then --Tcp消息
|
||
local c2sData = ...
|
||
local isDo,s2cData = false,nil
|
||
s2cData = skynet.server.tcpServer:TcpRecv( c2sData )
|
||
local sendMsg,sendLen = skynet.pack(s2cData)
|
||
skynet.ret(sendMsg,sendLen)
|
||
|
||
elseif "HttpMsg" == cmd then --Http消息
|
||
local id ,url , c2sData , addr ,header= ...
|
||
--对接收到消息进行处理
|
||
local isDo,s2cData = false,nil
|
||
function Do(url ,c2sData , addr)
|
||
--获取IP地址
|
||
local pos = string.find(addr,":")
|
||
addr = string.sub(addr,1,pos - 1)
|
||
local bodyStr=c2sData
|
||
c2sData = json:decode(c2sData)
|
||
if c2sData ~=nil and bodyStr ~= nil then
|
||
c2sData.bodyStr=bodyStr
|
||
end
|
||
s2cData = skynet.server.httpServer:Recv(url, c2sData , addr , header)
|
||
return s2cData
|
||
end
|
||
|
||
--pcall调用一下，有异常直接返回
|
||
|
||
isDo,s2cData = pcall(Do,url ,c2sData , addr , header)
|
||
local sendMsg,sendLen = 0,0
|
||
if isDo then
|
||
sendMsg,sendLen = skynet.pack(s2cData)
|
||
else
|
||
log.info("StartServer HttpMsg内部错误信息",s2cData)
|
||
s2cData ={}
|
||
s2cData.code = errorInfo.ErrorCode.InnerError
|
||
s2cData = json:encode(s2cData)
|
||
sendMsg,sendLen = skynet.pack(s2cData)
|
||
end
|
||
--返回去
|
||
skynet.ret(sendMsg,sendLen)
|
||
elseif "ClusterMsg" == cmd then --集群消息
|
||
local sendMsg,sendLen = 0,0
|
||
sendMsg,sendLen = skynet.pack(clusterServer:ClusterRecv(...))
|
||
skynet.ret(sendMsg,sendLen)
|
||
--elseif "RedisMsg" == cmd then --Redis消息 (废弃，后面再清理)
|
||
-- skynet.server.gameServer:RedisMsgRecv(...)
|
||
end
|
||
end)
|
||
end
|
||
|
||
--初始化各种模块
|
||
function skynet.Init()
|
||
skynet.newservice("Logger")
|
||
local isOk = true
|
||
|
||
--载入游戏需要的配置文件
|
||
skynet.server.gameConfig:LoadConfig()
|
||
skynet.server.gameConfig:LoadJson()
|
||
skynet.server.gameConfig:LoadProto()
|
||
|
||
skynet.desKey = "12345678"
|
||
skynet.AddTime = 0
|
||
skynet.ServerName = clusterServer:GetServerTypeName( serverId )
|
||
|
||
--初始化Redis
|
||
skynet.InitRedis()
|
||
|
||
--游戏服可以连接多个数据库
|
||
skynet.InitDB( false )
|
||
|
||
--初始化MongoDB
|
||
skynet.InitMongoDB()
|
||
|
||
--先初始化clusterServer ，再初始其它模块
|
||
skynet.server.clusterServer:Init()
|
||
|
||
if skynet.server.clusterServer:IsGameServer( serverId ) then
|
||
--游戏服才会用到该模块
|
||
skynet.server.redisCache:Init()
|
||
end
|
||
|
||
for key, value in pairs(skynet.server) do
|
||
if not string.find(key, "redis") and not string.find(key, "mongo") and "clusterServer" ~= key and value.Init then
|
||
value:Init()
|
||
end
|
||
end
|
||
|
||
log.info("程序模块初始化完成")
|
||
|
||
--获取当前服务器IP信息
|
||
local cfgServer = skynet.server.common:GetClusterConfig( serverId )
|
||
if not cfgServer then
|
||
log.info("当前获取集群配置出错1 ",serverId)
|
||
return false
|
||
end
|
||
log.info("获取当前服务器配置完成")
|
||
|
||
--http底层加载
|
||
if "" ~= cfgServer.httpPort then
|
||
if skynet.server.clusterServer.multiServerID == serverId then
|
||
--多功能服需要传输大数据，单独修改一下最大传输数量为1M
|
||
skynet.server.httpSocket = skynet.newservice("HttpMultiSocket", "0.0.0.0" , cfgServer.httpPort)
|
||
else
|
||
skynet.server.httpSocket = skynet.newservice("HttpSocket", "0.0.0.0" , cfgServer.httpPort)
|
||
end
|
||
end
|
||
log.info("Http模块初始化完成")
|
||
|
||
--登陆服和游戏服不绑定TCP端口
|
||
if "" ~= cfgServer.tcpPort then
|
||
skynet.server.tcpSocket = skynet.newservice("TcpSocket", "0.0.0.0" , cfgServer.tcpPort)
|
||
end
|
||
log.info("Tcp模块初始化完成")
|
||
|
||
if "" ~= cfgServer.webSocketPort then
|
||
skynet.server.webSocket = skynet.newservice("WebSocket", "0.0.0.0" , cfgServer.webSocketPort)
|
||
end
|
||
log.info("WebSocket模块初始化完成")
|
||
|
||
--通过配置获取的节点进行组装
|
||
local clusterList = {}
|
||
local serverName = ""
|
||
for k, v in pairs(skynet.server.gameConfig.ClusterServerConfig) do
|
||
if serverId == v.serverId then
|
||
skynet.externalIp = v.externalIp
|
||
end
|
||
serverName = clusterServer:GetServerTypeClusterName( v.serverId )
|
||
clusterList[ serverName ] = string.format("%s:%s",v.internalIp ,v.clusterPort)
|
||
end
|
||
|
||
--载入集群
|
||
local clusterName = clusterServer:GetServerTypeClusterName( serverId )
|
||
cluster.reload(clusterList)
|
||
cluster.register(clusterName)
|
||
cluster.open(clusterName)
|
||
skynet.server.cluster = cluster
|
||
log.info("载入集群节点配置完成")
|
||
end
|
||
|
||
--主服务器
|
||
skynet.start(function()
|
||
skynet.StartRecv()
|
||
skynet.Init()
|
||
skynet.fork(skynet.ClusterTimer,500)
|
||
skynet.fork(skynet.GameTimer,500)
|
||
skynet.fork(skynet.GameTimer5Minute,100*60*5)--五分钟定时任务
|
||
skynet.fork(skynet.SaveMongoDBTimer,500) --500
|
||
skynet.fork(skynet.SaveMysqlDBTimer,500) --500
|
||
skynet.fork(skynet.SyncTimer,500) --500
|
||
--skynet.fork(skynet.Subscribe)(废弃，后面再清理)
|
||
log.info("服务器成功开启")
|
||
end)
|
||
|
||
--初始化Redis
|
||
function skynet.InitRedis()
|
||
--redis连接
|
||
local redisCfg =
|
||
{
|
||
host = skynet.server.gameConfig.RedisConfig.host ,
|
||
port = skynet.server.gameConfig.RedisConfig.port ,
|
||
db = skynet.server.gameConfig.RedisConfig.dbIndex,
|
||
auth = skynet.server.gameConfig.RedisConfig.password
|
||
}
|
||
|
||
skynet.server.redis = redis.connect(redisCfg)
|
||
if not skynet.server.redis then
|
||
log.info("连接Redis数据库失败")
|
||
return false
|
||
else
|
||
log.info(string.format("Redis 数据库连接成功 信息 IP地址 %s 端口 %s" ,redisCfg.host , redisCfg.port))
|
||
end
|
||
|
||
--RedisUser连接，目前数量为2，根据配置文件来确定
|
||
for i = 1, 2, 1 do
|
||
local tmpConfig = skynet.server.gameConfig[ "RedisUser"..i.."Config" ]
|
||
if tmpConfig then
|
||
local redisUserCfg = { host = tmpConfig.host , port = tmpConfig.port , db = tmpConfig.dbIndex , auth = tmpConfig.password }
|
||
skynet.server[ "redisUser"..i ] = redis.connect( redisUserCfg )
|
||
if not skynet.server[ "redisUser"..i ] then
|
||
log.info("连接RedisUser数据库失败",i)
|
||
return false
|
||
else
|
||
log.info(string.format("RedisUser%d 数据库连接成功 信息 IP地址 %s 端口 %s" , i , redisUserCfg.host , redisUserCfg.port))
|
||
end
|
||
end
|
||
end
|
||
end
|
||
|
||
--初始化DB
|
||
function skynet.InitDB( isReConnect )
|
||
local isOk = true
|
||
local dbConfig = skynet.server.gameConfig.DBInfoConfig
|
||
local cfgOneServer = skynet.server.gameConfig:GetCurClusterServerCfg( serverId )
|
||
|
||
--分析要连接的数据库名
|
||
if "" ~= cfgOneServer.dbName then
|
||
local dbNameList = skynet.server.common:Split( cfgOneServer.dbName , "|")
|
||
for k, dbName in pairs( dbNameList ) do
|
||
if isReConnect then
|
||
skynet.server.db:DisConnect( dbName )
|
||
skynet.sleep(10) --间隔10毫秒
|
||
end
|
||
|
||
isOk = skynet.server.db:Connect( dbConfig.host ,dbConfig.port ,dbConfig.user,dbConfig.password , dbName )
|
||
if not isOk then
|
||
return false
|
||
end
|
||
end
|
||
end
|
||
end
|
||
|
||
--初始化MongoDB
|
||
function skynet.InitMongoDB()
|
||
if skynet.server.gameConfig:IsMongoDB() then
|
||
local dbCfg =
|
||
{
|
||
host = skynet.server.gameConfig.MongDBConfig.host ,
|
||
port =skynet.server.gameConfig.MongDBConfig.port ,
|
||
username = skynet.server.gameConfig.MongDBConfig.username,
|
||
password = skynet.server.gameConfig.MongDBConfig.password,
|
||
--authdb = skynet.server.gameConfig.MongDBConfig.authdb
|
||
}
|
||
local authdb = skynet.server.gameConfig.MongDBConfig.authdb
|
||
skynet.server.mongo = mongo.client(dbCfg)[ authdb ]
|
||
--skynet.server.mongo.user1:safe_insert({_id = 1, name = "user2", password = "123456"}, true)
|
||
--skynet.server.mongo.user1:findOne({test_key = 1});
|
||
--skynet.server.mongo.user1:safe_update({ _id = 3} ,{name = "user3.2", password = "123456"} , true )
|
||
--local curData = skynet.server..mongo.user3:findOne()
|
||
log.info(string.format("MongoDB数据库连接成功 信息 IP地址 %s 端口 %s" , dbCfg.host , dbCfg.port))
|
||
end
|
||
end
|
||
|
||
--集群Timer
|
||
function skynet.ClusterTimer( timeStamp )
|
||
local isSuc ,err = nil,nil
|
||
local todayTime = skynet.GetTime()
|
||
while true do
|
||
|
||
--跨天
|
||
if not skynet.server.common:IsSameDay(skynet.GetTime() , todayTime ) then
|
||
log.info(string.format("集群Timer 服务器跨天 当前时间 %d 服务器记录时间 %d",skynet.GetTime() ,todayTime ))
|
||
--跨天TIMER
|
||
function Do()
|
||
skynet.server.clusterServer:OnNewDay()
|
||
end
|
||
|
||
isSuc,err = pcall(Do)
|
||
if not isSuc then
|
||
log.info("集群Timer 跨天有报错",err)
|
||
end
|
||
todayTime = skynet.GetTime()
|
||
end
|
||
|
||
--5秒TIMER
|
||
function Do()
|
||
skynet.server.clusterServer:On5SecTimer()
|
||
end
|
||
|
||
isSuc,err = pcall(Do)
|
||
if not isSuc then
|
||
log.info("集群Timer 5秒有报错",err)
|
||
end
|
||
skynet.sleep(timeStamp)
|
||
end
|
||
end
|
||
|
||
--游戏TImer主要是游戏逻辑
|
||
function skynet.GameTimer( timeStamp )
|
||
local isSuc ,err = nil,nil
|
||
local todayTime = skynet.GetTime()
|
||
|
||
while true do
|
||
--跨天
|
||
if not skynet.server.common:IsSameDay(skynet.GetTime() , todayTime ) then
|
||
local str = string.format("游戏TImer 服务器跨天 当前时间 %d 服务器记录时间 %d",skynet.GetTime() , todayTime )
|
||
log.info(str)
|
||
|
||
--跨天TIMER
|
||
--clusterServer:OnNewDay()
|
||
for key, value in pairs(skynet.server) do
|
||
if "table"== type(value) and value.OnNewDay and not string.find(key, "redis") and not string.find(key, "mongo") and
|
||
"clusterServer" ~= key and "accountCenter" ~= key and "timer" ~= key then
|
||
function Do(value)
|
||
value:OnNewDay()
|
||
end
|
||
|
||
isSuc,err = pcall(Do,value)
|
||
if not isSuc then
|
||
log.info("游戏TImer 跨天TIMER有报错",key,err)
|
||
end
|
||
end
|
||
end
|
||
todayTime = skynet.GetTime()
|
||
end
|
||
|
||
--5秒TIMER
|
||
for key, value in pairs(skynet.server) do
|
||
if "table" == type(value) and value.On5SecTimer and not string.find(key, "redis") and not string.find(key, "mongo") and
|
||
"clusterServer" ~= key and "accountCenter" ~= key and "timer" ~= key then
|
||
function Do(value)
|
||
local t1 = skynet.GetTime()
|
||
value:On5SecTimer()
|
||
local t2 = skynet.GetTime() - t1
|
||
if t2 > 1 then
|
||
skynet.server.clusterServer:SendErrorInfoToCenter( nil , errorInfo.ErrorCode.CalcTimeTooLong , string.format("%s 计算时间过长", key))
|
||
log.info("游戏Timer 运行时间",key, t2 )
|
||
end
|
||
end
|
||
|
||
isSuc,err = pcall(Do,value)
|
||
if not isSuc then
|
||
log.info("游戏TImer 5秒TIMER有报错",key,err)
|
||
end
|
||
end
|
||
end
|
||
|
||
skynet.sleep(timeStamp)
|
||
end
|
||
end
|
||
|
||
--游戏TImer主要是游戏逻辑-五分钟
|
||
function skynet.GameTimer5Minute( timeStamp )
|
||
local isSuc ,err = nil,nil
|
||
|
||
while true do
|
||
|
||
--五分钟秒TIMER
|
||
for key, value in pairs(skynet.server) do
|
||
if "table" == type(value) and value.On5MinTimer and not string.find(key, "redis") and not string.find(key, "mongo") and
|
||
"clusterServer" ~= key and "accountCenter" ~= key and "timer" ~= key then
|
||
function Do(value)
|
||
local t1 = skynet.GetTime()
|
||
value:On5MinTimer()
|
||
local t2 = skynet.GetTime() - t1
|
||
if t2 > 1 then
|
||
skynet.server.clusterServer:SendErrorInfoToCenter( nil , errorInfo.ErrorCode.CalcTimeTooLong , string.format("%s 计算时间过长", key))
|
||
log.info("游戏Timer 运行时间",key, t2 )
|
||
end
|
||
end
|
||
|
||
isSuc,err = pcall(Do,value)
|
||
if not isSuc then
|
||
log.info("游戏TImer 5分钟TIMER有报错",key,err)
|
||
end
|
||
end
|
||
end
|
||
|
||
skynet.sleep(timeStamp)
|
||
end
|
||
end
|
||
|
||
--保存Mongo数据库Timer
|
||
function skynet.SaveMongoDBTimer( timeStamp )
|
||
--只有游戏服并且配置了Mongo数据库才开启timer
|
||
if skynet.server.gameConfig:IsMongoDB() and serverId >= clusterServer.gameServerMinID and serverId <= clusterServer.gameServerMaxID then
|
||
log.info("开启Mongo数据库Timer")
|
||
while true do
|
||
skynet.server.accountCenter:CheckSaveMongoDB()
|
||
skynet.sleep(timeStamp)
|
||
end
|
||
end
|
||
end
|
||
|
||
--保存Mysql数据库Timer
|
||
function skynet.SaveMysqlDBTimer( timeStamp )
|
||
if serverId >= clusterServer.gameServerMinID and serverId <= clusterServer.gameServerMaxID then
|
||
log.info("开启Mysql数据库Timer")
|
||
while true do
|
||
skynet.server.accountCenter:CheckSaveMysqlDB()
|
||
skynet.sleep(timeStamp)
|
||
end
|
||
end
|
||
end
|
||
|
||
--同步redis数据TImer
|
||
function skynet.SyncTimer( timeStamp )
|
||
while true do
|
||
skynet.server.timer:Refresh()
|
||
skynet.sleep(timeStamp)
|
||
end
|
||
end
|
||
|
||
--订阅Redis信息(废弃，后面再清理)
|
||
function skynet.Subscribe()
|
||
if not skynet.server.clusterServer:IsGameServer(serverId) then
|
||
return
|
||
end
|
||
|
||
--游戏服才发布-订阅功能
|
||
local redisCfg =
|
||
{
|
||
host = skynet.server.gameConfig.RedisConfig.host ,
|
||
port = skynet.server.gameConfig.RedisConfig.port ,
|
||
db = skynet.server.gameConfig.RedisConfig.dbIndex,
|
||
auth = skynet.server.gameConfig.RedisConfig.password
|
||
}
|
||
|
||
local w = redis.watch(redisCfg)
|
||
w:subscribe("mail") --订阅邮件
|
||
while true do
|
||
function Do()
|
||
local msg,channel = w:message()
|
||
skynet.send("StartServer", "lua","RedisMsg", msg , channel )
|
||
skynet.sleep(10)
|
||
return true
|
||
end
|
||
|
||
local isSuc,err = pcall(Do)
|
||
if not isSuc then
|
||
log.info("订阅Redis信息Timer 有报错",err)
|
||
end
|
||
end
|
||
end
|
||
|
||
--获取时间
|
||
function skynet.GetTime()
|
||
return os.time() + skynet.AddTime
|
||
end |