【数据存储】死信队列：处理失败消息的兜底机制

local DEAD = {}
local function toDeadLetter(msg, err)
    table.insert(DEAD, { msg = msg, err = err, retry = 0 })
end
local function process(msg)
    local ok, err = pcall(handle, msg)
    if not ok then
        toDeadLetter(msg, tostring(err))
    end
end

setontimerex(210, 3600)
function ontimer210()
    local kept = {}
    for _, d in ipairs(DEAD) do
        if d.retry < 3 then
            d.retry = d.retry + 1
            local ok = pcall(handle, d.msg)
            if not ok then
                table.insert(kept, d)
            end
        else
            table.insert(kept, d)
            sendmail("#值班老张", 943, "死信需人工处理", "积压 " .. #kept .. " 条", "")
        end
    end
    DEAD = kept
end