RocketMQ Consumer消费消息流程
2022-11-12 13:08:08 7 举报RocketMQ Consumer消费消息流程
作者其他创作
大纲/内容
run()
ConsumeRequest（线程）
ConsumeMessageConcurrentlyService
RemoteBrokerOffsetStore
处理消费结果
执行消息消费钩子函数
定时向broker同步消费进度
将这次消费的消息从ProcessQueue中移除，并返回消费进度
创建消费者并发消费的上下文环境
设置ackIndex
更新本地该队列的消费进度缓存
调用自定义的消费逻辑
0 条评论
下一页
