自行设计消息队列
需求描述
- 能够存储消息
- 能够获取消息
- 能够区分topic
接口设计
时序图
消息入队:
消息出队:
拓展点:
完全依赖Storage作为拓展点,若是单机消息队列,则直接实现单机Storage
若是集群存储则实现集群Storage
若是分布式存储则实现分布式的Storage
所有上层操作依赖Storage接口
已经默认实现了的单机Storage
分别是CompressFileStorage, SplitFileStorage
分别实现场景是,单消息单文件存储
多消息单文件存储
Github地址:
https://github.com/michaelssss/MyQueue