forked from endernon/PGRData
310 lines
11 KiB
Lua
310 lines
11 KiB
Lua
XNetwork = XNetwork or {}
|
||
|
||
if XMain.IsEditorDebug then
|
||
CS.XNetwork.IsShowNetLog = false
|
||
XNetwork.IsShowNetLog = true
|
||
else
|
||
XNetwork.IsShowNetLog = CS.XNetwork.IsShowNetLog
|
||
end
|
||
|
||
local Ip
|
||
local Port
|
||
local LastIp
|
||
local LastPort
|
||
local XRpc = XRpc
|
||
local IsDebug = XMain.IsEditorDebug
|
||
local ShieldedProtocol = {}
|
||
local NeedShieldProtocol = false
|
||
|
||
XNetwork.NetworkMode = {
|
||
Auto = 1,
|
||
Ipv4 = 2,
|
||
Ipv6 = 3,
|
||
}
|
||
XNetwork.NetworkModeKey = "NETWORK_MODE_KEY"
|
||
|
||
local function GetIpAndPort()
|
||
return Ip, Port
|
||
end
|
||
|
||
function XNetwork.SetGateAddress(ip, port)
|
||
Ip = ip
|
||
Port = port
|
||
end
|
||
|
||
function XNetwork.CheckIsChangedGate()
|
||
return LastIp ~= Ip or LastPort ~= Port
|
||
end
|
||
|
||
local LogTableFunc = IsDebug and XLog.Debug or XLog.Error
|
||
|
||
local function TipTableDiff(sha1Table)
|
||
if not CS.XTableManager.NeedSha1 then -- 开发环境下不解析Sha1
|
||
return
|
||
end
|
||
|
||
XTool.LoopMap(CS.XTableManager.Sha1Table, function(k, v)
|
||
local sha1 = sha1Table[k]
|
||
if not sha1 then
|
||
LogTableFunc("多余表格: " .. k)
|
||
return
|
||
end
|
||
|
||
if v ~= sha1 then
|
||
LogTableFunc("差异表格: " .. k .. ", 客户端sha1: " .. v .. " , 服务端sha1: " .. sha1)
|
||
end
|
||
|
||
sha1Table[k] = nil
|
||
end)
|
||
|
||
for k, _ in pairs(sha1Table) do
|
||
LogTableFunc("缺少表格: " .. k)
|
||
end
|
||
end
|
||
|
||
XRpc.NotifyCheckTableSha1 = function(data)
|
||
TipTableDiff(data.Sha1Table)
|
||
end
|
||
|
||
function XNetwork.ConnectGateServer(args)
|
||
if not args then
|
||
return
|
||
end
|
||
|
||
if IsDebug then
|
||
XRpc.CheckLuaNetLogEnable()
|
||
end
|
||
|
||
CS.XNetwork.OnConnect = function()
|
||
if args.IsReconnect then
|
||
local request = { PlayerId = XPlayer.Id, Token = XUserManager.ReconnectedToken, LastMsgSeqNo = CS.XNetwork.ServerMsgSeqNo }
|
||
if XNetwork.IsShowNetLog then
|
||
XLog.Debug("PlayerId=" .. request.PlayerId .. ", Token=" .. request.Token .. ", LastMsgSeqNo=" .. request.LastMsgSeqNo)
|
||
end
|
||
|
||
local request_func
|
||
request_func = function()
|
||
--放在外层，避免重连协议比其他协议慢返回
|
||
XEventManager.DispatchEvent(XEventId.EVENT_NETWORK_RECONNECT)
|
||
|
||
XNetwork.Call("ReconnectRequest", request, function(res)
|
||
-- XLog.Debug("服务器返回断线重连 测试，当作失败。" .. tostring(res.Code))
|
||
-- XLoginManager.OnReconnectFailed()
|
||
-- do return end
|
||
if res.Code ~= XCode.Success then
|
||
if XNetwork.IsShowNetLog then
|
||
XLog.Debug("服务器返回断线重连失败。" .. tostring(res.Code))
|
||
end
|
||
XLoginManager.OnReconnectFailed()
|
||
else
|
||
XNetwork.Send("ReconnectAck")
|
||
if XNetwork.IsShowNetLog then
|
||
XLog.Debug("服务器返回断线重连成功。")
|
||
end
|
||
XUserManager.ReconnectedToken = res.ReconnectToken
|
||
if args.ConnectCb then
|
||
args.ConnectCb()
|
||
end
|
||
|
||
if res.OfflineMessages then
|
||
CS.XNetwork.ProcessReconnectMessageList(res.OfflineMessages)
|
||
end
|
||
CS.XNetwork.ReCall(res.RequestNo)
|
||
end
|
||
end)
|
||
end
|
||
|
||
request_func()
|
||
else
|
||
XNetwork.Call("HandshakeRequest", {
|
||
ApplicationVersion = CS.XRemoteConfig.ApplicationVersion,
|
||
DocumentVersion = CS.XRemoteConfig.DocumentVersion,
|
||
Sha1 = CS.XTableManager.Sha1
|
||
}, function(response)
|
||
if args.RemoveHandshakeTimerCb then
|
||
args.RemoveHandshakeTimerCb()
|
||
end
|
||
|
||
if response.Code ~= XCode.Success then
|
||
local msgTab = {}
|
||
msgTab.error_code = response.Code
|
||
CS.XRecord.Record(msgTab, "24019", "HandshakeRequest")
|
||
if response.Code == XCode.GateServerNotOpen then
|
||
local localTimeStr = XTime.TimestampToLocalDateTimeString(response.UtcOpenTime, "yyyy-MM-dd HH:mm(G'M'T z)")
|
||
local context = CS.XTextManager.GetCodeText(response.Code) .. localTimeStr
|
||
XUiManager.SystemDialogTip("", context, XUiManager.DialogType.OnlySure)
|
||
elseif response.Code == XCode.LoginApplicationVersionError then
|
||
-- 处于调试模式时进错服显示取消按钮，否则不显示
|
||
local cancelCb = XMain.IsDebug and function() end or nil
|
||
CS.XTool.WaitCoroutine(CS.XApplication.CoDialog(CS.XApplication.GetText("Tip"),
|
||
CS.XStringEx.Format(CS.XApplication.GetText("UpdateApplication"),
|
||
CS.XInfo.Version), cancelCb, function() CS.XTool.WaitCoroutine(CS.XApplication.GoToUpdateURL(GetAppUpgradeUrl()), nil) end, "Cancel", "Confirm"))
|
||
elseif response.Code == XCode.LoginDocumentVersionError then
|
||
XUiManager.DialogTip("", CS.XTextManager.GetCodeText(response.Code), XUiManager.DialogType.OnlySure, nil, function()
|
||
CS.XApplication.Exit()
|
||
end)
|
||
else
|
||
XUiManager.DialogTip("", CS.XTextManager.GetCodeText(response.Code), XUiManager.DialogType.OnlySure)
|
||
end
|
||
|
||
if response.Code == XCode.LoginTableError then
|
||
XLog.Error("配置表客户端和服务端不一致")
|
||
TipTableDiff(response.Sha1Table)
|
||
end
|
||
|
||
CS.XNetwork.Disconnect()
|
||
return
|
||
end
|
||
|
||
CS.XRecord.Record("24020", "HandshakeRequestSuccess")
|
||
if args.ConnectCb then
|
||
args.ConnectCb()
|
||
end
|
||
end)
|
||
end
|
||
end
|
||
CS.XNetwork.OnDisconnect = function()
|
||
if args.DisconnectCb then
|
||
args.DisconnectCb()
|
||
end
|
||
end
|
||
CS.XNetwork.OnRemoteDisconnect = function()
|
||
if args.RemoteDisconnectCb then
|
||
args.RemoteDisconnectCb()
|
||
end
|
||
end
|
||
CS.XNetwork.OnError = function(error)
|
||
if args.ErrorCb then
|
||
args.ErrorCb(error)
|
||
end
|
||
end
|
||
CS.XNetwork.OnMessageError = function()
|
||
if args.MsgErrorCb then
|
||
args.MsgErrorCb()
|
||
end
|
||
end
|
||
CS.XNetwork.OnReconnectRequestFrequently = function()
|
||
if args.ReconnectRequestFrequentlyCb then
|
||
args.ReconnectRequestFrequentlyCb()
|
||
end
|
||
end
|
||
|
||
local ip, port
|
||
if args.IsReconnect then
|
||
ip, port = LastIp, LastPort
|
||
else
|
||
ip, port = GetIpAndPort()
|
||
end
|
||
|
||
XNetwork.ConnectServer(ip, port, args.IsReconnect)
|
||
end
|
||
|
||
function XNetwork.ConnectServer(ip, port, bReconnect)
|
||
if not ip or not port then
|
||
return
|
||
end
|
||
|
||
LastIp, LastPort = ip, port
|
||
local networkMode = XSaveTool.GetData(XNetwork.NetworkModeKey) or XNetwork.NetworkMode.Auto
|
||
if networkMode == XNetwork.NetworkMode.Auto then
|
||
CS.XNetwork.Connect(ip, tonumber(port), bReconnect, CS.XNetwork.NetworkMode.Auto)
|
||
elseif networkMode == XNetwork.NetworkMode.Ipv4 then
|
||
CS.XNetwork.Connect(ip, tonumber(port), bReconnect, CS.XNetwork.NetworkMode.Ipv4)
|
||
elseif networkMode == XNetwork.NetworkMode.Ipv6 then
|
||
CS.XNetwork.Connect(ip, tonumber(port), bReconnect, CS.XNetwork.NetworkMode.Ipv6)
|
||
else -- Auto保底
|
||
CS.XNetwork.Connect(ip, tonumber(port), bReconnect, CS.XNetwork.NetworkMode.Auto)
|
||
end
|
||
end
|
||
|
||
function XNetwork.Send(handler, request)
|
||
if IsDebug then
|
||
if handler == "" or (string.find(handler, " ")) then
|
||
XLog.Error("发送协议名错误！handler: " .. tostring(handler) .. ", request:", request)
|
||
return
|
||
end
|
||
end
|
||
-- 检查是否是屏蔽协议
|
||
if NeedShieldProtocol and ShieldedProtocol[handler] then
|
||
XUiManager.TipMsg(CS.XGame.ClientConfig:GetString("ShieldedProtocol"))
|
||
return
|
||
end
|
||
local requestContent, error = XMessagePack.Encode(request)
|
||
if IsDebug then
|
||
XRpc.DebugPrint(XRpc.DEBUG_TYPE.Send, handler, requestContent)
|
||
end
|
||
|
||
if requestContent == nil then
|
||
XLog.Error("XNetwork.Send 函数错误, 客户端发送给服务端的数据编码处理失败, 失败原因：" .. error)
|
||
return
|
||
end
|
||
|
||
CS.XNetwork.Send(handler, requestContent);
|
||
end
|
||
|
||
function XNetwork.Call(handler, request, reply, isEncoded, exReply, shieldReply)
|
||
if IsDebug then
|
||
if handler == "" or (string.find(handler, " ")) then
|
||
XLog.Error("发送协议名错误！handler: " .. tostring(handler) .. ", request:", request)
|
||
return
|
||
end
|
||
end
|
||
-- 检查是否是屏蔽协议
|
||
if NeedShieldProtocol and ShieldedProtocol[handler] then
|
||
XUiManager.TipMsg(CS.XGame.ClientConfig:GetString("ShieldedProtocol"))
|
||
if shieldReply then shieldReply() end
|
||
return
|
||
end
|
||
|
||
if IsDebug then
|
||
XRpc.DebugPrint(XRpc.DEBUG_TYPE.Send_Call, handler, isEncoded and XMessagePack.Decode(request) or request)
|
||
end
|
||
local requestContent, error
|
||
if isEncoded == true then
|
||
requestContent = request
|
||
else
|
||
requestContent, error = XMessagePack.Encode(request)
|
||
if requestContent == nil then
|
||
XLog.Error("XNetwork.Call 函数错误, 客户端发送给服务端的数据编码处理失败, 失败原因： " .. error)
|
||
return
|
||
end
|
||
end
|
||
|
||
CS.XNetwork.Call(handler, requestContent, function(responseContent)
|
||
local response, err = XMessagePack.Decode(responseContent)
|
||
if response == nil then
|
||
XLog.Error("XNetwork.Call 函数错误, 服务端返回的数据解码失败, 失败原因: " .. err)
|
||
return
|
||
end
|
||
|
||
if IsDebug then
|
||
XRpc.DebugPrint(XRpc.DEBUG_TYPE.Recv_Call, handler, response)
|
||
end
|
||
|
||
reply(response)
|
||
end, exReply)
|
||
end
|
||
|
||
function XNetwork.CallWithAutoHandleErrorCode(handler, request, reply, isEncoded)
|
||
XNetwork.Call(handler, request, function(res)
|
||
if res.Code ~= XCode.Success then
|
||
XUiManager.TipCode(res.Code)
|
||
return
|
||
end
|
||
if reply then reply(res) end
|
||
end, isEncoded)
|
||
end
|
||
|
||
--================
|
||
--设置协议屏蔽列表
|
||
--@param protocolList:屏蔽协议名列表
|
||
--================
|
||
function XNetwork.SetShieldedProtocolList(protocolList)
|
||
if not protocolList then return end
|
||
ShieldedProtocol = {}
|
||
NeedShieldProtocol = false
|
||
for _, protocolName in pairs(protocolList) do
|
||
NeedShieldProtocol = true
|
||
ShieldedProtocol[protocolName] = true
|
||
end
|
||
end
|