RocketMQ---消息存储

1.消息存储的原理如下: 1.1 CommitLog 1.消息存储文件,所有消息主题都存储到CommitLog中; 2.commitLog每个大小为1G,方便做内存映射; 3.commitLog的文件名为为该文件第一条消息的物理偏移量。 1.2 ConsumeQueue 1.消息消费队列:消息到达CommitLog后,将异步发送给消息消费队列供消费者消费(根据偏移量查找消息,从偏移量读取size长
相关文章
相关标签/搜索