mq延迟消费
2021-12-20 17:52:12 3 举报mq延迟消费
作者其他创作
大纲/内容
SCHEDULE_TOPIC
2:延迟消息放到延迟topic
4:将达到发送要求的消息重新推向commitLog
consume
commitlog
1:发送延迟消息
延迟消息服务ScheduleMessageService
5
6:消息消费者拉取消息
3消费者拉延迟消息
Broker
es更新成功发送延迟消息
此时es发生变更后能准确统计到数据
DELAY_TOPIC
producer
重新统计es数据
收藏
收藏
0 条评论
下一页
