Consumer运行原理
2022-03-29 09:47:56 0 举报
RocketMQ源码
作者其他创作
大纲/内容
BrokerLeader节点
提交消费进度内存
异步
消费者组
开启
失败消息
提交任务
后台线程
写入数据
每隔5秒检查新消息
ConsumerQueue
Consumer
NamerServer注册中心
磁盘文件
注册+心跳路由信息
ProcessQueue
后台线程长轮询
业务系统
内存-消费进度ConsumerGroup
定时检查
写入commitlog
延迟结束改写为原来topic
主从复制
RebalanceServeic重平衡组件
注册
分配队列给消费者
拉取线程
回调监听业务代码
删除处理成功的消息
写入消息
拉取 pull & push
Broker从节点
并发处理
响应处理结果成功/失败
线程池
改写topic为延时toptic
一一对应关系
Producer
延迟消息后台线程
消息失败处理机制
处理失败消息放入延时队列
Page Cache磁盘文件
0 条评论
回复 删除
下一页
