《Lua游戏开发实战》10.4 日志与监控

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

local logger = {}

-- 日志级别
local LOG_LEVELS = {INFO = 1, WARN = 2, ERROR = 3}

-- 当前日志级别
local current_level = LOG_LEVELS.INFO

-- 设置日志级别
function logger.set_log_level(level)
    current_level = level
end

-- 记录日志
function logger.log(level, message)
    if level >= current_level then
        local log_entry = string.format("[%s] %s: %s", os.date("%Y-%m-%d %H:%M:%S"), level, message)
        -- 将日志记录到文件或数据库
        -- 假设我们将日志记录到文件
        local file = io.open("game_log.txt", "a")
        file:write(log_entry .. "\n")
        file:close()
    end
end

-- 记录不同级别的日志
function logger.info(message)
    logger.log("INFO", message)
end

function logger.warn(message)
    logger.log("WARN", message)
end

function logger.error(message)
    logger.log("ERROR", message)
end

return logger

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14

local logger = {}

-- 假设日志文件路径
local log_file_path = "logs/game_log.txt"

-- 记录日志到文件
function logger.write_log_to_file(level, message)
    local log_entry = string.format("[%s] %s: %s", os.date("%Y-%m-%d %H:%M:%S"), level, message)
    local file = io.open(log_file_path, "a")
    if file then
        file:write(log_entry .. "\n")
        file:close()
    end
end

1
2
3
4
5
6
7

local kafka = require "kafka_client"  -- 假设我们使用一个 Kafka 客户端库

-- 发送日志到 Kafka
function logger.send_to_kafka(level, message)
    local log_entry = string.format("[%s] %s: %s", os.date("%Y-%m-%d %H:%M:%S"), level, message)
    kafka.send("game_logs", log_entry)  -- 发送到 Kafka 的 game_logs 主题
end

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

local monitor = {}

-- 假设我们使用一个库来获取系统资源
local sys = require "sys_resources"

-- 定时检查服务器资源
function monitor.check_server_health()
    local cpu_usage = sys.get_cpu_usage()
    local memory_usage = sys.get_memory_usage()
    local disk_usage = sys.get_disk_usage()

    -- 判断是否超过阈值
    if cpu_usage > 90 then
        logger.warn("CPU usage is high: " .. cpu_usage .. "%")
    end
    if memory_usage > 80 then
        logger.warn("Memory usage is high: " .. memory_usage .. "%")
    end
    if disk_usage > 85 then
        logger.warn("Disk usage is high: " .. disk_usage .. "%")
    end
end

-- 定时任务：每5秒检查一次
skynet.timer(5, monitor.check_server_health)

1
2
3
4
5
6
7
8
9

local function check_service_status()
    local status = skynet.call("game_logic_service", "status")
    if status ~= "ok" then
        logger.warn("Game logic service is down!")
    end
end

-- 定时检查服务状态
skynet.timer(10, check_service_status)

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17

local performance_monitor = {}

-- 监控服务的响应时间
function performance_monitor.check_response_time()
    local start_time = skynet.now()
    -- 调用服务
    skynet.call("game_logic_service", "lua", "process_request")
    local end_time = skynet.now()
    
    local response_time = end_time - start_time
    if response_time > 100 then  -- 如果响应时间超过100ms，触发报警
        logger.warn("Response time is too high: " .. response_time .. "ms")
    end
end

-- 定时检查响应时间
skynet.timer(5, performance_monitor.check_response_time)

1
2
3
4
5

local function send_alert(message)
    -- 发送邮件、短信或钉钉消息
    -- 这里假设有一个 send_email 函数
    send_email("admin@game.com", "System Alert", message)
end