AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
Consumer运行原理
2022-03-29 09:47:56
0
举报
分享方式
仅支持查看
RocketMQ源码
rocketmq
模板推荐
作者其他创作
大纲/内容
BrokerLeader节点
提交消费进度内存
异步
消费者组
开启
失败消息
提交任务
后台线程
写入数据
每隔5秒检查新消息
ConsumerQueue
Consumer
NamerServer注册中心
磁盘文件
注册+心跳路由信息
ProcessQueue
后台线程长轮询
业务系统
内存-消费进度ConsumerGroup
定时检查
写入commitlog
延迟结束改写为原来topic
主从复制
RebalanceServeic重平衡组件
注册
分配队列给消费者
拉取线程
回调监听业务代码
删除处理成功的消息
写入消息
拉取 pull & push
Broker从节点
并发处理
响应处理结果成功/失败
线程池
改写topic为延时toptic
一一对应关系
Producer
延迟消息后台线程
消息失败处理机制
处理失败消息放入延时队列
Page Cache磁盘文件
收藏
立即使用
Consumer运行原理
收藏
立即使用
Producer端核心流程（rocketmq）
收藏
立即使用
Broker基于raft协议的主从架构
收藏
立即使用
RocketMQ原理深入剖析
大大大大大
职业：程序员
去主页
Collect
Get Started
原理
Collect
Get Started
运行时
Collect
Get Started
PHP运行方式
Collect
Get Started
session-data-share-class-consumer
评论
0
条评论
下一页
Document
