Stream数据结构
2 分钟阅读
•
223 字
+
158 词
Stream实现原理
- 没有ACK机制
- 没有类似Kafka的消费者组的概念
- 消息堆积
- Lists是线性结构, 查询指定数据需要遍历整个列表
- 使用Radix Tree(压缩前缀树)和listpack结构来存储消息。
- 序列化生成消息ID
- 将多个消费者划分到不同的消费者组中。
- 支持多播、阻塞和非阻塞读取。
- ACK确认机制,保证了消息至少被消费一次。
- 可配置消息保存上限阈值,将历史消息丢弃,防止内存占用过大。