消息队列

消息池

• 存储所有收到的消息（添加 time 属性，num 作索引）
• 将消息放入消息队列中异步处理
• 维护 seq-num 的消息索引
• 定期清理过期消息
• 根据序号/ID 返回消息（数据，需要重新格式化为消息对象）

消息队列

• 单容器消息处理不需要使用 RabbitMQ、Redis Streams、Kafka
• 且已经在其他地方实现了数据备份与容灾
• 消息队列主要起到使逻辑清晰的作用