【网络通信】流量统计：上下行流量的分协议统计

---流量统计：按协议号分桶计数
local Traffic = { up = {}, down = {} }

function Traffic.countUp(msgId, bytes)
    Traffic.up[msgId] = (Traffic.up[msgId] or 0) + bytes
end

function Traffic.countDown(msgId, bytes)
    Traffic.down[msgId] = (Traffic.down[msgId] or 0) + bytes
end

---网关的发送与接收钩子
function Gateway.onSend(conn, msgId, body)
    Traffic.countDown(msgId, #body + 6)
end

function Gateway.onRecv(conn, msgId, body)
    Traffic.countUp(msgId, #body + 6)
end

---流量的报表：按协议排序输出
setontimerex(149, 60)
function Traffic.report()
    local up = {}
    for msgId, bytes in pairs(Traffic.up) do
        up[#up + 1] = { id = msgId, bytes = bytes }
    end
    table.sort(up, function(a, b) return a.bytes > b.bytes end)
    for i = 1, math.min(10, #up) do
        Ops.log(string.format('上行 Top%d %s %dKB',
            i, MsgRoute.nameOf(up[i].id),
            math.floor(up[i].bytes / 1024)))
    end
    for k in pairs(Traffic.up) do Traffic.up[k] = 0 end
end