文章目录
RocketMQ的消息存储结构RocketMQ的刷盘机制RocketMQ高可用机制RocketMQ负载均衡Producer负载均衡Consumer负载均衡
消息重试死信队列消费幂等
RocketMQ的消息存储结构
ConsumerQueue类似于CommitLog的索引文件(按偏移量查找),体积很小IndexFile:为消息查询提供了一种通过key或者时间区间来查询的方法,体积大
RocketMQ的刷盘机制
RocketMQ的消息是存储到磁盘上的,这样既能保证断电后恢复,又可以让存储的消息量超出内存的限制。消息在通过Producer写入RocketMQ的时候,有两种写磁盘的方式,分布式同步刷盘和异步刷盘。
RocketMQ高可用机制
异步刷盘+主从同步复制。
RocketMQ负载均衡
Producer负载均衡
Consumer负载均衡
集群模式天然负载均衡广播模式没有负载均衡的说法
消息重试
死信队列
消费幂等