细腻花卷

文章
4
资源
0
加入时间
3年0月28天

RocketMQ入门

可以看到一个topc下有多个queue,每个queue都存放着message,每个message可能还会有tag,按照顺序发送给消费者consumer,发过的消息都在offset后面。MQ会为每个broker维护一个commitlog,一旦文件存放到commitlog,消息就不会丢失。当无法拉取消息时,broker允许producer在30s内发送一个消息,然后直接给消费者消费。后两个索引文件的维护是基于一个线程ReputMessageService去异步维护后两个索引文件。