RocketMQ高级

    科技2025-04-26  18

    文章目录

    RocketMQ的消息存储结构RocketMQ的刷盘机制RocketMQ高可用机制RocketMQ负载均衡Producer负载均衡Consumer负载均衡 消息重试死信队列消费幂等

    RocketMQ的消息存储结构

    ConsumerQueue类似于CommitLog的索引文件(按偏移量查找),体积很小IndexFile:为消息查询提供了一种通过key或者时间区间来查询的方法,体积大

    RocketMQ的刷盘机制

    RocketMQ的消息是存储到磁盘上的,这样既能保证断电后恢复,又可以让存储的消息量超出内存的限制。消息在通过Producer写入RocketMQ的时候,有两种写磁盘的方式,分布式同步刷盘和异步刷盘。

    RocketMQ高可用机制

    异步刷盘+主从同步复制。

    RocketMQ负载均衡

    Producer负载均衡

    Consumer负载均衡

    集群模式天然负载均衡广播模式没有负载均衡的说法

    消息重试

    死信队列

    消费幂等

    Processed: 0.021, SQL: 8