动手造轮子 - 实现支持 Ack 的内存队列
💡
原文中文，约4700字，阅读约需12分钟。
📝
内容提要
本文介绍了AckQueue的实现，该内存队列在消息消费成功后才移除消息，并支持定时将未确认的消息重新入队。示例代码展示了AckQueue的入队、出队和确认操作。
🎯
关键要点
-
本文介绍了AckQueue的实现，该内存队列在消息消费成功后才移除消息。
-
AckQueue支持定时将未确认的消息重新入队。
-
示例代码展示了AckQueue的入队、出队和确认操作。
-
创建AckQueue时可以指定AckTimeout，方便测试。
-
使用ConcurrentQueue或Channel实现内存队列，避免消息丢失。
-
实现代码中包含AckQueueOptions和AckQueue类的定义。
-
AckQueue类中包含入队、出队、确认消息和重新入队未确认消息的方法。
-
为了实现自动化，添加了一个Timer定期重新将未及时Ack的消息加入队列。
-
实现是基于内存的，讨论了基于Redis实现更可靠的消息队列的可能性。
➡️
