RocketMQ主从消息的处理流程：
消息到主服务器会从commitLog类中的topicQueueTable<String /* topic-queueid*, Long/*offset*/>表中获取到这条消息在这个队列的偏移量，这个偏移量就是后面进入comsumeQueue的logicoffset。每来一条消息这个值都会加1。
从服务器数据中的消息的logicoffset已经在主服务器设置好了，所以从服务器不会更新这个数据结构，当主从切换后会发生数据不一致的情况。如下
最后
以上就是安详含羞草最近收集整理的关于rocketMQ主从问题的全部内容，更多相关rocketMQ主从问题内容请搜索靠谱客的其他文章。
本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
发表评论 取消回复