美文网首页
rocketmq源码之store模块

rocketmq源码之store模块

作者: Gahdamn | 来源:发表于2017-11-03 14:39 被阅读0次

    store启动

    this.reputMessageService.start();   这个服务会定时分拣到达的消息到其他消费队列里去


    doreput主要就是干dispatch分拣


    store会遍历所有实现dispatch接口的分拣器,调用他们的分拣接口


    而有个分拣器完成cosumequeue的建立


    相关文章

      网友评论

          本文标题:rocketmq源码之store模块

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