联合 https://blog.csdn.net/prestig… 作者文章
生产端的次要性能有启动消费者,敞开消费者,同步或异步推或者拉取音讯,获取指定音讯生产队列的生产进度,获取以后正在解决的音讯生产队列,订阅主题,勾销订阅,注册并发生产模式监听器等性能。
在 RocketMQ 的外部实现原理中,其实现机制为 PULL 模式,而 PUSH 模式是一种伪推送,是对 PULL 模式的封装。每拉去一批音讯后,提交到生产端的线程池(异步),而后马上向 Broker 拉取音讯,即实现相似“推”的成果。为什么要对拉取的根底上再封装出推送呢?次要是拉取模式对使用者不敌对,对使用者要求比拟高,封装成推送后的 API 简略。
别离介绍拉取与推送的具体流程。
RocketMQ 不保障音讯反复生产起因剖析(第 9 章)
ConsumeFromWhere 注意事项 (10 章)
订阅关系不统一导致音讯失落
Lite Pull 与 PUSH 模式之比照(11 章)
长轮询实现原理
PUSH 与 PULL 模式选型(12 章)