store启动
this.reputMessageService.start(); 这个服务会定时分拣到达的消息到其他消费队列里去
doreput主要就是干dispatch分拣
store会遍历所有实现dispatch接口的分拣器,调用他们的分拣接口
而有个分拣器完成cosumequeue的建立
this.reputMessageService.start(); 这个服务会定时分拣到达的消息到其他消费队列里去
doreput主要就是干dispatch分拣
store会遍历所有实现dispatch接口的分拣器,调用他们的分拣接口
而有个分拣器完成cosumequeue的建立
本文标题:rocketmq源码之store模块
本文链接:https://www.haomeiwen.com/subject/hvcipxtx.html
网友评论