在平時玩手機遊戲的時候，有時候會碰到網路斷開連線的情況，那麼在工程中，我們是怎麼解決這種情況的呢？

沒錯，心跳包，在遊戲過程中，每過一段時間，客戶端會向伺服器傳送一個很短或者空的資料，根據判斷是否有返回的資料，可以知道，是否正在連線。介紹不多說，我們看程式碼

local IDispose=require("Core/IDispose")
local HeartbeatCtrl = class("HeartbeatCtrl",IDispose);

HeartbeatCtrl.MAX_DELAY_TIME=30--檢測心跳的時間
--心跳包控制器
function HeartbeatCtrl:ctor()
    self:EventInit()
    self:SocketInit()
end

function HeartbeatCtrl:SocketInit()
    _G_Socket:AddPropertyEvent(SocketStatic.SERVER_LOGIN,HeartbeatCtrl.Start,self)
    _G_Socket:AddPropertyEvent(rpc_info.rpc_dict.keepAlive,HeartbeatCtrl.HeartbeatCallBack,self)
end

function HeartbeatCtrl:RemoveSocket()
    _G_Socket:RemovePropertyEvent(SocketStatic.SERVER_LOGIN,HeartbeatCtrl.Start,self)
    _G_Socket:RemovePropertyEvent(rpc_info.rpc_dict.keepAlive,HeartbeatCtrl.HeartbeatCallBack,self)
end

function HeartbeatCtrl:EventInit()

    _G_Dispatcher:AddPropertyEvent(GameStatic.START_ENTER_GAME,HeartbeatCtrl.Stop,self);
    _G_Dispatcher:AddPropertyEvent(GameStatic.SERVER_SHUT_DOWN,HeartbeatCtrl.Stop,self);
end

function HeartbeatCtrl:RemoveEvent()

    _G_Dispatcher:RemovePropertyEvent(GameStatic.START_ENTER_GAME,HeartbeatCtrl.Stop,self);
    _G_Dispatcher:RemovePropertyEvent(GameStatic.SERVER_SHUT_DOWN,HeartbeatCtrl.Stop,self);
end

function HeartbeatCtrl:Start()
    -- print("===========================    開啟心跳       ========================")
    self.sendCount=0
    self.receiveCount=0
    self.lastReceiveTime=0
    self.lastSendTime=0
    self.lastDelayTime=0
    self.timer = Timer.New(function()self:Heartbeat() end,25,-1,false)
    self.timer:Start()
    self:Heartbeat()

    FixedUpdateBeat:Add(self.Update, self)
end

function HeartbeatCtrl:Update(deltaTime,unscaledDeltaTime)
    if self:CheckTimeOut()==true then 
        self:Stop()
        self:TimerClean()
        --[[_G_Dispatcher:AddPropertyEvent(GameStatic.RE_CONNECT_SERVER_SUCESS,HeartbeatCtrl.ReConnectServerSucess,self)
        PreloadTip.instance:ShowStayTips("連線中斷，正在嘗試重新連線...");--]]
        Network.ConnectFailed()  
        -- local data = {}
        -- data.text = "斷開連線，是否重新連線遊戲？"
        -- data.callback = function() Game.EnterGame() end
        -- CommonPopup(data)
    end
end

function HeartbeatCtrl:ReConnectServerSucess()
    PreloadTip.instance:Reset()
    _G_CtrlManager.ins.login:SendEnterGame()
    self:Start()
    _G_Dispatcher:RemvoePropertyEvent(GameStatic.RE_CONNECT_SERVER_SUCESS,HeartbeatCtrl.ReConnectServerSucess,self)

end

function HeartbeatCtrl:Stop()
    self:TimerClean()
    FixedUpdateBeat:Remove(self.Update, self)
end

function HeartbeatCtrl:HeartbeatCallBack(eventType,dispatch)
    self.receiveCount=self.receiveCount+1
    self.lastReceiveTime=os.time()
    self.lastDelayTime = self.lastReceiveTime - self.lastSendTime;

    local serverTime=dispatch.now
    _G_TimerManager:SetServerTime(serverTime)
end

--獲取上一次的延時資訊
function HeartbeatCtrl:GetLastDelayTime()
    if self.sendCount == self.receiveCount then
        return self.lastDelayTime;
    end

    local currentDelayTime = os.time() - self.lastSendTime;
    if currentDelayTime < self.lastDelayTime then 
        return self.lastDelayTime;
    end
    
    return currentDelayTime;
end

function HeartbeatCtrl:Heartbeat()
    self.sendCount=self.sendCount+1
    self.lastSendTime=os.time()
    
    local id = rpc_info.rpc_dict.keepAlive
    local data = {}
    Network.SendMessage(id,data)
end

function HeartbeatCtrl:CheckTimeOut()
    -- print(self:GetLastDelayTime(),self.sendCount,self.receiveCount)
    -- if not self.test then 
    --     self.test=true
    --     return true
    -- end
    return self:GetLastDelayTime() > HeartbeatCtrl.MAX_DELAY_TIME
end

function HeartbeatCtrl:TimerClean()
    if self.timer then 
        self.timer:Stop();
        self.timer=nil
    end
end

function HeartbeatCtrl:Dispose()
    self:RemoveSocket()
    self:RemoveEvent()
    self:TimerClean()
end

return HeartbeatCtrl