RocketMQ消息拉取&消费&ACK
2021-04-28 10:24:02 0 举报介绍基于RocketMQ的消息拉取、消费、ACK
作者其他创作
大纲/内容
mqsAll
PullRequest
16': ACK本地消费进度(mq已drop|订阅已取消|)
ConsumeRequest
15. 删除本地消息
消费进度
13. 放回PullRequest
16. 更新本地消费进度
业务线程池
10. 返回消息、下次拉取偏移量
6. 保存MQ到本地处理表
cidAll
8. 取出PullRequest
11. 消息缓存本地
5. IDC优先重分配（mqsAll-cidsAll)
Runnable
1. 新增主题订阅
主题订阅表
Client
MQ处理表
t1
Subscription1
t2
Subscription2
...
9. 拉取消息(带上本地偏移)
BROKER
定时任务(5s)
mq
pq
broker1-t1-q0
msgMap
2. 注册订阅
7. 新增消息拉取请求
4 查topic订阅列表
9':查本地ACK偏移
broker1-t1-q1
1001
12. 每条消息提交消费异步任务
mq消费进度(尚存消息最小偏移)
3 查topic的mq分布
请求队列
NameSvr
拉取回调
消费线程池
收藏
0 条评论
下一页
