概述
RocketMQ主从消息的处理流程：
消息到主服务器会从commitLog类中的topicQueueTable<String /* topic-queueid*, Long/*offset*/>表中获取到这条消息在这个队列的偏移量，这个偏移量就是后面进入comsumeQueue的logicoffset。每来一条消息这个值都会加1。
从服务器数据中的消息的logicoffset已经在主服务器设置好了，所以从服务器不会更新这个数据结构，当主从切换后会发生数据不一致的情况。如下
最后
以上就是安详含羞草为你收集整理的rocketMQ主从问题的全部内容，希望文章能够帮你解决rocketMQ主从问题所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
发表评论 取消回复