新增在线人数日志

common/utils/serverLogUtil.lua

@@ -2,6 +2,7 @@
 local skynet = require "skynet"
 local timeUtil = require "utils.timeUtil"
 local lib_game_redis = require("lib_game_redis")
+local redisUtil = require("utils.redisUtil")
 
 local root = {}
 
@@ -196,4 +197,47 @@ function root.logBandShareCode(uid, bandShareCode, channel, version)
     writeServerLog("banding", date, dataStr)
 end
 
+-- 在线人数
+function root.logOnlineCount()
+    local mapCount = redisUtil.hgetall("online:count")
+    log.info("logOnlineCount mapCount[%s]", tostring(mapCount))
+    if is_empty(mapCount) then
+        return
+    end
+
+    local now = timeUtil.currentTime()
+    local date = timeUtil.toDate(now)
+    local dateStr = timeUtil.toString(now)
+
+    -- 全服
+    if mapCount["all"] then
+        local data = {
+            date,
+            dateStr,
+            "",
+            "",
+            mapCount["all"]
+        }
+        local dataStr = root.formatData(data)
+
+        writeServerLog("onlinecount", date, dataStr)
+    end
+    -- 主播
+    for k, v in pairs(mapCount) do
+        if string.match(k, "bandShareCode") and tonumber(v) > 0 then
+            local arr = string.split(k, ":")
+            local data = {
+                date,
+                dateStr,
+                arr[2],
+                "",
+                v
+            }
+            local dataStr = root.formatData(data)
+
+            writeServerLog("onlinecount", date, dataStr)
+        end
+    end
+end
+
 return root

dev/utils/util_online.lua

@@ -0,0 +1,53 @@
+--[[
+Descripttion:玩家信息
+version:
+Author: Neo,Huang
+Date: 2022-05-26 19:45:58
+LastEditors: Neo,Huang
+LastEditTime: 2022-05-26 19:46:41
+--]]
+local moduleData = require("data.module")
+local lib_game_redis = require("lib_game_redis")
+
+local root = {}
+
+-- 新增在线人数
+function root:add_online_count(uid)
+    if is_empty(uid) or is_robot(uid) then
+        return false
+    end
+    local channel = moduleData:get_channel(uid)
+    local bandShareCode = moduleData:hget(uid, "user", "bandShareCode")
+    local key = "online:count"
+    -- 全服人数
+    lib_game_redis:hincrby(key, "all", 1)
+    -- 渠道
+    if not is_empty(channel) then
+        lib_game_redis:hincrby(key, string.format("channel:%s", tostring(channel)), 1)
+    end
+    -- 主播
+    if not is_empty(bandShareCode) then
+        lib_game_redis:hincrby(key, string.format("bandShareCode:%s", tostring(bandShareCode)), 1)
+    end
+end
+-- 减少在线人数
+function root:sub_online_count(uid)
+    if is_empty(uid) or is_robot(uid) then
+        return false
+    end
+    local channel = moduleData:get_channel(uid)
+    local bandShareCode = moduleData:hget(uid, "user", "bandShareCode")
+    local key = "online:count"
+    -- 全服人数
+    lib_game_redis:hincrby(key, "all", -1)
+    -- 渠道
+    if not is_empty(channel) then
+        lib_game_redis:hincrby(key, string.format("channel:%s", tostring(channel)), -1)
+    end
+    -- 主播
+    if not is_empty(bandShareCode) then
+        lib_game_redis:hincrby(key, string.format("bandShareCode:%s", tostring(bandShareCode)), -1)
+    end
+end
+
+return root

nodes/game/lib/role.lua

@@ -1,6 +1,7 @@
 local dataMode = require "dataMode"
 local timeUtil = require("utils.timeUtil")
 local serverLogUtil = require("utils.serverLogUtil")
+local util_online = require("utils.util_online")
 
 local sessionData = require("data.session")
 local moduleData = require("data.module")
@@ -34,6 +35,8 @@ function root:login(session)
     -- 模块载入热数据
     self:load_modules()
 
+    -- 在线人数
+    util_online:add_online_count(self.uid)
     -- 初始化session 信息
     local nodeInfo = {nodeName = session.gateNode, agent = session.gateAgent}
     sessionData:user_update_cluster_info(self.uid, "gate", nodeInfo)
@@ -74,6 +77,8 @@ function root:logout_modules()
     -- 删除玩家session信息
     sessionData:user_update_cluster_info(self.uid, "gate")
     sessionData:user_update_cluster_info(self.uid, "game")
+    -- 在线人数
+    util_online:sub_online_count(self.uid)
 end
 
 -- 初始化游戏事件

nodes/global/main.lua

@@ -30,6 +30,7 @@ skynet.start(
         skynet.uniqueservice("battlerecordSrv")
         skynet.uniqueservice("rollSrv")
         skynet.uniqueservice("itemrecordSrv")
+        skynet.uniqueservice("onlineSrv")
 
         -- 集群
         init_nodes:init_cluster()

nodes/global/service/onlineSrv.lua

@@ -0,0 +1,31 @@
+--[[
+Descripttion:追梦
+version:
+Author: Neo,Huang
+Date: 2023-11-16 21:45:09
+LastEditors: Neo,Huang
+LastEditTime: 2023-11-16 23:20:12
+--]]
+local timer = require("timer")
+local baseService = require("baseService")
+local serverLogUtil = require "utils.serverLogUtil"
+
+local timerOnlineLog = nil
+
+local root = {}
+
+-- 在线人数
+local function _online_log()
+	serverLogUtil.logOnlineCount()
+end
+
+function root.onStart()
+	timerOnlineLog = timer.timeOut(60, _online_log)
+end
+
+function root.onStop()
+	-- 取消定时器
+	timerOnlineLog.func = nil
+end
+
+baseService.start(root, ".onlineSrv", true)