【网络通信】重连风暴：大版本更新后的重连洪峰治理

local tokens = 1000
local RATE = 200
setontimerex(211, 1)
function ontimer211()
    tokens = math.min(1000, tokens + RATE)
end
local function admitConnection()
    if tokens >= 1 then
        tokens = tokens - 1
        return true
    end
    return false
end

local waitQueue = { reconnect = {}, newLogin = {} }
local function enqueue(connType, actorId)
    table.insert(waitQueue[connType], actorId)
end
setontimerex(212, 1)
function ontimer212()
    for _, connType in ipairs({ "reconnect", "newLogin" }) do
        local q = waitQueue[connType]
        while #q > 0 and admitConnection() do
            local actorId = table.remove(q, 1)
            processConnection(actorId)
        end
    end
end