RocketMQ架构：Consumer分配queue
2024-05-08 11:22:45 0 举报RocketMQ架构：Consumer分配queue
作者其他创作
大纲/内容
对应
Consumer 消费者
consume queue
process queue
8、返回消费状态码SUCCESS
RebalanceService
后台线程
6、并发处理消息
12、broker 异步将消费进度写入磁盘文件
调用我们自己定义的业务逻辑listener.consumeMessage
2、给当前 consumer 分配 queue
11、异步将消费进度提交到 broker
消息拉取线程
10、提交消费进度到 consumer 内存中
9、将处理成功的消息从 queue 中删除
3、拉取消息
4、写入消息
磁盘文件
业务系统
7、回调监听器
process queue
5、将处理消息任务提交到线程池
线程池
1、先从 broker 获取 consumer group、Topic 下的 queue 信息
内存 -> 消费进度
Broker
0 条评论
下一页
