ROCKETMQ消息消费原理

2019独角兽企业重金招聘Python工程师标准>>> express 摘要 下面的阅读顺序是基于并发消费的逻辑来看的。正常消费逻辑是broker端收到消息以后，通过tag过滤，通知订阅的客户端来拉取消息。这个通知暂时被存放在客户端的阻塞队列中。客户端一直循环从这个队列中取通知，根据通知去拉消息。本地拉消息以前会校验本地的消息堆积状况（不找过1000个，大小不超过100M），拉过来以后校验tag过

>>阅读原文<<