Snail MQ 是一个简单易懂的消息队列实现。目的在于学习和巩固知识。
Snail在消息存储上借鉴了RocketMQ,具有CommitLog和CommitQueue。Log和Queue使用MappedFile进行尾追加写。
- 消息读写
- ack
- 多种ack模式
- 异步同步发送(netty)
- 多种刷盘模式
- key相同,顺序消息
- 拉取消息push模式
- boot-starter
- 重平衡
- 多种重平衡策略
客户端starter
<dependency>
<groupId>io.github.project-snail</groupId>
<artifactId>snailmq-client-boot-starter</artifactId>
<version>1.0.0</version>
</dependency>