为保证系统消息一定消费 ，设计补偿系统监控死信队列记录到数据库

可以使用 RabbitMQ 的死信队列功能，将消费失败的消息转发到死信队列中，并在死信队列中设置一个 TTL 时间，超时后将消息发送到补偿队列中重新消费。同时，可以在补偿队列中记录消费失败的消息，以便后续进行处理和分析。以下是一个示例的代码实现：

-- 创建死信队列
channel:queue_declare("dead_letter_queue", {
    durable = true,
    arguments = {
        ["x-dead-letter-exchange"] = "",
        ["x-dead-letter-routing-key"] = "compensation_queue",
        ["x-message-ttl"] = 60000 -- 设置 TTL 时间为 60 秒
    }
})

-- 创建补偿队列
channel:queue_declare("compensation_queue", {
    durable = true
})

-- 监听死信队列
channel:basic_consume("dead_letter_queue", function (delivery_info, properties, body)
    -- 记录消费失败的消息到数据库
    db:insert("failed_messages", {
        message_id = properties.message_id,
        message_body = body,
        timestamp = os.time()
    })

    -- 将消息发送到补偿队列中重新消费
    channel:basic_publish("", "compensation_queue", body, {
        message_id = properties.message_id
    })
end)

-- 监听补偿队列
channel:basic_consume("compensation_queue", function (delivery_info, properties, body)
    -- 处理消息
    process_message(body)

    -- 确认消息已经消费
    channel:basic_ack(delivery_info.delivery_tag)
end)

关于中文加密，可以使用一些常见的加密算法，如 AES、DES、RSA 等，只需要将明文转换成字节流，然后使用相应的加密算法进行加密，最后将密文转换成中文即可。以下是一个示例的代码实现：

local aes = require("resty.aes")

-- 加密密钥
local key = "1234567890123456"

-- 加密算法
local cipher = aes:new(key, aes.cipher(128, "cbc"), aes.new_iv(16))

-- 明文
local plaintext = "中文加密"

-- 转换成字节流
local bytes = { plaintext:byte(1, #plaintext) }

-- 加密
local ciphertext = cipher:encrypt(ngx.encode_base64(bytes))

-- 转换成中文
local result = ""
for i = 1, #ciphertext, 2 do
    result = result .. string.char(tonumber(ciphertext:sub(i, i + 1), 16))
end

print(result) -- 输出加密后的中文