64 lines
2.7 KiB
Lua
64 lines
2.7 KiB
Lua
|
local skynet = require "skynet"
|
|||
|
|
local oo = require "Class"
|
|||
|
|
local log = require "Log"
|
|||
|
|
local pb = require "pb"
|
|||
|
|
local errorInfo = require "ErrorInfo"
|
|||
|
|
local dataType = require "DataType"
|
|||
|
|
local redisKeyUrl = require "RedisKeyUrl"
|
|||
|
|
local MigrateData = oo.class()
|
|||
|
|
|
|||
|
|
function MigrateData:Init()
|
|||
|
|
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
--迁移账号数据
|
|||
|
|
function MigrateData:AccountData( account )
|
|||
|
|
if skynet.server.gameConfig:IsMultiRedis() then
|
|||
|
|
--开启了多redis
|
|||
|
|
local curAccountRedis = skynet.server.redisCenter:GetAccountRedis( account )
|
|||
|
|
local redisUserListKey = string.format(redisKeyUrl.AccountServerUserList , account )
|
|||
|
|
--并且指定redis没有玩家数据
|
|||
|
|
if not curAccountRedis:exists( redisUserListKey ) then
|
|||
|
|
local redisOldDb = skynet.server.redis:hgetall( redisUserListKey )
|
|||
|
|
redisOldDb = redisKeyUrl:CovertTable( redisOldDb )
|
|||
|
|
if redisOldDb and redisOldDb.DBIndex and redisOldDb.UserID then
|
|||
|
|
--原redis中有数据，需要迁移数据
|
|||
|
|
local packData = skynet.server.common:PackData( redisOldDb )
|
|||
|
|
curAccountRedis:hmset( redisUserListKey , table.unpack( packData ))
|
|||
|
|
|
|||
|
|
--先统计起来，后面一起删除
|
|||
|
|
local redisNeedDeleteKey = redisKeyUrl.AccountServerNeedDeleteAccountDataSet
|
|||
|
|
skynet.server.redis:sadd( redisNeedDeleteKey , account )
|
|||
|
|
--skynet.server.redis:del( redisKey ) 暂时不用
|
|||
|
|
log.info("成功迁移账号数据" , account , redisOldDb.DBIndex , redisOldDb.UserID , redisOldDb.PartnerId , redisOldDb.saveMySqlTime , redisOldDb.saveMongoTime )
|
|||
|
|
end
|
|||
|
|
end
|
|||
|
|
end
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
--迁移个人数据
|
|||
|
|
function MigrateData:DetailData( partnerId )
|
|||
|
|
--迁移redis相关
|
|||
|
|
if skynet.server.gameConfig:IsMultiRedis() then
|
|||
|
|
--开启了多redis
|
|||
|
|
local curPartnerRedis = skynet.server.redisCenter:GetPartnerRedis( partnerId ) --根据partnerId来获取redis索引
|
|||
|
|
local redisDetailKey = string.format( redisKeyUrl.GameServerPersonalDetail , partnerId )
|
|||
|
|
if not curPartnerRedis:exists( redisDetailKey ) then
|
|||
|
|
--获取旧redis数据
|
|||
|
|
local redisOldDetail = skynet.server.redis:hgetall( redisDetailKey )
|
|||
|
|
redisOldDetail = redisKeyUrl:CovertTable( redisOldDetail )
|
|||
|
|
|
|||
|
|
--对旧数据进行组装，然后迁移数据到新redis
|
|||
|
|
local packData = skynet.server.common:PackData( redisOldDetail )
|
|||
|
|
if #packData > 0 then
|
|||
|
|
curPartnerRedis:hmset( redisDetailKey , table.unpack( packData ) )
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
log.info("成功迁移个人数据" , partnerId )
|
|||
|
|
end
|
|||
|
|
end
|
|||
|
|
end
|
|||
|
|
|
|||
|
|
skynet.server.migrateData = MigrateData
|
|||
|
|
return MigrateData
|