rocketMq-延迟消息介绍

作者: 晴天哥_王志 | 来源:发表于2018-03-21 21:18 被阅读337次

    在rocketMq的消息体系中,很重要的一个消息体系是延迟消息,以前需要定时去实现的任务现在有rocketMq自身帮忙解决了,这篇文章主要是讲解清楚延迟消息的实现细节,延迟消息的是细节,延迟消息的实现细节,重要的事情说3遍。

    延迟消息的整个流转过程 

        1、消息先写入commitlog文件

        2、消费线程将数据保存以SCHEDULE_TOPIC_XXX的topic下面并且以延迟粒度作为queueId区分

        3、定时任务扫描SCHEDULE_TOPIC_XXX下的每个Queue启一个线程进行消费,到时间后写到consumeQueue当中。

        4、参考下面目录,SCHEDULE_TOPIC_XXX目录下面以延迟粒度作为queue的区分

        5、每个粒度的都会启动一个定时任务,消费任务后隔0.1s继续扫描

        6、判断消息是否到期了通过当前时间点和延迟时间对比

        7、真正的消息保存在commitLog当中,SCHEDULE_TOPIC_XXX下面的消息相当于对commitLog立面的存的消息的偏移量等做了一层包装,consumeQueue里面的消息其实是从SCHEDULE目录下获取得。

    延迟消息队列目录

    SCHEDULE_TOPIC_XXX消息生成

    commitLog消息同步到SCHEDULE_TOPIC_XXX当中

    说明:参见DefaultMessageStore类

    延迟消息消费

    解析延迟粒度

    说明:参见DefaultMessageStore类。

        1、根据不同的粒度启动扫描任务

    启动延迟消息的定时任务 消费延迟队列到consumeQueue队列

    说明:参见ScheduleMessageService类

        1、根据时间戳进行对比

    定时启动下一次扫描粒度

    说明:参见ScheduleMessageService类

        1、启动下一次任务扫描

    相关文章

      网友评论

        本文标题:rocketMq-延迟消息介绍

        本文链接:https://www.haomeiwen.com/subject/wkpyqftx.html