go-diskqueue
A Go package providing a filesystem-backed FIFO queue
Pulled out of https://github.com/nsqio/nsq
说明：基于go-diskqueue的改造版本
- 去除原先depth属性
- 去除自动轮转与自动删除的策略，为了适应某些场景需要重新读取队列
- 增加基于时间轮转的功能，每过一个时间周期，轮转一次队列的实际存储名字
- 此roll queue将写入记录持续不断地写入进来，并且保证数据至少被消费一遍
- 如果调用者不手动提交删除操作，则队列不会删除，在重启后，队列里面的数据会被再消费一遍，所以说重复读是大概率事情
- 此队列的场景是保证数据不丢，而不是保持消费一次